fix: 5125 sendoutboundroot cron called twice (#5129)

* fix: remove `process.exit()` sendoutboundroot * fix: remove `process.exit` from LH
connext · Nov 6, 2023 · d4ae7de · d4ae7de
1 parent 0a4fd27
commit d4ae7de
Show file tree

Hide file tree

Showing 4 changed files with 13 additions and 4 deletions.
diff --git 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
@@ -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
@@ -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
@@ -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)],
+    });
   }
 };