catch error if websocket is closed

latticexyz · Oct 14, 2024 · 72bb226 · 72bb226
1 parent 5057319
commit 72bb226
Showing 1 changed file with 9 additions and 5 deletions.
diff --git a/packages/store-sync/src/wiresaw.ts b/packages/store-sync/src/wiresaw.ts
@@ -68,11 +68,15 @@ export function watchLogs({ url, address, fromBlock }: WatchLogsInput): WatchLog
       });
 
       // Catch up to the pending logs
-      const initialLogs = await fetchInitialLogs({ client, address, fromBlock, topics });
-      const logs = [...initialLogs, ...logBuffer].sort(logSort);
-      const blockNumber = logs.at(-1)?.blockNumber ?? fromBlock;
-      subscriber.next({ blockNumber, logs: initialLogs });
-      caughtUp = true;
+      try {
+        const initialLogs = await fetchInitialLogs({ client, address, fromBlock, topics });
+        const logs = [...initialLogs, ...logBuffer].sort(logSort);
+        const blockNumber = logs.at(-1)?.blockNumber ?? fromBlock;
+        subscriber.next({ blockNumber, logs: initialLogs });
+        caughtUp = true;
+      } catch (e) {
+        subscriber.error("Could not fetch initial wiresaw logs");
+      }
     });
 
     return () => client?.close();