From f3c9799197cb290ac696d9d9cf58976e1291ad32 Mon Sep 17 00:00:00 2001
From: filip <filip.harald@gmail.com>
Date: Fri, 11 Oct 2024 10:18:48 +0200
Subject: [PATCH] hotfix: make aztec-listener recover from restarted chain

---
 services/aztec-listener/src/aztec/index.ts | 22 ++++++++++++++++------
 1 file changed, 16 insertions(+), 6 deletions(-)

diff --git a/services/aztec-listener/src/aztec/index.ts b/services/aztec-listener/src/aztec/index.ts
index 8a1140d5..52dab215 100644
--- a/services/aztec-listener/src/aztec/index.ts
+++ b/services/aztec-listener/src/aztec/index.ts
@@ -4,7 +4,10 @@ import {
   AZTEC_GENESIS_CATCHUP,
   AZTEC_LISTEN_FOR_BLOCKS,
 } from "../constants.js";
-import { getHeight as getLatestProcessedHeight } from "../database/latestProcessedHeight.controller.js";
+import {
+  getHeight as getLatestProcessedHeight,
+  storeHeight,
+} from "../database/latestProcessedHeight.controller.js";
 import { logger } from "../logger.js";
 import {
   getLatestHeight,
@@ -33,14 +36,21 @@ export const init = async () => {
   }, backOffOptions);
   logger.info(`AZTEC: initialized: ${JSON.stringify(nodeInfo)}`);
 
-  const latestProcessedHeight = await getLatestProcessedHeight();
-  const pollFromHeight = latestProcessedHeight
+  const latestProcessedHeight = (await getLatestProcessedHeight()) ?? 0;
+  const chainHeight = await getLatestHeight();
+  const isOffSync = chainHeight < latestProcessedHeight;
+  if (isOffSync) {
+    logger.warn(
+      `🤡 AZTEC: chain height is ${chainHeight} but we've processed up to ${latestProcessedHeight}`
+    );
+    await storeHeight(0);
+  }
+  const pollFromHeight = !isOffSync && latestProcessedHeight
     ? latestProcessedHeight + 1
-    : await getLatestHeight();
+    : chainHeight;
   if (AZTEC_GENESIS_CATCHUP)
     await startCatchup({ from: 1, to: pollFromHeight });
-  if (AZTEC_LISTEN_FOR_BLOCKS)
-    startPolling({ fromHeight: pollFromHeight });
+  if (AZTEC_LISTEN_FOR_BLOCKS) startPolling({ fromHeight: pollFromHeight });
 
   return {
     id: "AZTEC",