Skip to content

Commit

Permalink
Update handling of missing server side parameters.
Browse files Browse the repository at this point in the history
When a query parameter is not sent by the client (e.g. older version of client, newer version of server) this would have thrown an exception before.

Query parameter will now use the default value for type if not sent by client (e.g. 0, false, null).
  • Loading branch information
mikedawson committed Jul 14, 2024
1 parent ff7408a commit b5afa11
Show file tree
Hide file tree
Showing 5 changed files with 42 additions and 5 deletions.
2 changes: 1 addition & 1 deletion build.gradle
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ plugins {


group 'com.github.UstadMobile.door'
version '0.79.11'
version '0.79.12'

ext.localProperties = new Properties()

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -612,13 +612,24 @@ fun FileSpec.Builder.addHttpServerExtensionFun(
.apply {
daoFunDecl.parameters.forEachIndexed { index, param ->
add("val _arg_${param.name?.asString()} : %T = ", funAsMemberOfDao.parameterTypes[index]?.toTypeName())
add("json.decodeFromString(")
addKotlinxSerializationStrategy(funAsMemberOfDao.parameterTypes[index]!!, resolver)

if(param.hasAnnotation(RepoHttpBodyParam::class)) {
add(", request.requireBodyAsString())\n")
add("request.bodyAsStringOrNull()")
}else {
add(", request.requireParam(%S))\n", param.name?.asString())
add("request.queryParam(%S)", param.name?.asString())
}
beginControlFlow("?.let")
add("json.decodeFromString(")
addKotlinxSerializationStrategy(funAsMemberOfDao.parameterTypes[index]!!, resolver)
add(", it)\n")
unindent().add("}")

val paramTypeResolved = param.type.resolve()
if(!paramTypeResolved.isMarkedNullable) {
add(" ?: ")
add(param.type.resolve().defaultTypeValueCode(resolver))
}
add("\n")
}

if(daoFunDecl.returnType?.resolve()?.isPagingSource() == true) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -9,10 +9,14 @@ interface DoorJsonRequest {
*/
val db: RoomDatabase

fun queryParam(paramName: String): String?

fun requireParam(paramName: String): String

suspend fun requireBodyAsString(): String

suspend fun bodyAsStringOrNull(): String?

fun requireHeader(header: String): String

fun requireNodeId(): Long
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -11,6 +11,10 @@ class KtorDoorJsonRequestAdapter(
override val db: RoomDatabase,
) : DoorJsonRequest {

override fun queryParam(paramName: String): String? {
return call.request.queryParameters[paramName]
}

override fun requireParam(paramName: String): String {
return call.request.queryParameters[paramName]
?: throw IllegalStateException("requireStringParam: $paramName not found")
Expand All @@ -20,6 +24,11 @@ class KtorDoorJsonRequestAdapter(
return call.receiveText()
}

@Suppress("RedundantNullableReturnType")
override suspend fun bodyAsStringOrNull(): String? {
return requireBodyAsString()
}

override fun requireHeader(header: String): String {
return call.request.header(header) ?: throw IllegalStateException("requireHeader: $header not found")
}
Expand Down
13 changes: 13 additions & 0 deletions door-testdb/src/commonMain/kotlin/db3/DiscussionPostDao.kt
Original file line number Diff line number Diff line change
Expand Up @@ -317,4 +317,17 @@ expect abstract class DiscussionPostDao : RepositoryFlowLoadingStatusProvider {
@Update
abstract suspend fun update(post: DiscussionPost)

@HttpAccessible
@Query("""
SELECT DiscussionPost.*,
Member.firstName AS firstName,
Member.lastName AS lastName
FROM DiscussionPost
LEFT JOIN Member
ON Member.memberUid = DiscussionPost.posterMemberUid
WHERE Member.firstName = :firstName
""")
abstract suspend fun findByName(firstName: String?): List<DiscussionPost>


}

0 comments on commit b5afa11

Please sign in to comment.