chore: Overhaul log statements

Author: jsanmigimeno

src/monitor/monitor.gateway.ts

@@ -35,7 +35,7 @@ export class MonitorGateway implements OnModuleInit {
     }
 
     private async listenToMonitors(): Promise<void> {
-        this.loggerService.info(`Listening to Monitor services to broadcast state events.`);
+        this.loggerService.debug(`Listening to Monitor services to broadcast state events.`);
 
         for (const [chainId] of this.configService.chainsConfig) {
             const monitorPort = await this.monitorService.attachToMonitor(chainId);

src/monitor/monitor.worker.ts

@@ -136,7 +136,7 @@ class MonitorWorker {
 
     private broadcastStatus(): void {
         if (!this.latestBlock) {
-            this.logger.warn('Unable to broadcast status. \'latestBlock\' is null.');
+            this.logger.error('Unable to broadcast status. \'latestBlock\' is null.');
             return;
         }
 

src/submitter/queues/eval-queue.ts

@@ -50,6 +50,11 @@ export class EvalQueue extends ProcessingQueue<EvalOrder, SubmitOrder> {
         order: EvalOrder,
         _retryCount: number,
     ): Promise<HandleOrderResult<SubmitOrder> | null> {
+        this.logger.debug(
+            { messageIdentifier: order.messageIdentifier },
+            `Handling submitter eval order.`,
+        );
+
         const bounty = await this.queryBountyInfo(order.messageIdentifier);
         if (bounty === null || bounty === undefined) {
             throw Error(
@@ -306,7 +311,7 @@ export class EvalQueue extends ProcessingQueue<EvalOrder, SubmitOrder> {
             securedDeliveryRelativeProfit > this.evaluationConfig.relativeMinDeliveryReward
         );
 
-        this.logger.debug(
+        this.logger.info(
             {
                 messageIdentifier: bounty.messageIdentifier,
                 maxGasDelivery: bounty.maxGasDelivery,
@@ -396,7 +401,7 @@ export class EvalQueue extends ProcessingQueue<EvalOrder, SubmitOrder> {
             ackRelativeProfit > this.evaluationConfig.relativeMinAckReward
         );
 
-        this.logger.debug(
+        this.logger.info(
             {
                 messageIdentifier: bounty.messageIdentifier,
                 maxGasDelivery: bounty.maxGasDelivery,

src/submitter/queues/submit-queue.ts

@@ -32,7 +32,7 @@ export class SubmitQueue extends ProcessingQueue<
     ): Promise<HandleOrderResult<SubmitOrderResult> | null> {
         this.logger.debug(
             { messageIdentifier: order.messageIdentifier },
-            `Handling submit order`,
+            `Handling submitter submit order`,
         );
 
         // Simulate the packet submission as a static call. Skip if it's the first submission try,
@@ -113,20 +113,20 @@ export class SubmitQueue extends ProcessingQueue<
 
         if (success) {
             if (result != null) {
-                this.logger.debug(
+                this.logger.info(
                     orderDescription,
                     `Successful submit order: message submitted.`,
                 );
 
                 void this.registerSubmissionCost(order, result.txReceipt.gasUsed);
             } else {
-                this.logger.debug(
+                this.logger.info(
                     orderDescription,
                     `Successful submit order: message not submitted.`,
                 );
             }
         } else {
-            this.logger.error(orderDescription, `Unsuccessful submit order.`);
+            this.logger.warn(orderDescription, `Unsuccessful submit order.`);
 
             if (order.priority) {
                 this.logger.warn(

src/submitter/submitter.worker.ts

@@ -276,7 +276,7 @@ class SubmitterWorker {
         priority: boolean,
         incentivesPayload?: BytesLike,
     ) {
-        this.logger.debug(
+        this.logger.info(
             { messageIdentifier, priority },
             `Submit order received.`,
         );

src/wallet/queues/confirm-queue.ts

@@ -38,6 +38,11 @@ export class ConfirmQueue extends ProcessingQueue<PendingTransaction, ConfirmedT
         order: PendingTransaction,
         retryCount: number,
     ): Promise<HandleOrderResult<ConfirmedTransaction> | null> {
+        this.logger.debug(
+            { txRequest: order.txRequest },
+            `Handling wallet confirm order.`,
+        );
+
         // If it's the first time the order is processed, just wait for it
         if (retryCount == 0) {
             const transactionReceipt = order.tx.wait(
@@ -206,7 +211,7 @@ export class ConfirmQueue extends ProcessingQueue<PendingTransaction, ConfirmedT
         };
 
         if (success) {
-            this.logger.debug(orderDescription, `Transaction confirmed.`);
+            this.logger.info(orderDescription, `Transaction confirmed.`);
         } else {
             this.logger.error(orderDescription, `Transaction not confirmed.`);
         }

src/wallet/queues/submit-queue.ts

@@ -30,6 +30,10 @@ export class SubmitQueue extends ProcessingQueue<WalletTransactionRequest, Pendi
         order: WalletTransactionRequest,
         _retryCount: number
     ): Promise<HandleOrderResult<PendingTransaction> | null> {
+        this.logger.debug(
+            { txRequest: order.txRequest },
+            `Handling wallet submit order.`,
+        );
 
         const txDeadline = order.options.deadline ?? Infinity;
         if (Date.now() > txDeadline) {
@@ -104,12 +108,12 @@ export class SubmitQueue extends ProcessingQueue<WalletTransactionRequest, Pendi
 
         if (success) {
             if (result != null) {
-                this.logger.debug(
+                this.logger.info(
                     orderDescription,
                     `Successful transaction processing: transaction submitted.`,
                 );
             } else {
-                this.logger.debug(
+                this.logger.info(
                     orderDescription,
                     `Successful transaction processing: transaction not submitted.`,
                 );

src/wallet/wallet.worker.ts

@@ -321,7 +321,7 @@ class WalletWorker {
                 submissionError: tryErrorToString(transaction.submissionError)
             };
 
-            this.logger.debug(
+            this.logger.info(
                 logDescription,
                 `Unsuccessful transaction processing: transaction failed.`,
             );
@@ -348,7 +348,7 @@ class WalletWorker {
                 blockNumber: transaction.txReceipt.blockNumber
             };
 
-            this.logger.debug(
+            this.logger.info(
                 logDescription,
                 `Successful transaction processing: transaction confirmed.`,
             );
@@ -397,7 +397,7 @@ class WalletWorker {
 
                 await this.submitQueue.addOrders(requeueRequest);
             } else {
-                this.logger.debug(
+                this.logger.info(
                     logDescription,
                     `Unsuccessful transaction processing: transaction rejected.`,
                 );
@@ -433,7 +433,7 @@ class WalletWorker {
                     return null;
                 }
 
-                this.logger.debug(
+                this.logger.info(
                     { cancelTxNonce },
                     'Submitting transaction cancellation'
                 );