diff options
| author | Florian Dold <florian@dold.me> | 2024-02-13 10:53:43 +0100 |
|---|---|---|
| committer | Florian Dold <florian@dold.me> | 2024-02-15 21:56:54 +0100 |
| commit | 70a803038f1cbe05dc4779bdd87376fd073421be (patch) | |
| tree | 6607d69f6906ada9f912e31d9a9e3b65560a7326 /packages/taler-wallet-core/src/operations/reward.ts | |
| parent | 2c17e98c336d96f955ec82ad0a1b164e3da90103 (diff) | |
| download | wallet-core-70a803038f1cbe05dc4779bdd87376fd073421be.tar.xz | |
implement task shepherd, many small fixes and tweaks
Diffstat (limited to 'packages/taler-wallet-core/src/operations/reward.ts')
| -rw-r--r-- | packages/taler-wallet-core/src/operations/reward.ts | 6 |
1 files changed, 0 insertions, 6 deletions
diff --git a/packages/taler-wallet-core/src/operations/reward.ts b/packages/taler-wallet-core/src/operations/reward.ts index 6dcd48019..4d8653a9d 100644 --- a/packages/taler-wallet-core/src/operations/reward.ts +++ b/packages/taler-wallet-core/src/operations/reward.ts @@ -83,7 +83,6 @@ import { constructTransactionIdentifier, notifyTransition, parseTransactionIdentifier, - stopLongpolling, } from "./transactions.js"; import { PendingTaskType } from "../pending-types.js"; import { assertUnreachable } from "../util/assertUnreachable.js"; @@ -125,7 +124,6 @@ export class RewardTransactionContext implements TransactionContext { async suspendTransaction(): Promise<void> { const { ws, walletRewardId, transactionId, retryTag } = this; - stopLongpolling(ws, retryTag); const transitionInfo = await ws.db .mktx((x) => [x.rewards]) .runReadWrite(async (tx) => { @@ -161,13 +159,11 @@ export class RewardTransactionContext implements TransactionContext { } return undefined; }); - ws.workAvailable.trigger(); notifyTransition(ws, transactionId, transitionInfo); } async abortTransaction(): Promise<void> { const { ws, walletRewardId, transactionId, retryTag } = this; - stopLongpolling(ws, retryTag); const transitionInfo = await ws.db .mktx((x) => [x.rewards]) .runReadWrite(async (tx) => { @@ -207,7 +203,6 @@ export class RewardTransactionContext implements TransactionContext { async resumeTransaction(): Promise<void> { const { ws, walletRewardId, transactionId, retryTag } = this; - stopLongpolling(ws, retryTag); const transitionInfo = await ws.db .mktx((x) => [x.rewards]) .runReadWrite(async (tx) => { @@ -247,7 +242,6 @@ export class RewardTransactionContext implements TransactionContext { async failTransaction(): Promise<void> { const { ws, walletRewardId, transactionId, retryTag } = this; - stopLongpolling(ws, retryTag); const transitionInfo = await ws.db .mktx((x) => [x.rewards]) .runReadWrite(async (tx) => { |