feat: add configurable blocknum emitter

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@kryptokrauts/event-processor-node-lib",
-  "version": "1.0.11",
+  "version": "1.0.12",
   "description": "Wrapper for ease listening on antelope blockchain based on @blockmatic/antelope-ship-reader",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",

src/common/types.ts

@@ -44,6 +44,7 @@ export interface ShipReaderWrapperConfig {
   table_rows_whitelist: () => EosioReaderTableRowFilter[];
   actions_whitelist: () => EosioReaderActionFilter[];
   only_irreversible_blocks: boolean;
+  emit_current_blocknum: boolean;
 }
 
 export interface ActionData {

src/eosio/ship-reader-wrapper.ts

@@ -155,7 +155,16 @@ export class ShipReaderWrapper {
     // subscribe to incoming blocks event
     this.subscriptions.push(
       blocks$.pipe<EosioReaderBlock>(takeWhile(() => !this.forked)).subscribe(async block => {
-        logger.trace(`Current block ${this.current_block}`);
+        logger.trace(`Current block ${block.block_num}`);
+
+        if (this.config.emit_current_blocknum) {
+          await this.kafka_wrapper.sendEvent(
+            JSON.stringify({
+              blocknum: block.block_num,
+            }),
+            'current_block',
+          );
+        }
 
         // since replaying blocks is much faster, check within greater block-span
         let syncStateCheckInterval: number = 10 * sync_message_block_interval;