From e6a3824d75df0a0435607d7a8b839a91b0bb1de5 Mon Sep 17 00:00:00 2001
From: wsdt <kevin.riedl@wavect.io>
Date: Sat, 2 Mar 2024 22:30:42 +0100
Subject: [PATCH] chore: Added debug logs for db recovery

---
 src/service.ts | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git a/src/service.ts b/src/service.ts
index ad3813d..ae66f22 100644
--- a/src/service.ts
+++ b/src/service.ts
@@ -459,7 +459,9 @@ export class LightBridgeService extends BaseService<TeleportationOptions> {
   ): Promise<Disbursement[]> => {
     // totalDisbursements[sourceChainId]
     const nextDepositIds: { [sourceChainId: number]: number } = {}
+    this.logger.debug(`Unfiltered disbursements for db recovery: `, {disbursements})
     disbursements = disbursements.filter(async (d) => {
+      this.logger.debug(`Filter iteration for new disbursements (db recover)`, {disbursement: d, sourceChain: d.sourceChainId, nextDepositIds})
       if (!nextDepositIds[d.sourceChainId]) {
         // load into mapping if not yet done
         nextDepositIds[d.sourceChainId] =
@@ -468,9 +470,12 @@ export class LightBridgeService extends BaseService<TeleportationOptions> {
       // only try to disburse those who haven't been disbursed from a previous service already before DB state got lost
       return d.depositId >= nextDepositIds[d.sourceChainId]
     })
+    this.logger.debug(`Filtered disbursements for db recovery: `, {disbursements, nextDepositIdsKeys: Object.keys(nextDepositIds)})
 
     for (const sourceChainId of Object.keys(nextDepositIds)) {
-      const nextDisbursement = disbursements.find((d) => nextDepositIds[sourceChainId] === d.depositId)
+      const nextDisbursement = disbursements.find(
+        (d) => nextDepositIds[sourceChainId] === d.depositId
+      )
       if (!nextDisbursement) {
         this.logger.error(
           `Could NOT recover DB state, RESETTING block number for next startup to get system back up running.`
@@ -482,8 +487,11 @@ export class LightBridgeService extends BaseService<TeleportationOptions> {
         this.logger.warn(
           `Deposit info has ben RESET back to block: ${BobaChains[sourceChainId].height} for chainId ${sourceChainId}`
         )
+        throw new Error('Could not recover DB state, service reset initiated..')
       } else {
-        this.logger.info(`Found correct disbursement to be used next: `, {nextDisbursement})
+        this.logger.info(`Found correct disbursement to be used next: `, {
+          nextDisbursement,
+        })
       }
     }
     return disbursements