diff options
| -rw-r--r-- | src/headless/helpers.ts | 4 | ||||
| -rw-r--r-- | 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); }); } |