wallet-core: implement db migration check

1 files changed, 25 insertions, 9 deletions

diff --git a/packages/taler-harness/src/harness/harness.ts b/packages/taler-harness/src/harness/harness.ts
index b2714f496..b9164a968 100644
--- a/packages/taler-harness/src/harness/harness.ts
+++ b/packages/taler-harness/src/harness/harness.ts
@@ -1885,16 +1885,39 @@ function tryUnixConnect(socketPath: string): Promise<void> {
 
 export interface WalletServiceOptions {
   useInMemoryDb?: boolean;
+  /**
+   * Use a particular DB path instead of the default one in the
+   * test environment.
+   */
+  overrideDbPath?: string;
   name: string;
 }
 
+/**
+ * A wallet service that listens on a unix domain socket for commands.
+ */
 export class WalletService {
   walletProc: ProcessWrapper | undefined;
 
+  private internalDbPath: string;
+
   constructor(
     private globalState: GlobalTestState,
     private opts: WalletServiceOptions,
-  ) {}
+  ) {
+    if (this.opts.overrideDbPath) {
+      this.internalDbPath = this.opts.overrideDbPath;
+    } else {
+      if (this.opts.useInMemoryDb) {
+        this.internalDbPath = ":memory:";
+      } else {
+        this.internalDbPath = path.join(
+          this.globalState.testDir,
+          `walletdb-${this.opts.name}.sqlite3`,
+        );
+      }
+    }
+  }
 
   get socketPath() {
     const unixPath = path.join(
@@ -1905,14 +1928,7 @@ export class WalletService {
   }
 
   get dbPath() {
-    if (this.opts.useInMemoryDb) {
-      return ":memory:";
-    } else {
-      return path.join(
-        this.globalState.testDir,
-        `walletdb-${this.opts.name}.sqlite3`,
-      );
-    }
+    return this.internalDbPath;
   }
 
   async stop(): Promise<void> {