From 8ce489a464927bd81f1c7dbcd32f98aecd56233b Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=D0=92=D0=B8=D0=BA=D1=82=D0=BE=D1=80?=
 <78488229+viktor138irk@users.noreply.github.com>
Date: Fri, 8 May 2026 20:12:41 +0900
Subject: [PATCH] =?UTF-8?q?=D0=94=D0=BE=D0=B1=D0=B0=D0=B2=D0=BB=D0=B5?=
 =?UTF-8?q?=D0=BD=20callback=20=D0=B4=D0=BB=D1=8F=20=D0=B4=D0=BE=D1=81?=
 =?UTF-8?q?=D1=82=D0=B0=D0=B2=D0=BA=D0=B8=20=D0=BE=D1=82=D0=B2=D0=B5=D1=82?=
 =?UTF-8?q?=D0=BE=D0=B2=20=D0=BE=D0=BF=D0=B5=D1=80=D0=B0=D1=82=D0=BE=D1=80?=
 =?UTF-8?q?=D0=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 backend/src/telegram.js | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/backend/src/telegram.js b/backend/src/telegram.js
index 2832d35..92ff3e4 100644
--- a/backend/src/telegram.js
+++ b/backend/src/telegram.js
@@ -10,6 +10,7 @@ import {
 } from './db.js';
 
 let bot = null;
+let operatorMessageNotifier = null;
 let botStatus = {
   enabled: false,
   running: false,
@@ -47,6 +48,10 @@ function buildTelegramOptions(settings) {
   };
 }
 
+export function setOperatorMessageNotifier(callback) {
+  operatorMessageNotifier = callback;
+}
+
 export function getTelegramBridgeStatus() {
   return {
     ...botStatus,
@@ -146,7 +151,7 @@ export async function startTelegramBridge({ logger } = {}) {
         return;
       }
 
-      createOperatorMessage({
+      const message = createOperatorMessage({
         conversationId,
         siteId: conversation.site_id,
         operatorId: operator.id,
@@ -154,6 +159,10 @@ export async function startTelegramBridge({ logger } = {}) {
         telegramMessageId: String(ctx.message.message_id)
       });
 
+      if (operatorMessageNotifier) {
+        operatorMessageNotifier({ conversation, message, operator });
+      }
+
       await ctx.reply(`Answer saved for conversation ${conversationId}.`);
     });