fix: replaced console logs with logger in adapters and agents

Author: otsybizov

packages/adapters/cache/src/lib/caches/cache.ts

@@ -1,10 +1,19 @@
 import Redis from 'ioredis';
+import { Logger } from '@chimera-monorepo/utils';
 
 import { CacheParams, RedisClearFailure } from '../entities';
 
 /**
  * @classdesc Manages storage, updates, and retrieval of a set of data determined by use-case.
  */
+const logger = new Logger({
+  level: 'info',
+  name: 'cache',
+  formatters: {
+    level: (label) => ({ level: label.toUpperCase() }),
+  },
+});
+
 export abstract class Cache {
   protected readonly data!: Redis;
 
@@ -22,7 +31,7 @@ export abstract class Cache {
       });
       // Handle Redis connection errors to prevent unhandled exceptions
       this.data.on('error', (err) => {
-        console.error('Redis connection error:', err);
+        logger.error('Redis connection error', undefined, undefined, undefined, { error: err });
       });
     }
   }

packages/adapters/chainservice/src/aggregator.ts

@@ -131,7 +131,7 @@ export class RpcProviderAggregator {
    * @returns The TransactionResponse.
    */
   public async sendTransaction(transaction: OnchainTransaction) {
-    console.log(`=== sendTransaction called with domain ${this.domain} ===`);
+    this.logger.debug(`sendTransaction called with domain ${this.domain}`);
     this.checkSigner();
 
     const toSend = {

packages/adapters/chainservice/src/dispatch.ts

@@ -359,7 +359,7 @@ export class TransactionDispatch {
    * @returns A list of receipts or errors that occurred for each.
    */
   public async send(minTx: WriteTransaction, context: RequestContext): Promise<ITransactionReceipt> {
-    console.log(`=== DISPATCH SEND called for domain ${this.domain} ===`);
+    this.logger.debug(`Dispatch send called for domain ${this.domain}`);
     const method = this.send.name;
     const { requestContext, methodContext } = createLoggingContext(method, context);
     const txsId = getUuid();
@@ -544,7 +544,7 @@ export class TransactionDispatch {
    * @param transaction - OnchainTransaction object to modify based on submit result.
    */
   private async submit(transaction: OnchainTransaction) {
-    console.log(`=== DISPATCH SUBMIT called for domain ${this.domain} ===`);
+    this.logger.debug(`Dispatch submit called for domain ${this.domain}`);
     const method = this.submit.name;
     const { requestContext, methodContext } = createLoggingContext(method, transaction.context);
     this.logger.debug('Method start', requestContext, methodContext, {
@@ -562,7 +562,7 @@ export class TransactionDispatch {
 
     // Send the tx.
     try {
-      console.log(`=== DISPATCH SUBMIT about to call sendTransaction ===`);
+      this.logger.debug('Dispatch submit about to call sendTransaction');
       const response = await this.rpcProvider.sendTransaction(transaction);
       // Add this response to our local response history.
       if (transaction.hashes.includes(response.hash)) {

packages/adapters/chainservice/src/shared/rpc/eth/provider.ts

@@ -1,11 +1,18 @@
-import { EverclearError, delay, domainToChainId, parseHostname, ERC20Abi } from '@chimera-monorepo/utils';
+import { EverclearError, Logger, delay, domainToChainId, parseHostname, ERC20Abi } from '@chimera-monorepo/utils';
 import { chainWrapper, type PublicClient } from '@chimera-monorepo/utils';
-
 import { parseError, RpcError, ServerError, StallTimeout } from '../../errors';
 import { ISigner, ReadTransaction, WriteTransaction, ITransactionReceipt, ITransactionResponse, IBlock } from '../../types';
 import { RpcProvider } from '..';
 import { EthWallet } from './wallet';
 
+const ethProviderLogger = new Logger({
+  level: 'debug',
+  name: 'eth-provider',
+  formatters: {
+    level: (label) => ({ level: label.toUpperCase() }),
+  },
+});
+
 // TODO: Wrap metrics in a type, and add a getter for it for logging purposes (after sync() calls, for example)
 // TODO: Should be a multiton mapped by URL (such that no duplicate instances are created).
 /**
@@ -144,7 +151,7 @@ class BaseSyncProvider {
       try {
         sendTimestamp = Date.now();
         this.cpsTimestamps.push(sendTimestamp);
-        console.log(`=== ETH PROVIDER SEND called with method: ${method}, domain: ${this.domain}, params:`, params);
+        this.debugLog('ETH_PROVIDER_SEND', method, this.domain, params);
         return await Promise.race(
           [
             new Promise(async (resolve, reject) => {
@@ -248,8 +255,7 @@ class BaseSyncProvider {
 
   private debugLog(message: string, ...args: unknown[]) {
     if (this.debugLogging) {
-      // eslint-disable-next-line
-      console.log(`[${Date.now()}]`, `(${this.name})`, message, ...args);
+      ethProviderLogger.debug(`(${this.name}) ${message}`, undefined, undefined, { args });
     }
   }