fix: restore cpBlocksCache if processing failed (#259)

checkpoint-labs · Sep 27, 2023 · 71473ab · 71473ab
1 parent dd393da
commit 71473ab
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/src/checkpoint.ts b/src/checkpoint.ts
@@ -352,9 +352,10 @@ export default class Checkpoint {
   private async next(blockNum: number) {
     if (!this.prefetchEndBlock) throw new Error('prefetchEndBlock is not set');
 
+    let checkpointBlock;
     if (!this.config.disable_checkpoints && !this.config.tx_fn && !this.config.global_events) {
       if (blockNum <= this.prefetchEndBlock) {
-        const checkpointBlock = await this.getNextCheckpointBlock(blockNum);
+        checkpointBlock = await this.getNextCheckpointBlock(blockNum);
 
         if (checkpointBlock) {
           blockNum = checkpointBlock;
@@ -388,6 +389,10 @@ export default class Checkpoint {
         this.log.error({ blockNumber: blockNum, err }, 'error occurred during block processing');
       }
 
+      if (checkpointBlock && this.cpBlocksCache) {
+        this.cpBlocksCache.unshift(checkpointBlock);
+      }
+
       await Promise.delay(this.opts?.fetchInterval || DEFAULT_FETCH_INTERVAL);
       return this.next(blockNum);
     }