bugfix: read blocknum from sync message

kryptokrauts · Mar 22, 2024 · 618c9f3 · 618c9f3
1 parent 12528f0
commit 618c9f3
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@kryptokrauts/event-processor-node-lib",
-  "version": "1.0.8",
+  "version": "1.0.9",
   "description": "Wrapper for ease listening on antelope blockchain based on @blockmatic/antelope-ship-reader",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",

diff --git a/src/kafka/kafka-wrapper.ts b/src/kafka/kafka-wrapper.ts
@@ -79,7 +79,10 @@ class KafkaWrapper {
               const resetInfo = {
                 // either it is a "regular" message or a fork event
                 // in case it was a "regular" message, take last blocknum and increase by 1, since the last blocknum was successfully processed
-                last_blocknum: Number(messageJSON.blocknum) + 1 || messageJSON.restart_at_block,
+                last_blocknum:
+                  Number(messageJSON.blocknum) + 1 ||
+                  messageJSON.restart_at_block ||
+                  messageJSON.current_block,
                 type: messageJSON.reset_type || 'restart',
               };
               logger.info(