towards refunds with updated protocol

1 files changed, 12 insertions, 0 deletions

diff --git a/src/operations/refresh.ts b/src/operations/refresh.ts
index 4d477d644..74b032b91 100644
--- a/src/operations/refresh.ts
+++ b/src/operations/refresh.ts
@@ -535,6 +535,7 @@ async function processRefreshSession(
  * Create a refresh group for a list of coins.
  */
 export async function createRefreshGroup(
+  ws: InternalWalletState,
   tx: TransactionHandle,
   oldCoinPubs: CoinPublicKey[],
   reason: RefreshReason,
@@ -554,6 +555,17 @@ export async function createRefreshGroup(
   };
 
   await tx.put(Stores.refreshGroups, refreshGroup);
+
+  const processAsync = async (): Promise<void> => {
+    try {
+      await processRefreshGroup(ws, refreshGroupId);
+    } catch (e) {
+      logger.trace(`Error during refresh: ${e}`)
+    }
+  };
+
+  processAsync();
+
   return {
     refreshGroupId,
   };