diff options
Diffstat (limited to 'packages/taler-wallet-core/src/observable-wrappers.ts')
-rw-r--r-- | packages/taler-wallet-core/src/observable-wrappers.ts | 16 |
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>", |