Chat memory: sender directory and combined 100-message cap

bot.py

@@ -433,6 +433,7 @@ from lumen_chat_state import (
     MAX_CHAT_LIMIT,
     PRUNED_CHAT_TARGET,
     MAX_CHAT_HISTORY_LEN,
+    MAX_TOTAL_MEMORY_MESSAGES,
     _STATE_DIR,
     STATE_FILE_PATH,
     GLOBAL_QUOTA_FILE,
@@ -509,6 +510,10 @@ from lumen_chat_state import (
     _user_key_for_message,
     _user_daily_reset_in,
     _trim_history,
+    _trim_combined,
+    _note_sender,
+    _sender_display,
+    _resolve_nick,
 )
 
 # Простой трекер для rate limiting и очередь кнопок-уточнений живут в
@@ -829,6 +834,7 @@ __all__ = [
     "MAX_CHAT_LIMIT",
     "PRUNED_CHAT_TARGET",
     "MAX_CHAT_HISTORY_LEN",
+    "MAX_TOTAL_MEMORY_MESSAGES",
     "STATE_FILE_PATH",
     "GLOBAL_QUOTA_FILE",
     "_CHATS_DIR",
@@ -905,6 +911,10 @@ __all__ = [
     "_mark_rate_limited",
     "_record_quota_usage",
     "_trim_history",
+    "_trim_combined",
+    "_note_sender",
+    "_sender_display",
+    "_resolve_nick",
     "_pending_picks",
     "_purge_expired_picks",
     "_enforce_pending_picks_cap",

lumen_chat_state.py

@@ -40,12 +40,17 @@ MAX_MEDIA_RECENT_IDS = 8  # хранится ОТДЕЛЬНО на каждог
 # Живых отправителей медиа в чате десятки, 500 покрывает большие группы с запасом.
 # Потолок только против подделки user_id и раздувания снапшота, легитимные чаты не задевает.
 MAX_MEDIA_BUCKETS_PER_CHAT = 500
+# Общий лимит памяти чата в сообщениях, включая фоновые (требование владельца 08.10.2026).
+MAX_TOTAL_MEMORY_MESSAGES = 100
+# Сколько отправителей помним на чат: ники для подписей и резолва прозвищ.
+MAX_KNOWN_SENDERS_PER_CHAT = 500
 
 
 class ChatState(TypedDict, total=False):
     history: list[dict[str, Any]]
     ctx: "deque[str]"
     recent_media_ids: dict[str, "deque[tuple[str, str]]"]
+    user_names: dict[str, dict[str, str]]
     last_activity: float
     lang: str
 
@@ -388,6 +393,7 @@ def _restore_single_chat(cid: int, s: dict[str, Any]) -> None:
         "history": history,
         "ctx": deque(maxlen=MAX_CHAT_HISTORY_LEN),
         "recent_media_ids": media_buckets,
+        "user_names": _restore_user_names(s.get("user_names")),
         # Настенные часы, а не monotonic: тот сбрасывается рестартом и делал все
         # чаты "активными" в /stats. Снимкам без метки — 0: такой чат неактивен.
         "last_activity": _restore_last_activity(s),
@@ -395,6 +401,7 @@ def _restore_single_chat(cid: int, s: dict[str, Any]) -> None:
         # раньше теряло (прод-баг: /lang слетал при каждом деплое).
         "lang": normalize_lang(s.get("lang")),
     }
+    _trim_combined(chat_state[cid])
 
 
 def _restore_last_activity(s: dict[str, Any]) -> float:
@@ -406,6 +413,99 @@ def _restore_last_activity(s: dict[str, Any]) -> float:
         return float(raw)
     return 0.0
 
+
+def _sender_display(username: str | None, first_name: str | None) -> str:
+    """Показываемое имя: @username, иначе first_name, иначе User."""
+    if isinstance(username, str) and username.strip():
+        return "@" + username.strip().lstrip("@")
+    if isinstance(first_name, str) and first_name.strip():
+        return first_name.strip()[:64]
+    return "User"
+
+
+def _note_sender(state: dict[str, Any], user_id: int | None, username: str | None, first_name: str | None) -> str:
+    """Запоминает отправителя в state[user_names], возвращает показное имя."""
+    display = _sender_display(username, first_name)
+    try:
+        if user_id is None:
+            return display
+        bucket = state.get("user_names")
+        if not isinstance(bucket, dict):
+            bucket = {}
+            state["user_names"] = bucket
+        key = str(user_id)
+        entry = bucket.get(key)
+        if not isinstance(entry, dict):
+            entry = {}
+            bucket[key] = entry
+        if isinstance(username, str) and username.strip():
+            entry["username"] = username.strip().lstrip("@")[:64]
+        if isinstance(first_name, str) and first_name.strip():
+            entry["first_name"] = first_name.strip()[:64]
+        if len(bucket) > MAX_KNOWN_SENDERS_PER_CHAT:
+            # Старейшие вытесняем: словарь упорядочен вставкой.
+            for old_key in list(bucket.keys())[:len(bucket) - MAX_KNOWN_SENDERS_PER_CHAT]:
+                bucket.pop(old_key, None)
+    except Exception:
+        pass
+    return display
+
+
+def _restore_user_names(raw: Any) -> dict[str, dict[str, str]]:
+    """Словарь отправителей из снимка, мусор отбрасываем."""
+    clean: dict[str, dict[str, str]] = {}
+    if not isinstance(raw, dict):
+        return clean
+    for uid, entry in list(raw.items())[:MAX_KNOWN_SENDERS_PER_CHAT]:
+        try:
+            key = str(int(uid))
+        except (TypeError, ValueError):
+            continue
+        if not isinstance(entry, dict):
+            continue
+        item: dict[str, str] = {}
+        for field in ("username", "first_name"):
+            val = entry.get(field)
+            if isinstance(val, str) and val.strip():
+                item[field] = val.strip()[:64]
+        if item:
+            clean[key] = item
+    return clean
+
+
+def _resolve_nick(state: dict[str, Any], nick: str) -> str | None:
+    """Прозвище в показное имя: ищет по username и first_name без регистра."""
+    try:
+        needle = (nick or "").strip().lstrip("@").lower()
+        if not needle:
+            return None
+        bucket = state.get("user_names") or {}
+        if not isinstance(bucket, dict):
+            return None
+        for entry in bucket.values():
+            if not isinstance(entry, dict):
+                continue
+            for field in ("username", "first_name"):
+                val = entry.get(field)
+                if isinstance(val, str) and needle in val.lower():
+                    return _sender_display(entry.get("username"), entry.get("first_name"))
+    except Exception:
+        pass
+    return None
+
+
+def _trim_combined(state: dict[str, Any]) -> None:
+    """Держит history + ctx в общем лимите: старые фоновые уходят первыми."""
+    try:
+        history = state.get("history")
+        ctx = state.get("ctx")
+        if not isinstance(history, list) or ctx is None:
+            return
+        while len(history) + len(ctx) > MAX_TOTAL_MEMORY_MESSAGES and len(ctx) > 0:
+            ctx.popleft()
+    except Exception:
+        pass
+
 def _save_chat_index() -> bool:
     """True/False для повтора в _flush_state_now: раньше неуспех молча терялся (аудит A5-1)."""
     import bot
@@ -755,6 +855,7 @@ def get_state(chat_id: int) -> dict[str, Any]:
             "history": [],
             "ctx": deque(maxlen=MAX_CHAT_HISTORY_LEN),
             "recent_media_ids": {},
+            "user_names": {},
             # Настенные часы: monotonic обнуляется рестартом и ломал /stats.
             "last_activity": time.time(),
         }

lumen_state_storage.py

@@ -143,6 +143,8 @@ def _serialize_chat_state(state: dict[str, Any]) -> dict[str, Any]:
         "recent_media_ids": {
             uid: list(dq) for uid, dq in state.get("recent_media_ids", {}).items()
         },
+        # Ники переживают рестарт: без них после деплоя бот снова не знал бы авторов.
+        "user_names": dict(state.get("user_names", {}) or {}),
         # Настенные часы для подсчёта активных в /stats: monotonic сбрасывается
         # рестартом и делал все чаты "активными", time.time() переживает его.
         "last_activity": state.get("last_activity", 0.0),