aboutsummaryrefslogtreecommitdiff
path: root/packages/taler-wallet-core/src/operations/pending.ts
diff options
context:
space:
mode:
authorFlorian Dold <florian@dold.me>2022-10-14 21:00:13 +0200
committerFlorian Dold <florian@dold.me>2022-10-14 22:10:10 +0200
commitf1cba79c656875af0c6a09fd8e03b2c94fb2ac44 (patch)
tree469036c26f2ab84a5db218dd8833c38560c09e3d /packages/taler-wallet-core/src/operations/pending.ts
parent398e79d0d6b649d8921ffffa4d0be8775c15626e (diff)
downloadwallet-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.ts9
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);