Fixed cursor not creating

pinax-network · Jun 29, 2023 · 7920c23 · 7920c23
1 parent c53a59f
commit 7920c23
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 3 deletions.
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
     "name": "substreams-sink",
-    "version": "0.5.3",
+    "version": "0.5.4",
     "description": "Substreams Sink",
     "type": "module",
     "exports": "./dist/index.js",

diff --git a/src/run.ts b/src/run.ts
@@ -68,6 +68,10 @@ export function run(substreamPackage: Package, options: RunOptions) {
     // Block Emitter
     const emitter = new BlockEmitter(transport, request, registry);
 
+    emitter.on("cursor", (cursor, _) => {
+        fs.writeFileSync(cursorFile, cursor, "utf-8");
+    });
+
     // Metrics
     if (!metricsDisabled) {
         emitter.on("block", (block: BlockScopedData) => {