feat: shielded sync retry (#2176)

Author: mateuszjasiuk

apps/namadillo/src/hooks/useOptimisticTransferUpdate.tsx

@@ -21,16 +21,23 @@ export const useOptimisticTransferUpdate = () => {
     if (!viewingKey) {
       return;
     }
-    setStorageShieldedBalance((storage) => ({
-      ...storage,
-      [viewingKey]: storage[viewingKey].map((item) =>
-        item.address === token ?
-          {
-            ...item,
-            minDenomAmount: sum(item.minDenomAmount, incrementBaseDenomAmount),
-          }
-        : item
-      ),
-    }));
+    setStorageShieldedBalance((storage) => {
+      return storage[viewingKey] === undefined ?
+          storage
+        : {
+            ...storage,
+            [viewingKey]: storage[viewingKey].map((item) =>
+              item.address === token ?
+                {
+                  ...item,
+                  minDenomAmount: sum(
+                    item.minDenomAmount,
+                    incrementBaseDenomAmount
+                  ),
+                }
+              : item
+            ),
+          };
+    });
   };
 };

apps/namadillo/src/workers/ShieldedSyncWorker.ts

@@ -71,7 +71,30 @@ function newSdk(
 }
 
 async function shieldedSync(sdk: Sdk, payload: Sync["payload"]): Promise<void> {
-  await sdk.rpc.shieldedSync(payload.vks, payload.chainId);
+  const maxRetries = 10;
+  const baseDelayMs = 100;
+  const maxDelayMs = 1000;
+
+  for (let attempt = 0; attempt <= maxRetries; attempt++) {
+    try {
+      await sdk.rpc.shieldedSync(payload.vks, payload.chainId);
+      return;
+    } catch (error) {
+      if (attempt === maxRetries) {
+        break;
+      }
+
+      const delay = Math.min(baseDelayMs * (attempt + 1), maxDelayMs);
+
+      console.warn(
+        `shieldedSync attempt ${attempt + 1} failed, retrying in ${delay}ms:`,
+        error
+      );
+
+      await new Promise((resolve) => setTimeout(resolve, delay));
+    }
+  }
+  throw new Error(`shieldedSync failed after ${maxRetries + 1} attempts.`);
 }
 
 Comlink.expose(new Worker());

packages/shared/lib/Cargo.lock

@@ -18,7 +18,7 @@ nodejs = []
 web = []
 
 [build-dependencies]
-namada_tx = { git = "https://github.com/anoma/namada", tag="libs-v0.150.1" }
+namada_tx = { git = "https://github.com/anoma/namada", branch="tiago/indexer-client-backoff-sleep" }
 
 [dependencies]
 async-trait = {version = "0.1.51"}
@@ -27,7 +27,7 @@ chrono = "0.4.22"
 getrandom = { version = "0.3.0", features = [] }
 gloo-utils = { version = "0.1.5", features = ["serde"] }
 js-sys = "0.3.60"
-namada_sdk = { git = "https://github.com/anoma/namada", tag="libs-v0.150.1", default-features = false }
+namada_sdk = { git = "https://github.com/anoma/namada", branch="tiago/indexer-client-backoff-sleep", default-features = false }
 rand = {version = "0.8.5"}
 rayon = { version = "1.8", optional = true }
 rexie = "0.5"