diff options
| author | Florian Dold <florian@dold.me> | 2021-08-19 15:12:33 +0200 |
|---|---|---|
| committer | Florian Dold <florian@dold.me> | 2021-08-19 15:12:33 +0200 |
| commit | c0e6b6d0f66508ebc8d33502d1281cb48a1c9cc6 (patch) | |
| tree | e80d81ec1c13a24c73a00eb6f388d6db75b32c0c /packages/taler-wallet-core/src/operations/refresh.ts | |
| parent | defc393d6e320f6cc76df059a94936a7b88571a1 (diff) | |
| download | wallet-core-c0e6b6d0f66508ebc8d33502d1281cb48a1c9cc6.tar.xz | |
run pending operations at least once, style fixes
Diffstat (limited to 'packages/taler-wallet-core/src/operations/refresh.ts')
| -rw-r--r-- | packages/taler-wallet-core/src/operations/refresh.ts | 12 |
1 files changed, 11 insertions, 1 deletions
diff --git a/packages/taler-wallet-core/src/operations/refresh.ts b/packages/taler-wallet-core/src/operations/refresh.ts index 2549b1404..20b07d44e 100644 --- a/packages/taler-wallet-core/src/operations/refresh.ts +++ b/packages/taler-wallet-core/src/operations/refresh.ts @@ -147,6 +147,7 @@ async function refreshCreateSession( throw Error("db inconsistent: exchange of coin not found"); } + const { availableAmount, availableDenoms } = await ws.db .mktx((x) => ({ denominations: x.denominations, @@ -161,6 +162,7 @@ async function refreshCreateSession( throw Error("db inconsistent: denomination for coin not found"); } + // FIXME: use an index here, based on the withdrawal expiration time. const availableDenoms: DenominationRecord[] = await tx.denominations.indexes.byExchangeBaseUrl .iter(exchange.baseUrl) .toArray(); @@ -913,7 +915,15 @@ export async function autoRefresh( } } if (refreshCoins.length > 0) { - await createRefreshGroup(ws, tx, refreshCoins, RefreshReason.Scheduled); + const res = await createRefreshGroup( + ws, + tx, + refreshCoins, + RefreshReason.Scheduled, + ); + logger.info( + `created refresh group for auto-refresh (${res.refreshGroupId})`, + ); } logger.info( `current wallet time: ${timestampToIsoString(getTimestampNow())}`, |