fix: add subscribe event to autocc to avoid redundant process;

fix: init checkpoint 1 block shift

Author: nom4dv3

packages/orap/signal/event.ts

@@ -49,10 +49,12 @@ export class EventSignal implements Signal {
     this.subscribeCallback = async (...args: Array<any>) => {
       const _contractEventPayload = args.pop()
       await this.callback(...args, _contractEventPayload.log)
+      await this.crosschecker?.cache!.addLog(_contractEventPayload.log)
     }
     // to align with subscribe listener, parse event params and add EventLog to the last
     this.crosscheckCallback = async (log: Log) => {
       const parsedLog = this.contract.interface.decodeEventLog(this.eventFragment, log.data, log.topics)
+      this.logger.info('crosschecker capture a missing event! processing...', log.transactionHash, log.index)
       await this.callback(...parsedLog, log)
     }
   }

packages/reku/README.md

@@ -28,7 +28,7 @@ Options:
 - `store`?: the Store used to cache the <txhash, logindex> that already processed.
 - `storeKeyPrefix`?: set the prefix to all keys when set key-value to store (cache), e.g. key = prefix+'txHashList', prefix can be "project:app:network:" to form a "project:app:network:txHashList" redis key., defult: ''
 - `storeTtl`?: the ttl for <txhash, logindex> record in store, defualt: no limit
-- `batchBlocksCount`?: how many blocks to get per `getLogs` check, in readtime mode it waits until the new block num >= `batchBlocksCount`.
+- `batchBlocksCount`?: how many blocks to get per `getLogs` check, in readtime mode it waits until the new block num >= `batchBlocksCount`. default: 10
 - `delayBlockFromLatest`?: mostly for realtime mode; each time cc wait until `latest height > toBlock + delayBlockFromLatest`, default: 1
 - `blockInterval`?: the block interval (in ms) of the given chain, default: 12000 for eth
 - `pollingInterval`?: how long does it take between 2 block height check polling checks; mostly for limiting getLogs calling rate in catchup mode, default: 3000 ms

packages/reku/event/crosschecker/autochecker.ts

@@ -59,7 +59,7 @@ export class AutoCrossChecker extends BaseCrossChecker {
     const latestblocknum = await retryOnNull(async () => await this.provider.provider?.getBlockNumber())
 
     // resume checkpoint priority: options.fromBlock > cache > latestblocknum + 1
-    const defaultInitCheckpoint = await this.cache.getCheckpoint() ?? latestblocknum + 1
+    const defaultInitCheckpoint = await this.cache.getCheckpoint() ?? (latestblocknum + 1)
 
     const {
       fromBlock = defaultInitCheckpoint,
@@ -86,7 +86,7 @@ export class AutoCrossChecker extends BaseCrossChecker {
 
     const waitNextCrosscheck = async (): Promise<boolean> => {
       const latestblocknum = await retryOnNull(async () => await this.provider.provider?.getBlockNumber())
-      this.logger.info('[*] ccrOptions: fromBlock', ccrOptions.fromBlock, ', toBlock', ccrOptions.toBlock, ', latestblocknum', latestblocknum)
+      this.logger.debug('[*] ccrOptions: fromBlock', ccrOptions.fromBlock, ', toBlock', ccrOptions.toBlock, ', latestblocknum', latestblocknum)
       if (ccrOptions.toBlock + delayBlockFromLatest > latestblocknum) {
         // sleep until the toBlock
         this.logger.debug('sleep until the latestblocknum >= toBlock + delayBlockFromLatest, i.e.', (ccrOptions.toBlock + delayBlockFromLatest - latestblocknum) * blockInterval, 'ms')