feat: keep re-retrying getting the latest block if it fails instead o…

…f crashing the indexer
tenetxyz · Mar 31, 2024 · dd1efcc · dd1efcc
1 parent 6c87714
commit dd1efcc
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/packages/store-sync/src/createStoreSync.ts b/packages/store-sync/src/createStoreSync.ts
@@ -26,6 +26,7 @@ import {
   combineLatest,
   scan,
   identity,
+  retry,
 } from "rxjs";
 import { debug as parentDebug } from "./debug";
 import { SyncStep } from "./SyncStep";
@@ -184,6 +185,10 @@ export async function createStoreSync<config extends StoreConfig = StoreConfig>(
     tap((blockNumber) => {
       debug("on block number", blockNumber, "for", followBlockTag, "block tag");
     }),
+    retry({
+      count: undefined, // ie unlimited
+      delay: 3000, // poll the RPC every 3 seconds
+    }),
     shareReplay(1),
   );