From 43f4429998aae650352ac9c1f96d3ddcdc5f2cf4 Mon Sep 17 00:00:00 2001 From: Boki Date: Fri, 20 Jun 2025 08:02:58 -0400 Subject: [PATCH] cleaned up logs for apps --- apps/data-service/src/index.ts | 14 +++++++------- apps/data-service/src/providers/ib.provider.ts | 8 ++++---- apps/data-service/src/providers/proxy.provider.ts | 4 ++-- apps/data-service/src/providers/qm.provider.ts | 12 ++++++------ .../src/providers/webshare.provider.ts | 6 +++--- apps/data-sync-service/src/index.ts | 8 ++++---- apps/web-api/src/index.ts | 4 ++-- 7 files changed, 28 insertions(+), 28 deletions(-) diff --git a/apps/data-service/src/index.ts b/apps/data-service/src/index.ts index f069b05..7e9da31 100644 --- a/apps/data-service/src/index.ts +++ b/apps/data-service/src/index.ts @@ -65,7 +65,7 @@ async function initializeServices() { try { // Initialize MongoDB client singleton - logger.info('Connecting to MongoDB...'); + logger.debug('Connecting to MongoDB...'); const mongoConfig = databaseConfig.mongodb; await connectMongoDB({ uri: mongoConfig.uri, @@ -81,7 +81,7 @@ async function initializeServices() { logger.info('MongoDB connected'); // Initialize PostgreSQL client singleton - logger.info('Connecting to PostgreSQL...'); + logger.debug('Connecting to PostgreSQL...'); const pgConfig = databaseConfig.postgres; await connectPostgreSQL({ host: pgConfig.host, @@ -98,7 +98,7 @@ async function initializeServices() { logger.info('PostgreSQL connected'); // Initialize queue system - logger.info('Initializing queue system...'); + logger.debug('Initializing queue system...'); const queueManagerConfig: QueueManagerConfig = { redis: queueConfig.redis, defaultQueueOptions: { @@ -115,7 +115,7 @@ async function initializeServices() { logger.info('Queue system initialized'); // Initialize providers (register handlers and scheduled jobs) - logger.info('Initializing data providers...'); + logger.debug('Initializing data providers...'); const { initializeExchangeSyncProvider } = await import('./providers/exchange-sync.provider'); const { initializeIBProvider } = await import('./providers/ib.provider'); const { initializeProxyProvider } = await import('./providers/proxy.provider'); @@ -130,7 +130,7 @@ async function initializeServices() { logger.info('Data providers initialized'); // Create scheduled jobs from registered handlers - logger.info('Creating scheduled jobs from registered handlers...'); + logger.debug('Creating scheduled jobs from registered handlers...'); const { handlerRegistry } = await import('@stock-bot/queue'); const allHandlers = handlerRegistry.getAllHandlers(); @@ -163,7 +163,7 @@ async function initializeServices() { jobOptions ); totalScheduledJobs++; - logger.info('Scheduled job created', { + logger.debug('Scheduled job created', { handler: handlerName, operation: scheduledJob.operation, cronPattern: scheduledJob.cronPattern, @@ -245,7 +245,7 @@ shutdown.onShutdown(async () => { // Start the service startServer().catch(error => { - logger.error('Failed to start data service', { error }); + logger.fatal('Failed to start data service', { error }); process.exit(1); }); diff --git a/apps/data-service/src/providers/ib.provider.ts b/apps/data-service/src/providers/ib.provider.ts index 699488d..d436e5e 100644 --- a/apps/data-service/src/providers/ib.provider.ts +++ b/apps/data-service/src/providers/ib.provider.ts @@ -9,7 +9,7 @@ const logger = getLogger('ib-provider'); // Initialize and register the IB provider export function initializeIBProvider() { - logger.info('Registering IB provider with scheduled jobs...'); + logger.debug('Registering IB provider with scheduled jobs...'); const ibProviderConfig: HandlerConfigWithSchedule = { name: 'ib', @@ -52,11 +52,11 @@ export function initializeIBProvider() { logger.info('Fetched symbol summary from IB'); if (sessionHeaders) { - logger.info('Fetching exchanges from IB'); + logger.debug('Fetching exchanges from IB'); const exchanges = await fetchExchanges(sessionHeaders); logger.info('Fetched exchanges from IB', { count: exchanges?.length }); - logger.info('Fetching symbols from IB'); + logger.debug('Fetching symbols from IB'); const symbols = await fetchSymbols(sessionHeaders); logger.info('Fetched symbols from IB', { symbols }); @@ -78,5 +78,5 @@ export function initializeIBProvider() { }; handlerRegistry.registerWithSchedule(ibProviderConfig); - logger.info('IB provider registered successfully with scheduled jobs'); + logger.debug('IB provider registered successfully with scheduled jobs'); } diff --git a/apps/data-service/src/providers/proxy.provider.ts b/apps/data-service/src/providers/proxy.provider.ts index 1a9c0d3..c82a76e 100644 --- a/apps/data-service/src/providers/proxy.provider.ts +++ b/apps/data-service/src/providers/proxy.provider.ts @@ -10,7 +10,7 @@ const logger = getLogger('proxy-provider'); // Initialize and register the Proxy provider export function initializeProxyProvider() { - logger.info('Registering proxy provider with scheduled jobs...'); + logger.debug('Registering proxy provider with scheduled jobs...'); const proxyProviderConfig: HandlerConfigWithSchedule = { name: 'proxy', @@ -84,5 +84,5 @@ export function initializeProxyProvider() { }; handlerRegistry.registerWithSchedule(proxyProviderConfig); - logger.info('Proxy provider registered successfully with scheduled jobs'); + logger.debug('Proxy provider registered successfully with scheduled jobs'); } diff --git a/apps/data-service/src/providers/qm.provider.ts b/apps/data-service/src/providers/qm.provider.ts index 140921b..fe1bd0b 100644 --- a/apps/data-service/src/providers/qm.provider.ts +++ b/apps/data-service/src/providers/qm.provider.ts @@ -6,16 +6,16 @@ const logger = getLogger('qm-provider'); // Initialize and register the IB provider export function initializeQMProvider() { - logger.info('Registering IB provider with scheduled jobs...'); + logger.debug('Registering IB provider with scheduled jobs...'); const qmProviderConfig: HandlerConfigWithSchedule = { name: 'qm', operations: { 'create-sessions': async () => { - logger.info('Creating QM sessions...'); + logger.debug('Creating QM sessions...'); const { createSessions } = await import('./qm.tasks'); await createSessions(); - logger.info('QM sessions created successfully'); + logger.debug('QM sessions created successfully'); return { success: true, message: 'QM sessions created successfully' }; }, 'search-symbols': async () => { @@ -41,11 +41,11 @@ export function initializeQMProvider() { } }, 'spider-symbol-search': async (payload: SymbolSpiderJob) => { - logger.info('Processing spider symbol search job', { payload }); + logger.debug('Processing spider symbol search job', { payload }); const { spiderSymbolSearch } = await import('./qm.tasks'); const result = await spiderSymbolSearch(payload); - logger.info('Spider search job completed', { + logger.debug('Spider search job completed', { success: result.success, symbolsFound: result.symbolsFound, jobsCreated: result.jobsCreated, @@ -78,5 +78,5 @@ export function initializeQMProvider() { }; handlerRegistry.registerWithSchedule(qmProviderConfig); - logger.info('IB provider registered successfully with scheduled jobs'); + logger.debug('IB provider registered successfully with scheduled jobs'); } diff --git a/apps/data-service/src/providers/webshare.provider.ts b/apps/data-service/src/providers/webshare.provider.ts index b509b68..7deef85 100644 --- a/apps/data-service/src/providers/webshare.provider.ts +++ b/apps/data-service/src/providers/webshare.provider.ts @@ -24,14 +24,14 @@ export function getProxy(): string | null { // Initialize and register the WebShare provider export function initializeWebShareProvider() { - logger.info('Registering WebShare provider with scheduled jobs...'); + logger.debug('Registering WebShare provider with scheduled jobs...'); const webShareProviderConfig: HandlerConfigWithSchedule = { name: 'webshare', operations: { 'fetch-proxies': async _payload => { - logger.info('Fetching proxies from WebShare API'); + logger.debug('Fetching proxies from WebShare API'); try { const fetchedProxies = await fetchProxiesFromWebShare(); @@ -85,7 +85,7 @@ export function initializeWebShareProvider() { // Register the provider handlerRegistry.registerWithSchedule(webShareProviderConfig); - logger.info('WebShare provider registered successfully'); + logger.debug('WebShare provider registered successfully'); } export const webShareProvider = { diff --git a/apps/data-sync-service/src/index.ts b/apps/data-sync-service/src/index.ts index ab5bf53..0079b17 100644 --- a/apps/data-sync-service/src/index.ts +++ b/apps/data-sync-service/src/index.ts @@ -67,7 +67,7 @@ async function initializeServices() { try { // Initialize MongoDB client - logger.info('Connecting to MongoDB...'); + logger.debug('Connecting to MongoDB...'); const mongoConfig = databaseConfig.mongodb; mongoClient = await createAndConnectMongoDBClient({ uri: mongoConfig.uri, @@ -84,7 +84,7 @@ async function initializeServices() { logger.info('MongoDB connected'); // Initialize PostgreSQL client - logger.info('Connecting to PostgreSQL...'); + logger.debug('Connecting to PostgreSQL...'); const pgConfig = databaseConfig.postgres; postgresClient = await createAndConnectPostgreSQLClient({ host: pgConfig.host, @@ -102,7 +102,7 @@ async function initializeServices() { logger.info('PostgreSQL connected'); // Initialize sync managers - logger.info('Initializing sync managers...'); + logger.debug('Initializing sync managers...'); await syncManager.initialize(); await enhancedSyncManager.initialize(); logger.info('Sync managers initialized'); @@ -177,7 +177,7 @@ shutdown.onShutdown(async () => { // Start the service startServer().catch(error => { - logger.error('Failed to start data sync service', { error }); + logger.fatal('Failed to start data sync service', { error }); process.exit(1); }); diff --git a/apps/web-api/src/index.ts b/apps/web-api/src/index.ts index 1080a68..5682bc0 100644 --- a/apps/web-api/src/index.ts +++ b/apps/web-api/src/index.ts @@ -75,7 +75,7 @@ async function initializeServices() { try { // Initialize MongoDB client - logger.info('Connecting to MongoDB...'); + logger.debug('Connecting to MongoDB...'); const mongoConfig = databaseConfig.mongodb; mongoClient = await createAndConnectMongoDBClient({ uri: mongoConfig.uri, @@ -92,7 +92,7 @@ async function initializeServices() { logger.info('MongoDB connected'); // Initialize PostgreSQL client - logger.info('Connecting to PostgreSQL...'); + logger.debug('Connecting to PostgreSQL...'); const pgConfig = databaseConfig.postgres; postgresClient = await createAndConnectPostgreSQLClient({ host: pgConfig.host,