Merge branch 'master' into age-withdraw

1 files changed, 57 insertions, 14 deletions

diff --git a/packages/taler-wallet-core/src/host-impl.node.ts b/packages/taler-wallet-core/src/host-impl.node.ts
index 150bba49a..6a4f21d79 100644
--- a/packages/taler-wallet-core/src/host-impl.node.ts
+++ b/packages/taler-wallet-core/src/host-impl.node.ts
@@ -27,6 +27,7 @@ import type { IDBFactory } from "@gnu-taler/idb-bridge";
 import {
   BridgeIDBFactory,
   MemoryBackend,
+  createSqliteBackend,
   shimIndexedDB,
 } from "@gnu-taler/idb-bridge";
 import { AccessStats } from "@gnu-taler/idb-bridge";
@@ -39,24 +40,21 @@ import { createPlatformHttpLib } from "@gnu-taler/taler-util/http";
 import { SetTimeoutTimerAPI } from "./util/timer.js";
 import { Wallet } from "./wallet.js";
 import { DefaultNodeWalletArgs, makeTempfileId } from "./host-common.js";
+import { createNodeSqlite3Impl } from "@gnu-taler/idb-bridge/node-sqlite3-bindings";
 
 const logger = new Logger("host-impl.node.ts");
 
-/**
- * Get a wallet instance with default settings for node.
- *
- * Extended version that allows getting DB stats.
- */
-export async function createNativeWalletHost2(
+interface MakeDbResult {
+  idbFactory: BridgeIDBFactory;
+  getStats: () => AccessStats;
+}
+
+async function makeFileDb(
   args: DefaultNodeWalletArgs = {},
-): Promise<{
-  wallet: Wallet;
-  getDbStats: () => AccessStats;
-}> {
+): Promise<MakeDbResult> {
   BridgeIDBFactory.enableTracing = false;
   const myBackend = new MemoryBackend();
   myBackend.enableTracing = false;
-
   const storagePath = args.persistentStoragePath;
   if (storagePath) {
     try {
@@ -96,8 +94,41 @@ export async function createNativeWalletHost2(
   BridgeIDBFactory.enableTracing = false;
 
   const myBridgeIdbFactory = new BridgeIDBFactory(myBackend);
-  const myIdbFactory: IDBFactory = myBridgeIdbFactory as any as IDBFactory;
+  return {
+    idbFactory: myBridgeIdbFactory,
+    getStats: () => myBackend.accessStats,
+  };
+}
 
+async function makeSqliteDb(
+  args: DefaultNodeWalletArgs,
+): Promise<MakeDbResult> {
+  BridgeIDBFactory.enableTracing = false;
+  const imp = await createNodeSqlite3Impl();
+  const myBackend = await createSqliteBackend(imp, {
+    filename: args.persistentStoragePath ?? ":memory:",
+  });
+  myBackend.enableTracing = false;
+  const myBridgeIdbFactory = new BridgeIDBFactory(myBackend);
+  return {
+    getStats() {
+      throw Error("not implemented");
+    },
+    idbFactory: myBridgeIdbFactory,
+  };
+}
+
+/**
+ * Get a wallet instance with default settings for node.
+ *
+ * Extended version that allows getting DB stats.
+ */
+export async function createNativeWalletHost2(
+  args: DefaultNodeWalletArgs = {},
+): Promise<{
+  wallet: Wallet;
+  getDbStats: () => AccessStats;
+}> {
   let myHttpLib;
   if (args.httpLib) {
     myHttpLib = args.httpLib;
@@ -115,7 +146,19 @@ export async function createNativeWalletHost2(
     );
   };
 
-  shimIndexedDB(myBridgeIdbFactory);
+  let dbResp: MakeDbResult;
+
+  if (args.persistentStoragePath &&args.persistentStoragePath.endsWith(".json")) {
+    logger.info("using legacy file-based DB backend");
+    dbResp = await makeFileDb(args);
+  } else {
+    logger.info("using sqlite3 DB backend");
+    dbResp = await makeSqliteDb(args);
+  }
+
+  const myIdbFactory: IDBFactory = dbResp.idbFactory as any as IDBFactory;
+
+  shimIndexedDB(dbResp.idbFactory);
 
   const myDb = await openTalerDatabase(myIdbFactory, myVersionChange);
 
@@ -158,6 +201,6 @@ export async function createNativeWalletHost2(
   }
   return {
     wallet: w,
-    getDbStats: () => myBackend.accessStats,
+    getDbStats: dbResp.getStats,
   };
 }