Merge pull request #261 from lidofinance/fix/deposit-events-deletion

fix: deposit events deletion

package.json

@@ -1,6 +1,6 @@
 {
   "name": "lido-council-daemon",
-  "version": "3.1.1",
+  "version": "3.1.2",
   "description": "Lido Council Daemon",
   "author": "Lido team",
   "private": true,

src/contracts/deposits-registry/deposits-registry.service.ts

@@ -163,6 +163,11 @@ export class DepositRegistryService {
       // Delete invalid cache only after full synchronization due to:
       // - we cannot check root at arbitrary times, only if the backlog is less than 120 blocks
       await this.store.clearFromLastValidEvent();
+      // after deleting invalid data
+      // it is necessary to restart the process
+      // further, at reinitialisation a new
+      // deposit tree and the work cycle will be resumed
+      process.exit(1);
     }
 
     this.logger.log('Deposit events cache is updated', {

src/contracts/deposits-registry/store/store.service.ts

@@ -204,24 +204,25 @@ export class DepositsRegistryStoreService {
       lastValidEventIndex = event.depositCount;
     }
 
+    const lastValidEvent = currentCache.data[lastValidEventIndex];
+
     if (!isCacheConsistent) {
-      const lastValidEvent = currentCache.data[lastValidEventIndex];
       const nextEvent = currentCache.data[lastValidEventIndex + 1];
 
       this.logger.warn('Deposit cache is inconsistent', {
         lastValidEvent,
         nextEvent,
       });
+    }
 
-      const headers = this.formDepositEventHeaderForDeletion(
-        lastValidEvent?.blockNumber,
-      );
+    const headers = this.formDepositEventHeaderForDeletion(
+      lastValidEvent?.blockNumber,
+    );
 
-      await this.deleteDepositsGreaterThanOrEqualNBatch(
-        lastValidEventIndex + 1,
-        headers,
-      );
-    }
+    await this.deleteDepositsGreaterThanOrEqualNBatch(
+      lastValidEventIndex + 1,
+      headers,
+    );
   }
 
   /**
@@ -287,6 +288,13 @@ export class DepositsRegistryStoreService {
       });
       await this.db.batch(ops);
     }
+
+    this.logger.log('Deposit events deleted', {
+      depositCount,
+      headers,
+      operationsCount: ops.length,
+    });
+
     await this.setupEventsCache();
   }