From ef51ba983f49b32a04bb8460f24f720f7952f306 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Iv=C3=A1n=20=C3=81valos?= <avalos@disroot.org>
Date: Fri, 30 Jun 2023 17:52:24 -0600
Subject: WIP: initial work for Anastasis in qtart

---
 packages/taler-wallet-embedded/src/wallet-qjs.ts | 31 +++++++++++++++++++++++-
 1 file changed, 30 insertions(+), 1 deletion(-)

(limited to 'packages/taler-wallet-embedded/src/wallet-qjs.ts')

diff --git a/packages/taler-wallet-embedded/src/wallet-qjs.ts b/packages/taler-wallet-embedded/src/wallet-qjs.ts
index 2b1c8a108..db0aeacb6 100644
--- a/packages/taler-wallet-embedded/src/wallet-qjs.ts
+++ b/packages/taler-wallet-embedded/src/wallet-qjs.ts
@@ -41,6 +41,10 @@ import {
   Wallet,
   WalletApiOperation,
 } from "@gnu-taler/taler-wallet-core";
+import {
+  reduceAction,
+  ReducerState,
+} from "@gnu-taler/anastasis-core";
 
 setGlobalLogLevelFromString("trace");
 
@@ -169,6 +173,25 @@ class NativeWalletMessageHandler {
   }
 }
 
+/**
+ * Handle an Anastasis request from the native app.
+ */
+async function handleAnastasisRequest(
+  state: ReducerState,
+  action: string,
+  id: string,
+  args: any,
+): Promise<CoreApiResponse> {
+  // For now, this will return "success" even if the wrapped Anastasis
+  // response is a ReducerStateError.
+  return {
+    type: "response",
+    id,
+    operation: "anastasis",
+    result: await reduceAction(state, action, args),
+  };
+}
+
 export function installNativeWalletListener(): void {
   setGlobalLogLevelFromString("trace");
   const handler = new NativeWalletMessageHandler();
@@ -190,7 +213,13 @@ export function installNativeWalletListener(): void {
 
     let respMsg: CoreApiResponse;
     try {
-      respMsg = await handler.handleMessage(operation, id, msg.args ?? {});
+      if (msg.operation === "anastasis") {
+        // TODO: do some input validation here
+        let req = msg.args ?? {};
+        respMsg = await handleAnastasisRequest(req.state, req.action, id, req.args ?? {});
+      } else {
+        respMsg = await handler.handleMessage(operation, id, msg.args ?? {});
+      }
     } catch (e) {
       respMsg = {
         type: "error",
-- 
cgit v1.2.3