From d4ae7de0598aea6e130782c71343c85c88c5caaf Mon Sep 17 00:00:00 2001
From: Liu <57480598+liu-zhipeng@users.noreply.github.com>
Date: Tue, 7 Nov 2023 01:04:32 +0800
Subject: [PATCH] fix: 5125 sendoutboundroot cron called twice (#5129)

* fix: remove `process.exit()` sendoutboundroot

* fix: remove `process.exit` from LH
---
 .../lighthouse/src/tasks/processFromRoot/processFromRoot.ts  | 5 ++++-
 packages/agents/lighthouse/src/tasks/propagate/propagate.ts  | 4 +++-
 packages/agents/lighthouse/src/tasks/prover/prover.ts        | 4 +++-
 .../src/tasks/sendOutboundRoot/sendOutboundRoot.ts           | 4 +++-
 4 files changed, 13 insertions(+), 4 deletions(-)

diff --git a/packages/agents/lighthouse/src/tasks/processFromRoot/processFromRoot.ts b/packages/agents/lighthouse/src/tasks/processFromRoot/processFromRoot.ts
index 26cd7c987f..79d6df4c9e 100644
--- a/packages/agents/lighthouse/src/tasks/processFromRoot/processFromRoot.ts
+++ b/packages/agents/lighthouse/src/tasks/processFromRoot/processFromRoot.ts
@@ -87,6 +87,9 @@ export const makeProcessFromRoot = async (config: NxtpLighthouseConfig, chainDat
     console.error("Error starting processor. Sad! :(", e);
   } finally {
     await closeDatabase();
-    process.exit();
+
+    context.logger.info("Process from root complete!!!", requestContext, methodContext, {
+      chains: [...Object.keys(context.config.chains)],
+    });
   }
 };
diff --git a/packages/agents/lighthouse/src/tasks/propagate/propagate.ts b/packages/agents/lighthouse/src/tasks/propagate/propagate.ts
index 018fc28415..1a5ef8a288 100644
--- a/packages/agents/lighthouse/src/tasks/propagate/propagate.ts
+++ b/packages/agents/lighthouse/src/tasks/propagate/propagate.ts
@@ -91,6 +91,8 @@ export const makePropagate = async (config: NxtpLighthouseConfig, chainData: Map
   } catch (e: unknown) {
     console.error("Error starting Propagate task. Sad! :(", e);
   } finally {
-    process.exit();
+    context.logger.info("Propagate task complete!", requestContext, methodContext, {
+      chains: [...Object.keys(context.config.chains)],
+    });
   }
 };
diff --git a/packages/agents/lighthouse/src/tasks/prover/prover.ts b/packages/agents/lighthouse/src/tasks/prover/prover.ts
index ccb2fff980..be36973977 100644
--- a/packages/agents/lighthouse/src/tasks/prover/prover.ts
+++ b/packages/agents/lighthouse/src/tasks/prover/prover.ts
@@ -16,6 +16,7 @@ import { acquireLock, prefetch, releaseLock } from "./operations/publisher";
 const context: ProverContext = {} as any;
 export const getContext = () => context;
 export const makeProverPublisher = async (config: NxtpLighthouseConfig, chainData: Map<string, ChainData>) => {
+  const { requestContext, methodContext } = createLoggingContext(makeProverPublisher.name);
   try {
     await makeProver(config, chainData);
     if (!(await acquireLock())) throw new Error("Could not acquire lock");
@@ -30,7 +31,8 @@ export const makeProverPublisher = async (config: NxtpLighthouseConfig, chainDat
     console.error("Error starting Prover-Publisher. Sad! :(", e);
   } finally {
     await closeDatabase();
-    process.exit();
+
+    context.logger.info("Prover complete!!!", requestContext, methodContext, {});
   }
 };
 
diff --git a/packages/agents/lighthouse/src/tasks/sendOutboundRoot/sendOutboundRoot.ts b/packages/agents/lighthouse/src/tasks/sendOutboundRoot/sendOutboundRoot.ts
index 6bd55a1c98..6c0c84383b 100644
--- a/packages/agents/lighthouse/src/tasks/sendOutboundRoot/sendOutboundRoot.ts
+++ b/packages/agents/lighthouse/src/tasks/sendOutboundRoot/sendOutboundRoot.ts
@@ -91,6 +91,8 @@ export const makeSendOutboundRoot = async (config: NxtpLighthouseConfig, chainDa
   } catch (e: unknown) {
     console.error("Error starting SendOutboundRoot task. Sad! :(", e);
   } finally {
-    process.exit();
+    context.logger.info("SendOutboundRoot task complete!!!", requestContext, methodContext, {
+      chains: [...Object.keys(context.config.chains)],
+    });
   }
 };