feat: dialog history (10 msg) per chat_id

bot.py

@@ -1,8 +1,9 @@
-"""ORTOS Telegram Bot — synchronous httpx polling.
+"""ORTOS Telegram Bot — synchronous httpx polling.
 Groq (primary) -> local Llama 3.2 3B (fallback) -> 'not sure'.
 """
 
 import os, re, time, logging
+from collections import deque
 from openai import OpenAI
 import httpx
 from dotenv import load_dotenv
@@ -13,6 +14,8 @@ load_dotenv()
 
 logger = logging.getLogger(__name__)
 
+chat_history: dict[int, deque] = {}
+
 GROQ_API_KEY = os.getenv('GROQ_API_KEY')
 LLAMA_MODEL_PATH = os.getenv('LLAMA_MODEL_PATH')
 
@@ -58,12 +61,22 @@ def need_operator(text: str) -> bool:
     return False
 
 
-def _build_user_message(question: str, context_items):
+def _build_user_message(question: str, context_items, history: deque | None = None):
     if not context_items:
         context = "(нет информации)"
     else:
         context = "\n\n".join(f"[{item.title}]\n{item.content}" for item in context_items)
+
+    hist_text = ""
+    if history:
+        lines = []
+        for msg in history:
+            role = "Клиент" if msg["role"] == "user" else "ORTOS"
+            lines.append(f"{role}: {msg['content']}")
+        hist_text = "История диалога:\n" + "\n".join(lines) + "\n\n"
+
     return (
+        f"{hist_text}"
         f"Вопрос клиента: {question}\n\n"
         f"Доступная информация из базы знаний ORTOS:\n{context}\n\n"
         "Дай точный ответ на вопрос клиента, используя ТОЛЬКО информацию выше. "
@@ -71,7 +84,7 @@ def _build_user_message(question: str, context_items):
     )
 
 
-def get_grok_response(question: str, context_items) -> str | None:
+def get_grok_response(question: str, context_items, history: deque | None = None) -> str | None:
     if not GROQ_API_KEY:
         return None
     try:
@@ -84,7 +97,7 @@ def get_grok_response(question: str, context_items) -> str | None:
             model="llama-3.3-70b-versatile",
             messages=[
                 {"role": "system", "content": SYSTEM_PROMPT},
-                {"role": "user", "content": _build_user_message(question, context_items)},
+                {"role": "user", "content": _build_user_message(question, context_items, history)},
             ],
             temperature=0.1,
             max_tokens=500,
@@ -95,14 +108,14 @@ def get_grok_response(question: str, context_items) -> str | None:
         return None
 
 
-def get_local_response(question: str, context_items) -> str | None:
+def get_local_response(question: str, context_items, history: deque | None = None) -> str | None:
     if _llm is None:
         return None
     try:
         response = _llm.create_chat_completion(
             messages=[
                 {"role": "system", "content": SYSTEM_PROMPT},
-                {"role": "user", "content": _build_user_message(question, context_items)},
+                {"role": "user", "content": _build_user_message(question, context_items, history)},
             ],
             temperature=0.1,
             max_tokens=500,
@@ -140,22 +153,29 @@ def start_bot(bot_token: str):
                 text_lower = text.lower()
                 chat_id = msg["chat"]["id"]
 
+                if chat_id not in chat_history:
+                    chat_history[chat_id] = deque(maxlen=10)
+
                 if text_lower in GREETINGS or any(text_lower.startswith(g) for g in GREETINGS if " " in g):
-                    msg = "Здравствуйте! Я — бот салона ортопедических стелек ORTOS. Спросите что-нибудь о наших стельках, ценах, доставке, записи на консультацию!"
+                    reply = "Здравствуйте! Я — бот салона ортопедических стелек ORTOS. Спросите что-нибудь о наших стельках, ценах, доставке, записи на консультацию!"
                     client.post(f"{api_url}/sendMessage", json={
                         "chat_id": chat_id,
-                        "text": msg,
+                        "text": reply,
                     })
-                    log_add(question=text, response=msg, mode="greeting", search_method="—", timing_ms=0)
+                    log_add(question=text, response=reply, mode="greeting", search_method="—", timing_ms=0)
+                    chat_history[chat_id].append({"role": "user", "content": text})
+                    chat_history[chat_id].append({"role": "assistant", "content": reply})
                     continue
 
                 if need_operator(text):
-                    msg = "Переход на оператор"
+                    reply = "Переход на оператор"
                     client.post(f"{api_url}/sendMessage", json={
                         "chat_id": chat_id,
-                        "text": msg,
+                        "text": reply,
                     })
-                    log_add(question=text, response=msg, mode="operator", search_method="—", timing_ms=0)
+                    log_add(question=text, response=reply, mode="operator", search_method="—", timing_ms=0)
+                    chat_history[chat_id].append({"role": "user", "content": text})
+                    chat_history[chat_id].append({"role": "assistant", "content": reply})
                     continue
 
                 t0 = time.time()
@@ -163,11 +183,11 @@ def start_bot(bot_token: str):
                 results = debug["items"]
                 t1 = time.time()
 
-                response = get_grok_response(text, results)
+                response = get_grok_response(text, results, chat_history[chat_id])
                 mode = "groq"
                 llm_model = "llama-3.3-70b-versatile (Groq)"
                 if response is None:
-                    response = get_local_response(text, results)
+                    response = get_local_response(text, results, chat_history[chat_id])
                     mode = "local"
                     llm_model = "Llama 3.2 3B (local)"
                 if response is None:
@@ -176,6 +196,9 @@ def start_bot(bot_token: str):
                     llm_model = ""
                 t2 = time.time()
 
+                chat_history[chat_id].append({"role": "user", "content": text})
+                chat_history[chat_id].append({"role": "assistant", "content": response})
+
                 client.post(f"{api_url}/sendMessage", json={
                     "chat_id": chat_id,
                     "text": response,