diff options
Diffstat (limited to 'packages/taler-wallet-core/src/refresh.ts')
-rw-r--r-- | packages/taler-wallet-core/src/refresh.ts | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/packages/taler-wallet-core/src/refresh.ts b/packages/taler-wallet-core/src/refresh.ts index b467a1c47..f67fb5015 100644 --- a/packages/taler-wallet-core/src/refresh.ts +++ b/packages/taler-wallet-core/src/refresh.ts @@ -183,8 +183,8 @@ export class RefreshTransactionContext implements TransactionContext { } async resumeTransaction(): Promise<void> { - const { wex: ws, refreshGroupId, transactionId } = this; - const transitionInfo = await ws.db.runReadWriteTx( + const { wex, refreshGroupId, transactionId } = this; + const transitionInfo = await wex.db.runReadWriteTx( ["refreshGroups"], async (tx) => { const dg = await tx.refreshGroups.get(refreshGroupId); @@ -212,13 +212,13 @@ export class RefreshTransactionContext implements TransactionContext { return undefined; }, ); - notifyTransition(ws, transactionId, transitionInfo); - ws.taskScheduler.startShepherdTask(this.taskId); + notifyTransition(wex, transactionId, transitionInfo); + wex.taskScheduler.startShepherdTask(this.taskId); } async failTransaction(): Promise<void> { - const { wex: ws, refreshGroupId, transactionId } = this; - const transitionInfo = await ws.db.runReadWriteTx( + const { wex, refreshGroupId, transactionId } = this; + const transitionInfo = await wex.db.runReadWriteTx( ["refreshGroups"], async (tx) => { const dg = await tx.refreshGroups.get(refreshGroupId); @@ -252,9 +252,9 @@ export class RefreshTransactionContext implements TransactionContext { }; }, ); - ws.taskScheduler.stopShepherdTask(this.taskId); - notifyTransition(ws, transactionId, transitionInfo); - ws.taskScheduler.startShepherdTask(this.taskId); + wex.taskScheduler.stopShepherdTask(this.taskId); + notifyTransition(wex, transactionId, transitionInfo); + wex.taskScheduler.startShepherdTask(this.taskId); } } |