From fed840f56e2d29e5c54695967d6116d212aeaa4f Mon Sep 17 00:00:00 2001 From: Kristina Date: Mon, 5 May 2025 12:54:28 +0400 Subject: [PATCH] Add more logs for tg bot (#8829) Signed-off-by: Kristina Fefelova --- services/telegram-bot/pod-telegram-bot/src/start.ts | 9 ++++++++- services/telegram-bot/pod-telegram-bot/src/worker.ts | 2 ++ 2 files changed, 10 insertions(+), 1 deletion(-) diff --git a/services/telegram-bot/pod-telegram-bot/src/start.ts b/services/telegram-bot/pod-telegram-bot/src/start.ts index 5759538ca9..570ec33e45 100644 --- a/services/telegram-bot/pod-telegram-bot/src/start.ts +++ b/services/telegram-bot/pod-telegram-bot/src/start.ts @@ -55,6 +55,7 @@ Analytics.setTag('application', 'telegram-bot-service') export async function requestReconnect (bot: Telegraf, limiter: Limiter): Promise { if (config.MongoDB === '' || config.MongoURL === '') { + ctx.info('MongoDB is not configured, skipping reconnect') return } @@ -84,11 +85,15 @@ export const start = async (): Promise => { setMetadata(serverClient.metadata.UserAgent, config.ServiceId) registerLoaders() + ctx.info('Creating worker...') const worker = await PlatformWorker.create(ctx) + ctx.info('Set up bot...') const bot = await setUpBot(worker) - + ctx.info('Creating server...') const app = createServer(bot, worker, ctx) + ctx.info('Creating queue...') const queue = getPlatformQueue('telegramBotService', config.QueueRegion) + ctx.info('queue', { clientId: queue.getClientId() }) if (config.Domain === '') { ctx.info('Starting bot with polling') @@ -110,7 +115,9 @@ export const start = async (): Promise => { res.status(200).send() }) + ctx.info('Requesting reconnect...') await requestReconnect(bot, worker.limiter) + ctx.info('Starting server...') const server = listen(app, ctx, config.Port) const consumer = queue.createConsumer( diff --git a/services/telegram-bot/pod-telegram-bot/src/worker.ts b/services/telegram-bot/pod-telegram-bot/src/worker.ts index 33691b48c3..d9b869ebd9 100644 --- a/services/telegram-bot/pod-telegram-bot/src/worker.ts +++ b/services/telegram-bot/pod-telegram-bot/src/worker.ts @@ -87,7 +87,9 @@ export class PlatformWorker { const storageConfig: StorageConfiguration = storageConfigFromEnv() const storage = buildStorageFromConfig(storageConfig) + ctx.info('Connecting to database...', { dbUrl: config.DbUrl }) const db = await getDb() + ctx.info('Database connected') const limiter = new Limiter() return new PlatformWorker(ctx, storage, limiter, db)