diff options
author | Florian Dold <florian@dold.me> | 2023-07-01 00:52:14 +0200 |
---|---|---|
committer | Florian Dold <florian@dold.me> | 2023-07-01 00:52:14 +0200 |
commit | f93ab03a1b946af441e35b9c057f129d25311273 (patch) | |
tree | 063624453ae0b6a38f859bd530ab0a1e29db93fb /packages/taler-wallet-core/src/operations/recoup.ts | |
parent | 7a18e12a175856b3d17d2bb70ec549004c281ff5 (diff) | |
download | wallet-core-f93ab03a1b946af441e35b9c057f129d25311273.tar.xz |
wallet-core: get rid of internal runUntilDone usages
Diffstat (limited to 'packages/taler-wallet-core/src/operations/recoup.ts')
-rw-r--r-- | packages/taler-wallet-core/src/operations/recoup.ts | 23 |
1 files changed, 9 insertions, 14 deletions
diff --git a/packages/taler-wallet-core/src/operations/recoup.ts b/packages/taler-wallet-core/src/operations/recoup.ts index c8c766d1b..dea2d4b16 100644 --- a/packages/taler-wallet-core/src/operations/recoup.ts +++ b/packages/taler-wallet-core/src/operations/recoup.ts @@ -26,36 +26,34 @@ */ import { Amounts, - codecForRecoupConfirmation, - codecForReserveStatus, CoinStatus, - encodeCrock, - getRandomBytes, - j2s, Logger, - NotificationType, RefreshReason, - TalerProtocolTimestamp, TalerPreciseTimestamp, URL, + codecForRecoupConfirmation, + codecForReserveStatus, + encodeCrock, + getRandomBytes, + j2s, } from "@gnu-taler/taler-util"; +import { readSuccessResponseJsonOrThrow } from "@gnu-taler/taler-util/http"; import { CoinRecord, CoinSourceType, RecoupGroupRecord, RefreshCoinSource, WalletStoresV1, + WithdrawCoinSource, WithdrawalGroupStatus, WithdrawalRecordType, - WithdrawCoinSource, } from "../db.js"; import { InternalWalletState } from "../internal-wallet-state.js"; -import { readSuccessResponseJsonOrThrow } from "@gnu-taler/taler-util/http"; import { checkDbInvariant } from "../util/invariants.js"; import { GetReadWriteAccess } from "../util/query.js"; -import { createRefreshGroup, processRefreshGroup } from "./refresh.js"; -import { internalCreateWithdrawalGroup } from "./withdraw.js"; import { TaskRunResult } from "./common.js"; +import { createRefreshGroup } from "./refresh.js"; +import { internalCreateWithdrawalGroup } from "./withdraw.js"; const logger = new Logger("operations/recoup.ts"); @@ -402,9 +400,6 @@ export async function processRecoupGroup( rg2.scheduleRefreshCoins, RefreshReason.Recoup, ); - processRefreshGroup(ws, refreshGroupId.refreshGroupId).catch((e) => { - logger.error(`error while refreshing after recoup ${e}`); - }); } await tx.recoupGroups.put(rg2); }); |