fix: adjust logger levels to ensure correct logging (#1577)

Author: greatertomi

packages/cardano-services-client/src/ChainHistoryProvider/BlockfrostChainHistoryProvider.ts

@@ -153,7 +153,7 @@ export class BlockfrostChainHistoryProvider extends BlockfrostProvider implement
     return this.fetchCBOR(hash)
       .then((cbor) => {
         const tx = Serialization.Transaction.fromCbor(Serialization.TxCBOR(cbor)).toCore();
-        this.logger.info('Fetched details from CBOR for tx', hash);
+        this.logger.debug('Fetched details from CBOR for tx', hash);
         return tx;
       })
       .catch((error) => {
@@ -498,7 +498,7 @@ export class BlockfrostChainHistoryProvider extends BlockfrostProvider implement
     pagination,
     blockRange
   }: TransactionsByAddressesArgs): Promise<Paginated<Cardano.HydratedTx>> {
-    this.logger.info(`transactionsByAddresses: ${JSON.stringify(blockRange)} ${JSON.stringify(addresses)}`);
+    this.logger.debug(`transactionsByAddresses: ${JSON.stringify(blockRange)} ${JSON.stringify(addresses)}`);
     try {
       const lowerBound = blockRange?.lowerBound ?? 0;
       const upperBound = blockRange?.upperBound ?? DB_MAX_SAFE_INTEGER;

packages/cardano-services-client/src/UtxoProvider/BlockfrostUtxoProvider.ts

@@ -36,7 +36,7 @@ export class BlockfrostUtxoProvider extends BlockfrostProvider implements UtxoPr
     const result = await this.fetchCBOR(hash)
       .then((cbor) => {
         const tx = Serialization.Transaction.fromCbor(Serialization.TxCBOR(cbor)).toCore();
-        this.logger.info('Fetched details from CBOR for tx', hash);
+        this.logger.debug('Fetched details from CBOR for tx', hash);
         return tx;
       })
       .catch((error) => {

packages/cardano-services-client/src/WebSocket.ts

@@ -401,7 +401,7 @@ export class CardanoWsClient extends WsProvider {
     };
 
     ws.onclose = () => {
-      this.logger.info('WebSocket client connection closed', this.clientId);
+      this.logger.debug('WebSocket client connection closed', this.clientId);
 
       if (this.heartbeatTimeout) {
         clearInterval(this.heartbeatTimeout);

packages/e2e/src/factories.ts

@@ -623,7 +623,7 @@ export const getWallet = async (props: GetWalletProps) => {
   );
 
   const [{ address, rewardAccount }] = await firstValueFrom(wallet.addresses$);
-  logger.info(`Created wallet "${wallet.name}": ${address}/${rewardAccount}`);
+  logger.debug(`Created wallet "${wallet.name}": ${address}/${rewardAccount}`);
 
   const maxInterval =
     polling?.maxInterval ||
@@ -705,7 +705,7 @@ export const getSharedWallet = async (props: GetSharedWalletProps) => {
   );
 
   const [{ address, rewardAccount }] = await firstValueFrom(wallet.addresses$);
-  logger.info(`Created wallet "${wallet.name}": ${address}/${rewardAccount}`);
+  logger.debug(`Created wallet "${wallet.name}": ${address}/${rewardAccount}`);
 
   const maxInterval =
     polling?.maxInterval ||

packages/e2e/test/artillery/wallet-restoration/WalletRestoration.ts

@@ -54,15 +54,15 @@ const extractAddresses = async (count: number): Promise<AddressesModel[]> => {
         throw new Error(`You can not restore more than ${dump.length} distinct wallets for ${network} network.`);
       }
       result = dump.slice(0, count);
-      logger.info(`Selected subset of predefined ${network} addresses with count: ${result.length}.`);
+      logger.debug(`Selected subset of predefined ${network} addresses with count: ${result.length}.`);
     } else if (env.DB_SYNC_CONNECTION_STRING) {
       const db = new Pool({ connectionString: env.DB_SYNC_CONNECTION_STRING });
-      logger.info('About to query db for distinct addresses.');
+      logger.debug('About to query db for distinct addresses.');
       result = (await db.query(findAddressesWithRegisteredStakeKey, [count])).rows;
       if (result.length < count) {
         throw new Error(`Addresses found from db are less than desired wallets count of ${count}`);
       }
-      logger.info(`Found DB addresses count: ${result.length}`);
+      logger.debug(`Found DB addresses count: ${result.length}`);
     } else {
       throw new Error('Please provide a valid KEY_MANAGEMENT_PARAMS or DB_SYNC_CONNECTION_STRING env variable.');
     }
@@ -84,7 +84,7 @@ let index = 0;
 
 export const walletRestoration: FunctionHook<WalletVars> = async ({ vars, _uid }, ee, done) => {
   const currentAddress = vars.addresses[index];
-  logger.info(`Current address: ${currentAddress.address}`);
+  logger.debug(`Current address: ${currentAddress.address}`);
   ++index;
 
   try {
@@ -109,7 +109,7 @@ export const walletRestoration: FunctionHook<WalletVars> = async ({ vars, _uid }
     ee.emit('histogram', `${operationName}.time`, Date.now() - startedAt);
     ee.emit('counter', operationName, 1);
 
-    logger.info(
+    logger.debug(
       `Wallet with name ${vars.currentWallet.name} and address ${currentAddress.address} was successfully restored`
     );
   } catch (error) {
@@ -124,6 +124,6 @@ export const walletRestoration: FunctionHook<WalletVars> = async ({ vars, _uid }
 
 export const shutdownWallet: FunctionHook<WalletVars> = async ({ vars, _uid }, _ee, done) => {
   vars.currentWallet?.shutdown();
-  logger.info(`Wallet with VU id ${_uid} was shutdown`);
+  logger.debug(`Wallet with VU id ${_uid} was shutdown`);
   done();
 };

packages/e2e/test/web-extension/extension/background/cip30.ts

@@ -12,12 +12,12 @@ import { walletName } from '../const';
 const confirmationCallback: walletCip30.CallbackConfirmation = {
   signData: async ({ sender }) => {
     if (!sender) throw new Error('No sender context');
-    logger.info('signData request from', sender);
+    logger.debug('signData request from', sender);
     return { cancel$: NEVER };
   },
   signTx: async ({ sender }) => {
     if (!sender) throw new Error('No sender context');
-    logger.info('signTx request', sender);
+    logger.debug('signTx request', sender);
     return { cancel$: NEVER };
   },
   submitTx: async () => true

packages/ogmios/src/CardanoNode/OgmiosObservableCardanoNode/OgmiosObservableCardanoNode.ts

@@ -90,7 +90,7 @@ const stateQueryRetryBackoffConfig = (
   ...retryConfig,
   shouldRetry: (error) => {
     if (retryableStateQueryErrors.has(CardanoNodeUtil.asCardanoNodeError(error)?.code)) {
-      logger.info('Local state query unavailable yet, will retry...');
+      logger.debug('Local state query unavailable yet, will retry...');
       return true;
     }
     return false;

packages/ogmios/src/CardanoNode/queries.ts

@@ -138,15 +138,15 @@ export const withCoreCardanoNodeError = async <T>(operation: () => Promise<T>) =
 
 export const queryEraSummaries = (client: LedgerStateQuery.LedgerStateQueryClient, logger: Logger) =>
   withCoreCardanoNodeError(async () => {
-    logger.info('Querying era summaries');
+    logger.debug('Querying era summaries');
     const systemStart = new Date((await client.genesisConfiguration('byron')).startTime);
     const eraSummaries = await client.eraSummaries();
     return eraSummaries.map((era) => eraSummary(era, systemStart));
   });
 
 export const queryGenesisParameters = (client: LedgerStateQuery.LedgerStateQueryClient, logger: Logger) =>
   withCoreCardanoNodeError(async () => {
-    logger.info('Querying genesis parameters');
+    logger.debug('Querying genesis parameters');
     // Update this to query multiple eras if the CompactGenesis type will have to include params from other eras
     return genesis(await client.genesisConfiguration('shelley'));
   });

packages/util/src/RunnableModule.ts

@@ -48,46 +48,46 @@ export abstract class RunnableModule {
       throw new InvalidModuleState<RunnableModuleState>(this.name, 'initializeBefore', null);
     }
     this.state = 'initializing';
-    this.logger.info('Initializing...');
+    this.logger.debug('Initializing...');
   }
 
   initializeAfter() {
     if (this.state !== 'initializing') {
       throw new InvalidModuleState<RunnableModuleState>(this.name, 'initializeAfter', 'initializing');
     }
     this.state = 'initialized';
-    this.logger.info('Initialized');
+    this.logger.debug('Initialized');
   }
 
   startBefore() {
     if (this.state !== 'initialized') {
       throw new InvalidModuleState<RunnableModuleState>(this.name, 'start', 'initialized');
     }
     this.state = 'starting';
-    this.logger.info('Starting...');
+    this.logger.debug('Starting...');
   }
 
   startAfter() {
     if (this.state !== 'starting') {
       throw new InvalidModuleState<RunnableModuleState>(this.name, 'start', 'starting');
     }
     this.state = 'running';
-    this.logger.info('Started');
+    this.logger.debug('Started');
   }
 
   shutdownBefore() {
     if (this.state !== 'running') {
       throw new InvalidModuleState<RunnableModuleState>(this.name, 'shutdown', 'running');
     }
     this.state = 'stopping';
-    this.logger.info('Stopping...');
+    this.logger.debug('Stopping...');
   }
 
   shutdownAfter() {
     if (this.state !== 'stopping') {
       throw new InvalidModuleState<RunnableModuleState>(this.name, 'shutdown', 'stopping');
     }
     this.state = 'initialized';
-    this.logger.info('Shutdown complete');
+    this.logger.debug('Shutdown complete');
   }
 }

packages/util/test/RunnableModule.test.ts

@@ -35,7 +35,7 @@ describe('RunnableModule', () => {
     it('optionally takes a logger on construction', () => {
       const runnableModule = new SomeRunnableModule(logger);
       expect(runnableModule.state).toBeNull();
-      expect(logger.info).not.toHaveBeenCalled();
+      expect(logger.debug).not.toHaveBeenCalled();
     });
   });
   describe('initialize', () => {
@@ -49,11 +49,11 @@ describe('RunnableModule', () => {
       expect(runnableModule.state).toBeNull();
       await runnableModule.initialize();
       expect(runnableModule.state).toBe('initialized');
-      expect(logger.info).toHaveBeenCalled();
+      expect(logger.debug).toHaveBeenCalled();
       jest.resetAllMocks();
       await expect(runnableModule.initialize()).rejects.toThrowError(InvalidModuleState);
       expect(runnableModule.state).toBe('initialized');
-      expect(logger.info).not.toHaveBeenCalled();
+      expect(logger.debug).not.toHaveBeenCalled();
     });
   });
 
@@ -68,12 +68,12 @@ describe('RunnableModule', () => {
     it('changes state if initialized and not already in progress, and logs info', async () => {
       expect(runnableModule.state).toBe('initialized');
       await runnableModule.start();
-      expect(logger.info).toHaveBeenCalled();
+      expect(logger.debug).toHaveBeenCalled();
       expect(runnableModule.state).toBe('running');
       jest.resetAllMocks();
       await expect(runnableModule.initialize()).rejects.toThrowError(InvalidModuleState);
       expect(runnableModule.state).toBe('running');
-      expect(logger.info).not.toHaveBeenCalled();
+      expect(logger.debug).not.toHaveBeenCalled();
     });
   });
 
@@ -89,13 +89,13 @@ describe('RunnableModule', () => {
     it('changes state if running and not already in progress, and logs info', async () => {
       expect(runnableModule.state).toBe('running');
       await runnableModule.shutdown();
-      expect(logger.info).toHaveBeenCalled();
+      expect(logger.debug).toHaveBeenCalled();
       expect(runnableModule.state).toBe('initialized');
       jest.resetAllMocks();
       await expect(runnableModule.initialize()).rejects.toThrowError(InvalidModuleState);
       await expect(runnableModule.shutdown()).rejects.toThrowError(InvalidModuleState);
       expect(runnableModule.state).toBe('initialized');
-      expect(logger.info).not.toHaveBeenCalled();
+      expect(logger.debug).not.toHaveBeenCalled();
     });
   });
 });

packages/web-extension/src/walletManager/SigningCoordinator/SigningCoordinator.ts

@@ -97,7 +97,7 @@ export class SigningCoordinator<WalletMetadata extends {}, AccountMetadata exten
         walletType: requestContext.wallet.type
       },
       (keyAgent) => {
-        this.#logger.info('Signing transaction', transaction.getId());
+        this.#logger.debug('Signing transaction', transaction.getId());
         return keyAgent.signTransaction(transaction.body(), signContext, options);
       }
     );