Updates: Removed logs + queuedAt indexed

Author: farhanW3

src/prisma/migrations/20240802175702_transaction_tbl_queued_at_idx/migration.sql

@@ -0,0 +1,2 @@
+-- CreateIndex
+CREATE INDEX CONCURRENTLY "transactions_queuedAt_idx" ON "transactions"("queuedAt");

src/prisma/schema.prisma

@@ -163,6 +163,7 @@ model Transactions {
   @@index([sentAt, minedAt, cancelledAt, errorMessage, queuedAt])
   @@index([sentAt, accountAddress, userOpHash, minedAt, errorMessage, retryCount])
   @@index([sentAt, transactionHash, accountAddress, minedAt, errorMessage, nonce])
+  @@index([queuedAt])
   @@map("transactions")
 }
 

src/worker/tasks/processTx.ts

@@ -116,7 +116,7 @@ export const processTx = async () => {
           });
           logger({
             service: "worker",
-            level: "info",
+            level: "debug",
             message: `[processTx] Got DB nonce ${dbNonceData?.nonce} for ${walletAddress}.`,
           });
 
@@ -129,7 +129,7 @@ export const processTx = async () => {
             ]);
           logger({
             service: "worker",
-            level: "info",
+            level: "debug",
             message: `[processTx] Got onchain nonce ${mempoolNonceData} for ${walletAddress}.`,
           });
 
@@ -152,7 +152,7 @@ export const processTx = async () => {
 
           logger({
             service: "worker",
-            level: "info",
+            level: "debug",
             message: `[processTx] Sending ${txsToSend.length} transactions from wallet ${walletAddress}.`,
           });
 
@@ -314,7 +314,7 @@ export const processTx = async () => {
 
           logger({
             service: "worker",
-            level: "info",
+            level: "debug",
             message: `[processTx] Updated nonce to ${nextUnusedNonce} for ${walletAddress}.`,
           });
 
@@ -536,7 +536,7 @@ export const processTx = async () => {
 
         logger({
           service: "worker",
-          level: "info",
+          level: "debug",
           message: `[processTx] Awaiting transactions/userOps promises...`,
         });
         await Promise.all([...sentTxs, ...sentUserOps]);