diff options
author | Florian Dold <florian@dold.me> | 2022-10-14 21:00:13 +0200 |
---|---|---|
committer | Florian Dold <florian@dold.me> | 2022-10-14 22:10:10 +0200 |
commit | f1cba79c656875af0c6a09fd8e03b2c94fb2ac44 (patch) | |
tree | 469036c26f2ab84a5db218dd8833c38560c09e3d /packages/taler-wallet-core/src/operations/pending.ts | |
parent | 398e79d0d6b649d8921ffffa4d0be8775c15626e (diff) | |
download | wallet-core-f1cba79c656875af0c6a09fd8e03b2c94fb2ac44.tar.xz |
wallet-core: DB tweaks
Diffstat (limited to 'packages/taler-wallet-core/src/operations/pending.ts')
-rw-r--r-- | packages/taler-wallet-core/src/operations/pending.ts | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/packages/taler-wallet-core/src/operations/pending.ts b/packages/taler-wallet-core/src/operations/pending.ts index 285cef534..d2066d4fc 100644 --- a/packages/taler-wallet-core/src/operations/pending.ts +++ b/packages/taler-wallet-core/src/operations/pending.ts @@ -106,16 +106,17 @@ async function gatherRefreshPending( now: AbsoluteTime, resp: PendingOperationsResponse, ): Promise<void> { + const keyRange = GlobalIDB.KeyRange.bound( + OperationStatusRange.ACTIVE_START, + OperationStatusRange.ACTIVE_END, + ); const refreshGroups = await tx.refreshGroups.indexes.byStatus.getAll( - OperationStatus.Pending, + keyRange, ); for (const r of refreshGroups) { if (r.timestampFinished) { return; } - if (r.frozen) { - return; - } const opId = RetryTags.forRefresh(r); const retryRecord = await tx.operationRetries.get(opId); |