config updates + retry update (#434)

Author: farhanW3

src/db/configuration/getConfiguration.ts

@@ -178,8 +178,8 @@ export const getConfiguration = async (): Promise<Config> => {
         maxTxsToProcess: 30,
         minedTxListenerCronSchedule: "*/5 * * * * *",
         maxTxsToUpdate: 50,
-        retryTxListenerCronSchedule: "*/30 * * * * *",
-        minEllapsedBlocksBeforeRetry: 15,
+        retryTxListenerCronSchedule: "*/10 * * * * *",
+        minEllapsedBlocksBeforeRetry: 4,
         maxFeePerGasForRetries: ethers.utils
           .parseUnits("1000", "gwei")
           .toString(),

src/db/transactions/getTxToRetry.ts

@@ -29,6 +29,7 @@ WHERE
   AND "transactionHash" IS NOT NULL
   AND "retryCount" < ${config.maxRetriesPerTx}
 ORDER BY
+  "sentAt",
   "nonce"
 ASC
 LIMIT

src/worker/tasks/retryTx.ts

@@ -49,21 +49,21 @@ export const retryTx = async () => {
         }
 
         const gasOverrides = await getGasSettingsForRetry(tx, provider);
-        if (
-          gasOverrides.maxFeePerGas?.gt(config.maxFeePerGasForRetries) ||
-          gasOverrides.maxPriorityFeePerGas?.gt(
-            config.maxPriorityFeePerGasForRetries,
-          )
-        ) {
-          // Return if gas settings exceed configured limits. Try again later.
-          logger({
-            service: "worker",
-            level: "warn",
-            queueId: tx.id,
-            message: `${tx.chainId} chain gas price is higher than maximum threshold.`,
-          });
-          return;
-        }
+        // if (
+        //   gasOverrides.maxFeePerGas?.gt(config.maxFeePerGasForRetries) ||
+        //   gasOverrides.maxPriorityFeePerGas?.gt(
+        //     config.maxPriorityFeePerGasForRetries,
+        //   )
+        // ) {
+        //   // Return if gas settings exceed configured limits. Try again later.
+        //   logger({
+        //     service: "worker",
+        //     level: "warn",
+        //     queueId: tx.id,
+        //     message: `${tx.chainId} chain gas price is higher than maximum threshold.`,
+        //   });
+        //   return;
+        // }
 
         logger({
           service: "worker",