wallet-core: count deposits towards pendingOutgoing

1 files changed, 30 insertions, 0 deletions

diff --git a/packages/taler-wallet-core/src/balance.ts b/packages/taler-wallet-core/src/balance.ts
index e63ea6641..94a500384 100644
--- a/packages/taler-wallet-core/src/balance.ts
+++ b/packages/taler-wallet-core/src/balance.ts
@@ -196,6 +196,15 @@ class BalancesStore {
     b.pendingIncoming = Amounts.add(b.pendingIncoming, amount).amount;
   }
 
+  async addPendingOutgoing(
+    currency: string,
+    exchangeBaseUrl: string,
+    amount: AmountLike,
+  ): Promise<void> {
+    const b = await this.initBalance(currency, exchangeBaseUrl);
+    b.pendingOutgoing = Amounts.add(b.pendingOutgoing, amount).amount;
+  }
+
   async setFlagIncomingAml(
     currency: string,
     exchangeBaseUrl: string,
@@ -388,6 +397,27 @@ export async function getBalancesInsideTransaction(
           case DepositOperationStatus.PendingKyc:
             await balanceStore.setFlagOutgoingKyc(currency, e);
         }
+
+        switch (dgRecord.operationStatus) {
+          case DepositOperationStatus.SuspendedKyc:
+          case DepositOperationStatus.PendingKyc:
+          case DepositOperationStatus.PendingTrack:
+          case DepositOperationStatus.SuspendedAborting:
+          case DepositOperationStatus.SuspendedDeposit:
+          case DepositOperationStatus.SuspendedTrack:
+          case DepositOperationStatus.PendingDeposit: {
+            const perExchange = dgRecord.infoPerExchange;
+            if (perExchange) {
+              for (const [e, v] of Object.entries(perExchange)) {
+                await balanceStore.addPendingOutgoing(
+                  currency,
+                  e,
+                  v.amountEffective,
+                );
+              }
+            }
+          }
+        }
       }
     });