From c077c0d8c08fb83fb6f4ba860a9d600cc22131c3 Mon Sep 17 00:00:00 2001
From: Florian Dold <florian@dold.me>
Date: Sat, 7 Aug 2021 17:59:06 +0200
Subject: consider deposit operations for pending operations

---
 .../taler-wallet-core/src/operations/pending.ts    | 22 ++++++++++++++++++++++
 1 file changed, 22 insertions(+)

(limited to 'packages/taler-wallet-core/src')

diff --git a/packages/taler-wallet-core/src/operations/pending.ts b/packages/taler-wallet-core/src/operations/pending.ts
index 3a6af186e..200e6ccbd 100644
--- a/packages/taler-wallet-core/src/operations/pending.ts
+++ b/packages/taler-wallet-core/src/operations/pending.ts
@@ -180,6 +180,27 @@ async function gatherProposalPending(
   });
 }
 
+async function gatherDepositPending(
+  tx: GetReadOnlyAccess<{ depositGroups: typeof WalletStoresV1.depositGroups }>,
+  now: Timestamp,
+  resp: PendingOperationsResponse,
+): Promise<void> {
+  await tx.depositGroups.iter().forEach((dg) => {
+    if (dg.timestampFinished) {
+      return;
+    }
+    const timestampDue = dg.retryInfo?.nextRetry ?? getTimestampNow();
+    resp.pendingOperations.push({
+      type: PendingTaskType.Deposit,
+      givesLifeness: true,
+      timestampDue,
+      depositGroupId: dg.depositGroupId,
+      lastError: dg.lastError,
+      retryInfo: dg.retryInfo,
+    });
+  });
+}
+
 async function gatherTipPending(
   tx: GetReadOnlyAccess<{ tips: typeof WalletStoresV1.tips }>,
   now: Timestamp,
@@ -313,6 +334,7 @@ export async function getPendingOperations(
       await gatherRefreshPending(tx, now, resp);
       await gatherWithdrawalPending(tx, now, resp);
       await gatherProposalPending(tx, now, resp);
+      await gatherDepositPending(tx, now, resp);
       await gatherTipPending(tx, now, resp);
       await gatherPurchasePending(tx, now, resp);
       await gatherRecoupPending(tx, now, resp);
-- 
cgit v1.2.3