1 files changed, 11 insertions, 5 deletions
diff --git a/packages/taler-wallet-core/src/observable-wrappers.ts b/packages/taler-wallet-core/src/observable-wrappers.ts
index 5a8be9cf6..b36f41611 100644
--- a/packages/taler-wallet-core/src/observable-wrappers.ts
+++ b/packages/taler-wallet-core/src/observable-wrappers.ts
@@ -25,7 +25,7 @@ import { IDBDatabase } from "@gnu-taler/idb-bridge";
 import {
   ObservabilityContext,
   ObservabilityEventType,
-  RetryLoopOpts
+  RetryLoopOpts,
 } from "@gnu-taler/taler-util";
 import { TaskIdStr } from "./common.js";
 import { TalerCryptoInterface } from "./index.js";
@@ -44,7 +44,7 @@ export class ObservableTaskScheduler implements TaskScheduler {
   constructor(
     private impl: TaskScheduler,
     private oc: ObservabilityContext,
-  ) { }
+  ) {}
 
   private taskDepCache = new Set<string>();
 
@@ -122,12 +122,15 @@ export class ObservableDbAccess<StoreMap> implements DbAccess<StoreMap> {
   constructor(
     private impl: DbAccess<StoreMap>,
     private oc: ObservabilityContext,
-  ) { }
+  ) {}
   idbHandle(): IDBDatabase {
     return this.impl.idbHandle();
   }
 
   async runAllStoresReadWriteTx<T>(
+    options: {
+      label?: string;
+    },
     txf: (
       tx: DbReadWriteTransaction<StoreMap, StoreNames<StoreMap>[]>,
     ) => Promise<T>,
@@ -139,7 +142,7 @@ export class ObservableDbAccess<StoreMap> implements DbAccess<StoreMap> {
       location,
     });
     try {
-      const ret = await this.impl.runAllStoresReadWriteTx(txf);
+      const ret = await this.impl.runAllStoresReadWriteTx(options, txf);
       this.oc.observe({
         type: ObservabilityEventType.DbQueryFinishSuccess,
         name: "<unknown>",
@@ -157,6 +160,9 @@ export class ObservableDbAccess<StoreMap> implements DbAccess<StoreMap> {
   }
 
   async runAllStoresReadOnlyTx<T>(
+    options: {
+      label?: string;
+    },
     txf: (
       tx: DbReadOnlyTransaction<StoreMap, StoreNames<StoreMap>[]>,
     ) => Promise<T>,
@@ -168,7 +174,7 @@ export class ObservableDbAccess<StoreMap> implements DbAccess<StoreMap> {
       location,
     });
     try {
-      const ret = await this.impl.runAllStoresReadOnlyTx(txf);
+      const ret = await this.impl.runAllStoresReadOnlyTx(options, txf);
       this.oc.observe({
         type: ObservabilityEventType.DbQueryFinishSuccess,
         name: "<unknown>",