diff options
Diffstat (limited to 'packages/taler-wallet-core/src/recoup.ts')
-rw-r--r-- | packages/taler-wallet-core/src/recoup.ts | 14 |
1 files changed, 8 insertions, 6 deletions
diff --git a/packages/taler-wallet-core/src/recoup.ts b/packages/taler-wallet-core/src/recoup.ts index a2ffa4132..02aa1e167 100644 --- a/packages/taler-wallet-core/src/recoup.ts +++ b/packages/taler-wallet-core/src/recoup.ts @@ -26,6 +26,7 @@ */ import { Amounts, + CancellationToken, CoinStatus, Logger, RefreshReason, @@ -40,6 +41,11 @@ import { } from "@gnu-taler/taler-util"; import { readSuccessResponseJsonOrThrow } from "@gnu-taler/taler-util/http"; import { + TaskRunResult, + TransactionContext, + constructTaskIdentifier, +} from "./common.js"; +import { CoinRecord, CoinSourceType, RecoupGroupRecord, @@ -53,14 +59,9 @@ import { } from "./db.js"; import { InternalWalletState } from "./internal-wallet-state.js"; import { PendingTaskType } from "./pending-types.js"; -import { checkDbInvariant } from "./util/invariants.js"; -import { - TaskRunResult, - TransactionContext, - constructTaskIdentifier, -} from "./common.js"; import { createRefreshGroup } from "./refresh.js"; import { constructTransactionIdentifier } from "./transactions.js"; +import { checkDbInvariant } from "./util/invariants.js"; import { internalCreateWithdrawalGroup } from "./withdraw.js"; const logger = new Logger("operations/recoup.ts"); @@ -295,6 +296,7 @@ async function recoupRefreshCoin( export async function processRecoupGroup( ws: InternalWalletState, recoupGroupId: string, + cancellationToken: CancellationToken, ): Promise<TaskRunResult> { let recoupGroup = await ws.db.runReadOnlyTx(["recoupGroups"], async (tx) => { return tx.recoupGroups.get(recoupGroupId); |