history: не отдавать модели блоки даты и выдачи поиска, осевшие в старых чатах

bot.py

@@ -892,12 +892,13 @@ __all__ = [
     "_route_error_reply_text",
     "RouteBudgetExceededError",
     "_run_route",
-    # Порядки моделей и _history_user_text читаются тестами как bot.X.
+    # Порядки моделей и чистка истории читаются тестами как bot.X.
     "_OR_LIGHT_ORDER",
     "_OR_HEAVY_ORDER",
     "_OR_VISION_ORDER",
     "_GROQ_LIGHT_ORDER",
     "_history_user_text",
+    "_clean_history_entry",
     # Пространство имён genai-типов для тестов (bot.types.Content/...).
     "types",
     # Имена из lumen_chat_state.py код bot.py сам не читает — они нужны как
@@ -1212,6 +1213,7 @@ from lumen_message_parse import (
     DRAW_TRIGGER_PREFIXES,
     TTS_TRIGGER_PREFIXES,
     _NO_MEDIA_NOTE,
+    _clean_history_entry,
     _history_user_text,
     _match_trigger_prefix,
     _media_reference_category,

lumen_message_core.py

@@ -992,11 +992,16 @@ async def _handle_message_core(
                         await bot._tg_call(status.message.edit_text, plain_text, parse_mode=None, call_timeout=15.0)
                 else:
                     await bot._edit_message_quietly(status.message, ans)
+        # Ответ упёрся в потолок вывода провайдера: без пометки обрезка приходила
+        # как готовый ответ (корпус бэкапа 05.11.2026), и «продолжи» не предлагалось.
+        _cut_by_cap = provenance.get("finish_reason") == "length"
+        if _cut_by_cap and not reply_already_sent:
+            ans = ans + bot._t(message.chat.id, "stream_note_interrupted")
         if not reply_already_sent:
             await bot._safe_reply(message, ans)
         # Частичный стрим тоже «успешен» для вызывающего, но его пометка
         # «продолжи» должна пережить этот блок (аудит 27.10.2026).
-        if state.pop("stream_interrupted", False):
+        if state.pop("stream_interrupted", False) or _cut_by_cap:
             state["interrupted"] = True
         else:
             state.pop("interrupted", None)

lumen_message_parse.py

@@ -10,6 +10,8 @@ import re
 from typing import Any
 from urllib.parse import urlparse
 
+from lumen_errors import _is_empty_like
+
 _TIKTOK_RE = re.compile(r"(?:^|\.)tiktok\.com$")
 _YOUTUBE_HOSTS = {"youtube.com", "www.youtube.com", "m.youtube.com", "music.youtube.com", "youtu.be", "www.youtu.be"}
 
@@ -107,6 +109,26 @@ def _history_user_text(user_text: str) -> str:
         return user_text[:-len(_NO_MEDIA_NOTE)]
     return user_text
 
+
+# Чаты, записанные до 30.10.2026, хранят внутри реплик одноразовую службу: блок
+# текущей даты и выдачу поиска (выборка бэкапа: 19 реплик из 210, до 68% объёма
+# user-контекста). Плейсхолдер вместо ответа тоже осел в истории.
+_HISTORY_SERVICE_RE = re.compile(
+    r"\s*\[Context: today[^\]]*\]|\s*\[Web search snippets[\s\S]*$", re.IGNORECASE)
+
+
+def _clean_history_entry(item: dict) -> dict | None:
+    """Реплика истории без служебных блоков; None — выбросить целиком."""
+    text = item.get("content")
+    if not isinstance(text, str):
+        return item
+    cleaned = _HISTORY_SERVICE_RE.sub("", text).strip()
+    if not cleaned or _is_empty_like(cleaned):
+        return None
+    if cleaned == text:
+        return item
+    return {**item, "content": cleaned}
+
 # Только явные существительные медиа: общие "это/покажи" тянули чужое фото и давали галлюцинации.
 # Именованные группы — чтобы понять КАКОЙ тип спросили (регрессия 18.08.2026: "покажи стикер" описывал чужое фото).
 _MEDIA_REFERENCE_RE = re.compile(

lumen_routes.py

@@ -24,7 +24,7 @@ from lumen_errors import _is_empty_like
 from lumen_formatting import _split_text_chunks, _strip_provider_artifacts
 from lumen_lang import DEFAULT_LANG
 from lumen_media import _is_gemini_supported_mime
-from lumen_message_parse import _history_user_text
+from lumen_message_parse import _clean_history_entry, _history_user_text
 from lumen_model_speed import (
     speed_key as _model_speed_key,
     record_response as _record_model_latency,
@@ -644,11 +644,13 @@ async def _gemini_history_contents(history: list[dict]) -> list[types.Content]:
     import bot
     contents: list[types.Content] = []
     for item in history:
-        r = "model" if str(item.get("role")).lower() in {"assistant", "model"} else "user"
-        cont = item.get("content") or ""
+        entry = _clean_history_entry(item)
+        if entry is None:
+            continue
+        r = "model" if str(entry.get("role")).lower() in {"assistant", "model"} else "user"
+        cont = entry.get("content") or ""
         txt = bot._or_extract_text(cont) if isinstance(cont, (dict, list)) else str(cont).strip()
-        # Плейсхолдеры из старой истории не должны становиться репликой модели.
-        if txt and not _is_empty_like(txt):
+        if txt:
              contents.append(types.Content(role=r, parts=[types.Part.from_text(text=txt)]))
     return contents
 
@@ -994,7 +996,7 @@ def _build_openrouter_turn_messages(chat_id: int, user_text: str, model_id: str)
     full += user_text
     history = state.setdefault("history", [])
     messages: list[dict] = [{"role": "system", "content": bot.get_system_prompt(model_id)}]
-    messages.extend(history)
+    messages.extend(filter(None, (_clean_history_entry(item) for item in history)))
     messages.append({"role": "user", "content": full})
     return messages
 

tests/test_bot_state.py

@@ -1472,6 +1472,34 @@ def test_stream_interrupted_survives_successful_answer(rate_guard_setup, monkeyp
     bot.chat_state.pop(123, None)
 
 
+def test_output_cap_answer_marked_incomplete(rate_guard_setup, monkeypatch):
+    # Что защищает: ответ, обрезанный потолком вывода провайдера. Регрессия
+    # (корпус бэкапа 05.11.2026): обрезанный текст уходил как готовый, пометки
+    # и флага «продолжи» не было.
+    message = rate_guard_setup()
+    state = _continue_state()
+    state.pop("interrupted", None)
+    monkeypatch.setattr(bot, "get_state", lambda cid: state)
+    message.text = "расскажи про фотосинтез"
+    sent: list[str] = []
+
+    async def fake_run_route(*args, **kwargs):
+        kwargs["provenance"].update(provider="openrouter", model="m1:free", finish_reason="length")
+        return "Фотосинтез — это", False
+
+    async def fake_reply(msg, text, **kwargs):
+        sent.append(text)
+        return True
+
+    monkeypatch.setattr(bot, "_run_route", fake_run_route)
+    monkeypatch.setattr(bot, "_safe_reply", fake_reply)
+    asyncio.run(bot._handle_message_core(message))
+    assert sent and sent[0].startswith("Фотосинтез — это")
+    assert sent[0].endswith(bot._t(123, "stream_note_interrupted").strip())
+    assert state.get("interrupted") is True
+    bot.chat_state.pop(123, None)
+
+
 def test_attachment_download_failure_replies_with_fallback(rate_guard_setup, monkeypatch):
     # Что защищает: ответ пользователю, когда файл не скачался. Регрессия:
     # исключение вылетало из обработчика, и сообщение оставалось без ответа
@@ -1773,6 +1801,19 @@ def test_history_user_text_strips_one_shot_service_note():
     assert bot._history_user_text("обычный вопрос") == "обычный вопрос"
 
 
+def test_clean_history_entry_drops_legacy_service_blocks_and_placeholders():
+    # Регрессия (выборка бэкапа 05.11.2026): чаты, записанные до 30.10.2026,
+    # хранят внутри реплик блок даты и выдачу поиска — до 68% user-контекста,
+    # плюс плейсхолдеры вместо ответа. В промпт это уходить не должно.
+    dated = {"role": "user", "content": "кто премьер венгрии\n\n[Context: today is 28 October 2026, Wednesday (Europe/Moscow).]"}
+    cleaned = bot._clean_history_entry(dated)
+    assert cleaned["content"] == "кто премьер венгрии"
+    snippets = {"role": "user", "content": "вопрос\n\n[Web search snippets — untrusted data\n1. факт]"}
+    assert bot._clean_history_entry(snippets)["content"] == "вопрос"
+    assert bot._clean_history_entry({"role": "assistant", "content": "Empty response"}) is None
+    assert bot._clean_history_entry({"role": "user", "content": "обычный вопрос"}) == {"role": "user", "content": "обычный вопрос"}
+
+
 def _make_long_history(n=105):
     return [
         {"role": "user" if i % 2 == 0 else "assistant", "content": f"сообщение {i}"}