Show typing before media downloads and register localized command menus in parallel

bot.py

@@ -1611,17 +1611,28 @@ async def _webhook_startup() -> None:
             }
             for code, cmds in localized_commands
         ]
-        commands_ok = False
-        for cmd_payload in cmd_payloads:
-            try:
+        # 24 локали последовательно — это 5-12 с холодного старта через прокси.
+        # Регистрируем с ограниченной параллельностью: меню не влияет на ответы,
+        # но не хочется упираться в flood-контроль Telegram.
+        _commands_sem = asyncio.Semaphore(4)
+
+        async def _register_commands(cmd_payload: dict) -> None:
+            async with _commands_sem:
                 await asyncio.wait_for(
                     telegram_api_call("setMyCommands", cmd_payload, request_timeout=15.0),
-                    timeout=18.0
+                    timeout=18.0,
                 )
+
+        results = await asyncio.gather(
+            *(_register_commands(payload) for payload in cmd_payloads),
+            return_exceptions=True,
+        )
+        commands_ok = False
+        for cmd_payload, result in zip(cmd_payloads, results):
+            if isinstance(result, BaseException):
+                log.warning("[webhook] setMyCommands failed (%s): %s", cmd_payload.get("language_code", "default"), result)
+            else:
                 commands_ok = True
-            except Exception as exc:
-                log.warning("[webhook] setMyCommands failed (%s): %s", cmd_payload.get("language_code", "default"), exc)
-        # for-else без break врал бы об успехе при провале всех языков.
         if commands_ok:
             log.info("[webhook] Bot commands set successfully.")
         else:

lumen_message_core.py

@@ -658,6 +658,16 @@ async def _handle_message_core(
             await bot._send_pick_question(message, pick_scenario, clean_prompt)
             return
 
+    # «Печатает…» показываем сразу, ДО скачивания вложения и транскрибации:
+    # иначе видео на 20 МБ несколько секунд выглядело как молчание (аудит 29.10.2026).
+    # Не ждём ответа: круг к Telegram не должен задерживать модель.
+    if not is_guest:
+        async def _send_typing() -> None:
+            with contextlib.suppress(Exception):
+                await bot.bot.send_chat_action(chat_id=message.chat.id, action="typing")
+
+        bot._track_inflight_task(asyncio.create_task(_send_typing()))
+
     media_too_big_mb = 0
     try:
         med_name, media_tuple = await bot._resolve_incoming_media(
@@ -718,16 +728,6 @@ async def _handle_message_core(
               await bot._tg_call(message.reply, bot._t(message.chat.id, "status_listening"))
          return
 
-    # Отправка typing экшена (bot.bot — инстанс aiogram Bot, не модуль).
-    # Не ждём ответа: это отдельный круг к Telegram через прокси, и вызов
-    # модели стартовал бы на 0.1-0.3с позже. Индикатор косметический.
-    if not is_guest:
-        async def _send_typing() -> None:
-            with contextlib.suppress(Exception):
-                await bot.bot.send_chat_action(chat_id=message.chat.id, action="typing")
-
-        bot._track_inflight_task(asyncio.create_task(_send_typing()))
-
     media_mime = media_tuple[1] if media_tuple else None
     # Смешанный альбом (фото + видео-слайды): достаточно одного видео — весь набор едет
     # в Gemini-ветку, иначе видео-слайды молча терялись (ревью ветки: смотрели только media[0]).

tests/test_bot_state.py

@@ -1680,6 +1680,26 @@ def test_message_core_sends_typing_indicator(rate_guard_setup, monkeypatch):
     fake_bot.send_chat_action.assert_awaited_once_with(chat_id=123, action="typing")
 
 
+def test_typing_starts_before_media_download(rate_guard_setup, monkeypatch):
+    # Аудит 29.10.2026: "печатает" уходил только после скачивания вложения —
+    # большое видео несколько секунд выглядело как молчание.
+    message = rate_guard_setup()
+    message.text = "что на фото?"
+    fake_bot = SimpleNamespace(send_chat_action=AsyncMock())
+    monkeypatch.setattr(bot, "bot", fake_bot)
+    seen = {}
+
+    async def resolve(*args, **kwargs):
+        for _ in range(3):
+            await asyncio.sleep(0)
+        seen["typing_before_download"] = fake_bot.send_chat_action.await_count
+        return "", None
+
+    monkeypatch.setattr(bot, "_resolve_incoming_media", resolve)
+    _run_core_capturing_prompt(message, monkeypatch)
+    assert seen.get("typing_before_download") == 1
+
+
 def test_message_core_does_not_wait_for_typing_before_model(rate_guard_setup, monkeypatch):
     # Что защищает: вызов модели не ждёт сетевого ответа на "печатает".
     # Регрессия: вернуть await перед send_chat_action — модель стартует на один