Media drops are honest: fetchable attachment failure replies error, entry log for media

bot.py

@@ -1169,6 +1169,14 @@ async def handle_message(message: Message) -> None:
     is_private = message.chat.type == ChatType.PRIVATE if message.chat else True
     is_guest = is_guest_message(message)
     mentioned = message_mentions_bot(message)
+    # Входящее медиа логируем всегда: молчаливый дроп таких сообщений (прод 23.09.2026 — войс
+    # в личке обработан за 0 мс без следа) иначе не диагностировать вообще.
+    _in_src = _msg_media_source(message)
+    if _in_src is not None:
+        log.info(
+            "[in] media message: chat=%s kind=%s has_text=%s",
+            chat_id, type(_in_src).__name__, bool(message.text or message.caption),
+        )
 
     # Если бот не упомянут в группе, это просто контекст — обрабатываем без локов и ожидания
     if not is_private and not is_guest and not mentioned:

lumen_message_core.py

@@ -277,6 +277,11 @@ async def _handle_message_core(message: Message, extra_media: list[tuple[bytes,
          clean_prompt = "Подробно перескажи и опиши содержание этого YouTube-видео."
 
     if not clean_prompt and not media_tuple and not youtube_url_to_analyze:
+         src = _msg_media_source(message)
+         if src is not None and type(src).__name__ != "Sticker":
+              # Вложение было, но скачать/распознать не вышло — честно говорим, а не "Слушаю" в пустоту.
+              await bot._safe_reply(message, bot._model_error_text("fallback", bot._chat_lang(message.chat.id)))
+              return
          if mentioned:
               await bot._tg_call(message.reply, bot._t(message.chat.id, "status_listening"))
          return

tests/test_bot_state.py

@@ -615,6 +615,50 @@ def test_voice_message_falls_back_to_gemini_audio_on_transcribe_failure(rate_gua
     bot.chat_state.pop(123, None)
 
 
+def test_unfetchable_attachment_gets_honest_error_not_silence(rate_guard_setup, monkeypatch):
+    # Вложение есть, а скачать не вышло — честная ошибка вместо "Слушаю" в пустоту (прод 23.09.2026).
+    message = rate_guard_setup()
+    message.text = ""
+    message.photo = [SimpleNamespace(file_id="dead", mime_type=None, file_name=None)]
+    replied = []
+
+    async def fake_resolve(message, state, clean_prompt, *, is_private):
+        return None, "", "", None
+
+    async def fake_safe_reply(message, text, **kwargs):
+        replied.append(text)
+
+    monkeypatch.setattr(bot, "_resolve_incoming_media", fake_resolve)
+    monkeypatch.setattr(bot, "_safe_reply", fake_safe_reply)
+    asyncio.run(bot._handle_message_core(message))
+    assert len(replied) == 1
+    assert "Слушаю" not in replied[0]
+    bot.chat_state.pop(123, None)
+
+
+def test_sticker_without_text_keeps_old_listening_behavior(rate_guard_setup, monkeypatch):
+    # Стикер — не ошибка скачивания: прежнее поведение без изменений.
+    message = rate_guard_setup()
+    message.text = ""
+    Sticker = type("Sticker", (), {})
+    message.sticker = Sticker()
+    called = []
+
+    async def fake_resolve(message, state, clean_prompt, *, is_private):
+        return None, "", "", None
+
+    async def fake_tg_call(method, *args, **kwargs):
+        called.append(args[0] if args else "")
+        return SimpleNamespace()
+
+    monkeypatch.setattr(bot, "_resolve_incoming_media", fake_resolve)
+    monkeypatch.setattr(bot, "_tg_call", fake_tg_call)
+    monkeypatch.setattr(bot, "message_mentions_bot", lambda message: True)
+    asyncio.run(bot._handle_message_core(message))
+    assert any("Слушаю" in str(c) for c in called)
+    bot.chat_state.pop(123, None)
+
+
 def test_ordinary_question_gets_no_file_notice(rate_guard_setup, monkeypatch):
     message = rate_guard_setup()
     message.text = "столица Венгрии?"