feat: missing logger migrations

Author: FedericoAmura

packages/event-listener/src/lib/actions/log-context.ts

@@ -1,3 +1,5 @@
+import { logger } from '@lit-protocol/logger';
+
 import { Action } from './action';
 import { StateMachine } from '../state-machine';
 
@@ -10,10 +12,10 @@ interface LogContextActionParams {
 export class LogContextAction extends Action {
   constructor(params: LogContextActionParams) {
     const logContextFunction = async () => {
-      console.log(
-        `State Machine context: `,
-        params.stateMachine.getFromContext(params.path)
-      );
+      logger.info({
+        msg: `State Machine context`,
+        context: params.stateMachine.getFromContext(params.path),
+      });
     };
 
     super({

packages/event-listener/src/lib/actions/mint-pkp.ts

@@ -1,3 +1,5 @@
+import { logger } from '@lit-protocol/logger';
+
 import { Action } from './action';
 import { StateMachine } from '../state-machine';
 
@@ -12,7 +14,7 @@ export class MintPkpAction extends Action {
       const mintingReceipt =
         await params.stateMachine.litContracts.pkpNftContractUtils.write.mint();
       const pkp = mintingReceipt.pkp;
-      params.debug && console.log(`Minted PKP: ${pkp}`);
+      params.debug && logger.info(`Minted PKP: ${pkp}`);
       params.stateMachine.setToContext('activePkp', pkp);
     };
 

packages/event-listener/src/lib/listeners/fetch.ts

@@ -1,3 +1,5 @@
+import { logger } from '@lit-protocol/logger';
+
 import { Listener } from './listener';
 
 interface FetchListenerConfig {
@@ -32,7 +34,7 @@ export class FetchListener extends Listener<any> {
               this.emit(value);
             }
           } catch (error) {
-            console.error('FetchListener error:', error);
+            logger.error({ msg: 'FetchListener error:', error });
           }
         }, pollInterval);
       },

packages/event-listener/src/lib/state-machine.ts

@@ -7,6 +7,7 @@ import {
 } from '@lit-protocol/constants';
 import { LitContracts } from '@lit-protocol/contracts-sdk';
 import { LitNodeClient } from '@lit-protocol/lit-node-client';
+import { logger } from '@lit-protocol/logger';
 
 import {
   Action,
@@ -382,17 +383,17 @@ export class StateMachine {
     // Aggregate (AND) all listener checks to a single function result
     transitionConfig.check = async (values) => {
       this.debug &&
-        console.log(
-          `${transitionDefinition.fromState} -> ${transitionDefinition.toState} values`,
-          values
-        );
+        logger.info({
+          msg: `${transitionDefinition.fromState} -> ${transitionDefinition.toState} values`,
+          values,
+        });
       return Promise.all(checks.map((check) => check(values))).then(
         (results) => {
           this.debug &&
-            console.log(
-              `${transitionDefinition.fromState} -> ${transitionDefinition.toState} results`,
-              results
-            );
+            logger.info({
+              msg: `${transitionDefinition.fromState} -> ${transitionDefinition.toState} results`,
+              results,
+            });
           return results.every((result) => result);
         }
       );
@@ -410,7 +411,7 @@ export class StateMachine {
     initialState: string,
     onStop?: voidAsyncFunction
   ): Promise<void> {
-    this.debug && console.log('Starting state machine...');
+    this.debug && logger.info('Starting state machine...');
 
     await Promise.all([
       this.litContracts.connect(),
@@ -421,7 +422,7 @@ export class StateMachine {
     await this.enterState(initialState);
     this.status = 'running';
 
-    this.debug && console.log('State machine started');
+    this.debug && logger.info('State machine started');
   }
 
   /**
@@ -470,20 +471,21 @@ export class StateMachine {
    * Stops the state machine by exiting the current state and not moving to another one.
    */
   public async stopMachine(): Promise<void> {
-    this.debug && console.log('Stopping state machine...');
+    this.debug && logger.info('Stopping state machine...');
 
     this.status = 'stopped';
     await this.exitCurrentState();
     await this.onStopCallback?.();
 
-    this.debug && console.log('State machine stopped');
+    this.debug && logger.info('State machine stopped');
   }
 
   /**
    * Stops listening on the current state's transitions and exits the current state.
    */
   private async exitCurrentState(): Promise<void> {
-    this.debug && console.log('exitCurrentState', this.currentState?.key);
+    this.debug &&
+      logger.info({ msg: 'exitCurrentState', state: this.currentState?.key });
 
     const currentTransitions =
       this.transitions.get(this.currentState?.key ?? '') ??
@@ -514,7 +516,7 @@ export class StateMachine {
         `State ${stateKey} not found`
       );
     }
-    this.debug && console.log('enterState', state.key);
+    this.debug && logger.info({ msg: 'enterState', state: state.key });
     await state.enter();
     const nextTransitions =
       this.transitions.get(state.key) ?? new Map<string, Transition>();
@@ -542,7 +544,7 @@ export class StateMachine {
       );
     }
     if (this.currentState === nextState) {
-      console.warn(
+      logger.warn(
         `State ${stateKey} is already active. Skipping state change.`
       );
       return;
@@ -615,7 +617,7 @@ export class StateMachine {
           }
           if (this.debug) {
             const activePkp = this.context.get('activePkp');
-            console.log(`Machine configured to use pkp ${activePkp}`);
+            logger.info(`Machine configured to use pkp ${activePkp}`);
           }
           break;
         default:
@@ -665,7 +667,7 @@ export class StateMachine {
       }
 
       // Throwing when stopping could hide above error
-      this.stopMachine().catch(console.error);
+      this.stopMachine().catch((error) => logger.error({ error }));
     }
   }
 

packages/event-listener/src/lib/states/state.ts

@@ -1,3 +1,5 @@
+import { logger } from '@lit-protocol/logger';
+
 import { voidAsyncFunction } from '../types';
 
 export interface BaseStateParams {
@@ -29,15 +31,15 @@ export class State {
    * Executes the onEnter action for the state.
    */
   async enter() {
-    this.debug && console.log(`enter ${this.key}`);
+    this.debug && logger.info(`enter ${this.key}`);
     await this.onEnter?.();
   }
 
   /**
    * Executes the onExit action for the state.
    */
   async exit() {
-    this.debug && console.log(`exit ${this.key}`);
+    this.debug && logger.info(`exit ${this.key}`);
     await this.onExit?.();
   }
 }

packages/event-listener/src/lib/transitions/transition.ts

@@ -1,3 +1,5 @@
+import { logger } from '@lit-protocol/logger';
+
 import { Listener } from '../listeners';
 import { onError } from '../types';
 
@@ -75,13 +77,13 @@ export class Transition {
    */
   async startListening() {
     try {
-      this.debug && console.log('startListening');
+      this.debug && logger.info('startListening');
       await Promise.all(this.listeners.map((listener) => listener.start()));
 
       if (!this.listeners.length) {
         // If the transition does not have any listeners it will never emit. Therefore, we "match" automatically on next event loop
         setTimeout(() => {
-          this.debug && console.log('Transition without listeners: auto match');
+          this.debug && logger.info('Transition without listeners: auto match');
           this.onMatch([]);
         }, 0);
       }
@@ -99,7 +101,7 @@ export class Transition {
    */
   async stopListening() {
     try {
-      this.debug && console.log('stopListening');
+      this.debug && logger.info('stopListening');
       this.queue.length = 0; // Flush the queue as there might be more value arrays to check
       await Promise.all(this.listeners.map((listener) => listener.stop()));
     } catch (e) {
@@ -129,10 +131,10 @@ export class Transition {
         const isMatch = this.check ? await this.check(currentValues) : true;
 
         if (isMatch) {
-          this.debug && console.log('match', currentValues);
+          this.debug && logger.info({ msg: 'match', values: currentValues });
           await this.onMatch?.(currentValues);
         } else {
-          this.debug && console.log('mismatch', currentValues);
+          this.debug && logger.info({ msg: 'mismatch', values: currentValues });
           await this.onMismatch?.(currentValues);
         }
       }

packages/lit-node-client/src/lib/helpers/mint-claim-callback.ts

@@ -6,6 +6,7 @@ import {
   RELAYER_URL_BY_NETWORK,
   WrongNetworkException,
 } from '@lit-protocol/constants';
+import { logger } from '@lit-protocol/logger';
 import {
   ClaimResult,
   MintCallback,
@@ -77,7 +78,7 @@ export const defaultMintClaimCallback: MintCallback<
     const errStmt = `An error occurred requesting "/auth/claim" endpoint ${JSON.stringify(
       errResp
     )}`;
-    console.warn(errStmt);
+    logger.warn(errStmt);
     throw new NetworkError(
       {
         info: {