fix: resolve lh propose bootup

connext · Oct 12, 2023 · 8007a97 · 8007a97
1 parent b170bd3
commit 8007a97
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 2 deletions.
diff --git a/packages/agents/lighthouse/src/tasks/index.ts b/packages/agents/lighthouse/src/tasks/index.ts
@@ -36,7 +36,7 @@ export const makeLighthouse = async (event?: any) => {
     case "sendoutboundroot":
       await makeSendOutboundRoot(config, chainData);
       break;
-    case "proposer":
+    case "propose":
       await makePropose(config, chainData);
       break;
   }

diff --git a/packages/agents/lighthouse/src/tasks/propose/operations/propose.ts b/packages/agents/lighthouse/src/tasks/propose/operations/propose.ts
@@ -64,7 +64,8 @@ export const propose = async () => {
 
   const latestSnapshotIds = [...new Map([...pendingSnapshotsById].sort().reverse()).keys()];
   if (latestSnapshotIds.length === 0) {
-    logger.info("No pending snapshot roots found", requestContext, methodContext);
+    logger.info("No pending snapshot roots found. Nothing to propose", requestContext, methodContext);
+    return;
   }
   const latestSnapshotId = latestSnapshotIds[0];
 

diff --git a/packages/agents/lighthouse/src/tasks/propose/propose.ts b/packages/agents/lighthouse/src/tasks/propose/propose.ts
@@ -1,4 +1,5 @@
 import { ChainReader, contractDeployments, getAmbABIs, getContractInterfaces } from "@connext/nxtp-txservice";
+import { closeDatabase, getDatabase } from "@connext/nxtp-adapters-database";
 import {
   ChainData,
   createLoggingContext,
@@ -46,6 +47,7 @@ export const makePropose = async (config: NxtpLighthouseConfig, chainData: Map<s
       context.logger.child({ module: "ChainReader" }),
       context.config.chains,
     );
+    context.adapters.database = await getDatabase(context.config.database.url, context.logger);
 
     context.adapters.relayers = [];
     for (const relayerConfig of context.config.relayers) {
@@ -106,6 +108,8 @@ export const makePropose = async (config: NxtpLighthouseConfig, chainData: Map<s
     }
   } catch (e: unknown) {
     console.error("Error starting Propose task. Sad! :(", e);
+    await closeDatabase();
+    process.exit();
   } finally {
     process.exit();
   }