From 290b18545e15a5dff349a7f01079309f77fa7c3a Mon Sep 17 00:00:00 2001
From: whekin <stanislavkalishin@gmail.com>
Date: Sat, 14 Mar 2026 15:23:12 +0400
Subject: [PATCH] chore(bot): clean up topic processor log levels and add start
 log

---
 apps/bot/src/topic-processor.ts | 26 ++++++++++++++++++++------
 1 file changed, 20 insertions(+), 6 deletions(-)

diff --git a/apps/bot/src/topic-processor.ts b/apps/bot/src/topic-processor.ts
index 8662669..016c766 100644
--- a/apps/bot/src/topic-processor.ts
+++ b/apps/bot/src/topic-processor.ts
@@ -246,13 +246,27 @@ export function createTopicProcessor(
   apiKey: string | undefined,
   model: string,
   timeoutMs: number,
-  logger?: { error: (obj: unknown, msg?: string) => void }
+  logger?: {
+    error: (obj: unknown, msg?: string) => void
+    info: (obj: unknown, msg?: string) => void
+    warn: (obj: unknown, msg?: string) => void
+  }
 ): TopicProcessor | undefined {
   if (!apiKey) {
     return undefined
   }
 
   return async (input) => {
+    logger?.info(
+      {
+        event: 'topic_processor.start',
+        topicRole: input.topicRole,
+        messageText: input.messageText,
+        explicitMention: input.isExplicitMention
+      },
+      'Topic processor starting'
+    )
+
     const abortController = new AbortController()
     const timeout = setTimeout(() => abortController.abort(), timeoutMs)
 
@@ -434,7 +448,7 @@ If user dismisses ("не, забей", "cancel"), use dismiss_workflow.`
 
       switch (route) {
         case 'silent':
-          logger?.error(
+          logger?.info(
             { event: 'topic_processor.silent', reason },
             'Topic processor decided silent'
           )
@@ -446,7 +460,7 @@ If user dismisses ("не, забей", "cancel"), use dismiss_workflow.`
               ? parsed.replyText.trim()
               : null
           if (!replyText) {
-            logger?.error(
+            logger?.info(
               { event: 'topic_processor.empty_chat_reply', reason },
               'Topic processor returned empty chat reply'
             )
@@ -464,7 +478,7 @@ If user dismisses ("не, забей", "cancel"), use dismiss_workflow.`
               : null
 
           if (!amountMinor || !currency || !itemDescription) {
-            logger?.error(
+            logger?.warn(
               {
                 event: 'topic_processor.missing_purchase_fields',
                 amountMinor: parsed.amountMinor,
@@ -518,7 +532,7 @@ If user dismisses ("не, забей", "cancel"), use dismiss_workflow.`
           const kind = parsed.kind === 'rent' || parsed.kind === 'utilities' ? parsed.kind : null
 
           if (!amountMinor || !currency || !kind) {
-            logger?.error(
+            logger?.warn(
               {
                 event: 'topic_processor.missing_payment_fields',
                 amountMinor: parsed.amountMinor,
@@ -556,7 +570,7 @@ If user dismisses ("не, забей", "cancel"), use dismiss_workflow.`
         }
 
         default:
-          logger?.error(
+          logger?.warn(
             { event: 'topic_processor.unknown_route', route: parsed.route },
             'Topic processor returned unknown route'
           )