From 1b0b3f146c829caf04a42984d1a09a7c80b867c4 Mon Sep 17 00:00:00 2001
From: Florian Dold <florian.dold@gmail.com>
Date: Mon, 23 Mar 2020 17:33:38 +0530
Subject: make sure the 'testing withdraw' subcommand does retries

---
 src/headless/helpers.ts    | 4 +++-
 src/operations/reserves.ts | 4 ++--
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/src/headless/helpers.ts b/src/headless/helpers.ts
index 0f690f26a..dc56a9876 100644
--- a/src/headless/helpers.ts
+++ b/src/headless/helpers.ts
@@ -158,6 +158,9 @@ export async function withdrawTestBalance(
   ]);
 
   const donePromise = new Promise((resolve, reject) => {
+    myWallet.runRetryLoop().catch((x) => {
+      reject(x);
+    });
     myWallet.addNotificationListener(n => {
       if (
         n.type === NotificationType.ReserveDepleted &&
@@ -169,7 +172,6 @@ export async function withdrawTestBalance(
   });
 
   await bank.createReserve(bankUser, amount, reservePub, exchangePaytoUri);
-
   await myWallet.confirmReserve({ reservePub: reserveResponse.reservePub });
   await donePromise;
 }
diff --git a/src/operations/reserves.ts b/src/operations/reserves.ts
index 0daad8cc1..c0e22b3c6 100644
--- a/src/operations/reserves.ts
+++ b/src/operations/reserves.ts
@@ -195,7 +195,7 @@ export async function createReserve(
   // Asynchronously process the reserve, but return
   // to the caller already.
   processReserve(ws, resp.reservePub, true).catch(e => {
-    console.error("Processing reserve failed:", e);
+    console.error("Processing reserve (after createReserve) failed:", e);
   });
 
   return resp;
@@ -604,7 +604,7 @@ export async function confirmReserve(
   ws.notify({ type: NotificationType.ReserveUpdated });
 
   processReserve(ws, req.reservePub, true).catch(e => {
-    console.log("processing reserve failed:", e);
+    console.log("processing reserve (after confirmReserve) failed:", e);
   });
 }
 
-- 
cgit v1.2.3