[wallet] Proper DB import/export functionality

1 files changed, 23 insertions, 0 deletions

diff --git a/wallet/src/main/java/net/taler/wallet/backend/WalletBackendApi.kt b/wallet/src/main/java/net/taler/wallet/backend/WalletBackendApi.kt
index bf6f371..ea58dd7 100644
--- a/wallet/src/main/java/net/taler/wallet/backend/WalletBackendApi.kt
+++ b/wallet/src/main/java/net/taler/wallet/backend/WalletBackendApi.kt
@@ -23,6 +23,7 @@ import kotlinx.coroutines.GlobalScope
 import kotlinx.coroutines.launch
 import kotlinx.coroutines.withContext
 import kotlinx.serialization.KSerializer
+import kotlinx.serialization.json.JsonObject
 import kotlinx.serialization.json.decodeFromJsonElement
 import net.taler.wallet.backend.TalerErrorCode.NONE
 import org.json.JSONObject
@@ -86,4 +87,26 @@ class WalletBackendApi(
             WalletResponse.Error(info)
         }
     }
+
+    // Returns raw JSON response instead of serialized object
+    suspend inline fun rawRequest(
+        operation: String,
+        noinline args: (JSONObject.() -> JSONObject)? = null,
+    ): WalletResponse<JsonObject> = withContext(Dispatchers.Default) {
+        val json = BackendManager.json
+        try {
+            when (val response = sendRequest(operation, args?.invoke(JSONObject()))) {
+                is ApiResponse.Response -> {
+                    WalletResponse.Success(response.result)
+                }
+                is ApiResponse.Error -> {
+                    val error: TalerErrorInfo = json.decodeFromJsonElement(response.error)
+                    WalletResponse.Error(error)
+                }
+            }
+        } catch (e: Exception) {
+            val info = TalerErrorInfo(NONE, "", e.toString())
+            WalletResponse.Error(info)
+        }
+    }
 }