feat: FaultException

mmrpc-core:

- added FaultException

mmrpc-server:

- added ApplicationCall.respond(FaultException, ...)

mmrpc-client:

- modified HttpClient.exec(...) to throw FaultException when encountered

Author: lsafer-meemer

mmrpc-client-kotlin/src/commonMain/kotlin/ktor_exec.kt

@@ -2,13 +2,14 @@ package org.cufy.mmrpc.client
 
 import io.ktor.client.*
 import io.ktor.client.call.*
+import io.ktor.client.plugins.*
 import io.ktor.client.request.*
 import io.ktor.http.*
+import io.ktor.http.HttpMethod
+import kotlinx.serialization.json.JsonObject
+import org.cufy.json.asContentStringOrNull
 import org.cufy.json.serializeToJsonString
-import org.cufy.mmrpc.Http
-import org.cufy.mmrpc.HttpEndpointInfo
-import org.cufy.mmrpc.RoutineObject
-import org.cufy.mmrpc.StructObject
+import org.cufy.mmrpc.*
 
 suspend inline fun <reified I : StructObject, reified O : StructObject> HttpClient.exec(
     routine: RoutineObject<I, O>,
@@ -29,18 +30,37 @@ suspend inline fun <reified I : StructObject, reified O : StructObject> HttpClie
     val valueString = input.serializeToJsonString()
     val method = endpoint.method.firstOrNull() ?: Http.POST
 
-    return post {
-        baseurl?.let { this.url.takeFrom(it) }
+    try {
+        return post {
+            baseurl?.let { this.url.takeFrom(it) }
 
-        this.method = HttpMethod.parse(method.name)
-        this.url.appendPathSegments(endpoint.path.value)
+            this.method = HttpMethod.parse(method.name)
+            this.url.appendPathSegments(endpoint.path.value)
 
-        keyString?.let { this.headers["X-MMRPC-KEY"] = it }
-        token?.let { bearerAuth(it) }
+            keyString?.let { this.headers["X-MMRPC-KEY"] = it }
+            token?.let { bearerAuth(it) }
 
-        contentType(ContentType.Application.Json)
-        setBody(valueString)
+            contentType(ContentType.Application.Json)
+            setBody(valueString)
 
-        block()
-    }.body()
+            block()
+        }.body()
+    } catch (cause: ResponseException) {
+        if (cause.response.status.value in 400..<600) {
+            val obj = try {
+                cause.response.body<JsonObject>()
+            } catch (_: Exception) {
+                throw cause
+            }
+
+            val canonicalNameString = obj["type"]?.asContentStringOrNull
+            val message = obj["message"]?.asContentStringOrNull
+
+            canonicalNameString ?: throw cause
+
+            throw FaultException(CanonicalName(canonicalNameString), message, cause)
+        }
+
+        throw cause
+    }
 }

mmrpc-core/src/commonMain/kotlin/FaultException.kt

@@ -0,0 +1,21 @@
+package org.cufy.mmrpc
+
+open class FaultException : Exception {
+    val canonicalName: CanonicalName
+
+    constructor(canonicalName: CanonicalName) : super() {
+        this.canonicalName = canonicalName
+    }
+
+    constructor(canonicalName: CanonicalName, message: String?) : super(message) {
+        this.canonicalName = canonicalName
+    }
+
+    constructor(canonicalName: CanonicalName, message: String?, cause: Throwable?) : super(message, cause) {
+        this.canonicalName = canonicalName
+    }
+
+    constructor(canonicalName: CanonicalName, cause: Throwable?) : super(cause) {
+        this.canonicalName = canonicalName
+    }
+}

mmrpc-server-kotlin/src/jvmMain/kotlin/ktor_respond.kt

@@ -5,10 +5,7 @@ import io.ktor.server.application.*
 import io.ktor.server.response.*
 import org.cufy.json.JsonObject
 import org.cufy.json.set
-import org.cufy.mmrpc.FaultInfo
-import org.cufy.mmrpc.FaultObject
-import org.cufy.mmrpc.RoutineObject
-import org.cufy.mmrpc.StructObject
+import org.cufy.mmrpc.*
 
 suspend inline fun <reified O : StructObject> ApplicationCall.respond(
     routine: RoutineObject<*, O>,
@@ -18,12 +15,30 @@ suspend inline fun <reified O : StructObject> ApplicationCall.respond(
     respond(status, output)
 }
 
+suspend inline fun ApplicationCall.respond(
+    fault: FaultException,
+    message: String? = fault.message,
+    status: HttpStatusCode = HttpStatusCode.BadRequest,
+) {
+    val json = JsonObject {
+        this["type"] = fault.canonicalName.value
+        this["message"] = message
+    }
+
+    respond(status, json)
+}
+
 suspend inline fun ApplicationCall.respond(
     fault: FaultObject,
     message: String? = null,
     status: HttpStatusCode = HttpStatusCode.BadRequest,
 ) {
-    respond(fault.__info__, message, status)
+    val json = JsonObject {
+        this["type"] = fault.__info__.canonicalName.value
+        this["message"] = message
+    }
+
+    respond(status, json)
 }
 
 suspend inline fun ApplicationCall.respond(