fix(store-indexer): subscribe postgres indexer to stream (#1514)

latticexyz · Sep 16, 2023 · ed07018 · ed07018
1 parent 9b43029
commit ed07018
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/.changeset/chilled-kangaroos-dream.md b/.changeset/chilled-kangaroos-dream.md
@@ -0,0 +1,5 @@
+---
+"@latticexyz/store-indexer": patch
+---
+
+Fixes postgres indexer stopping sync after it catches up to the latest block.
diff --git a/packages/store-indexer/bin/postgres-indexer.ts b/packages/store-indexer/bin/postgres-indexer.ts
@@ -105,6 +105,8 @@ const { latestBlockNumber$, storedBlockLogs$ } = await createStoreSync({
   maxBlockRange: env.MAX_BLOCK_RANGE,
 });
 
+storedBlockLogs$.subscribe();
+
 combineLatest([latestBlockNumber$, storedBlockLogs$])
   .pipe(
     filter(