chore: allow config last_ledger

oraidex · Aug 26, 2024 · 736a61b · 736a61b
1 parent 207bdcf
commit 736a61b
Show file tree

Hide file tree

Showing 3 changed files with 13 additions and 7 deletions.
diff --git a/packages/relayer/.env.example b/packages/relayer/.env.example
@@ -1,3 +1,4 @@
 XRPL_RPC=
 MNEMONIC_ENCRYPTED=
-XRPL_SEED_ENCRYPTED=
+XRPL_SEED_ENCRYPTED=
+LAST_LEDGER=
diff --git a/packages/relayer/src/actions/orai-to-xrpl.ts b/packages/relayer/src/actions/orai-to-xrpl.ts
@@ -52,15 +52,15 @@ export default class OraiToXrpl implements RelayerAction {
               operation
             )}, got error: ${error}`
           );
-          // try reconnect
-          await this.xrplClient.client.connect();
         }
       }
     } catch (error) {
       console.error(
         "error querying unprocessed transactions orai to xrpl: ",
         error
       );
+      // try reconnect
+      await this.xrplClient.client.connect();
       return;
     }
   }

diff --git a/packages/relayer/src/relayer.ts b/packages/relayer/src/relayer.ts
@@ -59,10 +59,14 @@ export class XrplBridgeRelayer {
 
   async relay() {
     while (true) {
-      for (const relayerAction of this.relayerActions) {
-        await relayerAction.takeAction();
+      try {
+        for (const relayerAction of this.relayerActions) {
+          await relayerAction.takeAction();
+        }
+        await setTimeout(PROCESS_INTERVAL);
+      } catch (err) {
+        console.log(err);
       }
-      await setTimeout(PROCESS_INTERVAL);
     }
   }
 }
@@ -71,6 +75,7 @@ export default async (yargs: Argv) => {
   const oraiRpcUrl = process.env.RPC_URL ?? "https://rpc.orai.io";
   const xrplServer =
     process.env.XRPL_SERVER || "wss://s.altnet.rippletest.net:51233";
+  const lastLedger = Number(process.env.LAST_LEDGER) || -1;
   console.log(xrplServer);
 
   const discordWebhookUrl = process.env.DISCORD_WEBHOOK_URL;
@@ -110,7 +115,7 @@ export default async (yargs: Argv) => {
     bridgeAdapter.cwClient,
     bridgeAdapter.xrplClient,
     xrplBridgeAddr,
-    -1,
+    lastLedger,
     webhookClient
   );