Fix Gemini streaming await and correct SDK contract mocks

lumen_streaming.py

@@ -94,14 +94,11 @@ def _stream_wait(bot: Any, deadline: float | None) -> float:
 async def _gemini_stream_pieces(model_id: str, call_contents: list, gconfig, *, deadline: float | None = None):
     """Куски от Gemini (тонкая обёртка над generate_content_stream).
 
-    Рукопожатия как отдельного шага НЕТ намеренно: generate_content_stream
-    возвращает генератор, не делая сети (проверено по исходнику google-genai
-    2.24.0: тело — `return stream_generator()`), поэтому wait_for вокруг вызова
-    ограничивал только мгновенное создание объекта и никогда не срабатывал —
-    витрина таймаута без защиты (враждебное ревью 27.09.2026). Реальную сетевую
-    жду ловлю ниже: первый кусок идёт через __anext__ под тем же _stream_wait."""
+    В google-genai 2.27.0 это async def: вызов надо ждать (пример из SDK:
+    `async for chunk in await client.aio.models.generate_content_stream(...)`).
+    Реальную сетевую жду ловлю ниже: первый кусок идёт через __anext__ под тем же _stream_wait."""
     import bot
-    stream = bot.client.aio.models.generate_content_stream(model=model_id, contents=call_contents, config=gconfig)
+    stream = await bot.client.aio.models.generate_content_stream(model=model_id, contents=call_contents, config=gconfig)
     stream_iter = stream.__aiter__()
     try:
         while True:

tests/test_bot_streaming.py

@@ -35,15 +35,10 @@ def test_stream_wait_caps_chunk_timeout_by_remaining_budget():
 
 
 def _fake_gemini_stream(pieces=None, *, raises=None, hang_sec=0.0):
-    """Мок generate_content_stream по НАСТОЯЩЕМУ контракту google-genai 2.24.0:
-    обычная функция, возвращающая асинхронный генератор (тело SDK — `return
-    stream_generator()`), а НЕ корутина.
-
-    Раньше фейки здесь были `async def ... return gen()`, из-за чего тесты
-    подпирали фиктивное рукопожатие wait_for вокруг вызова: реальный SDK сети
-    в корутине не делает, значит тот таймаут не срабатывал никогда
-    (враждебное ревью 27.09.2026)."""
-    def _stream(*, model, contents, config=None):
+    """Мок generate_content_stream по контракту google-genai 2.27.0:
+    async def, вызов надо ждать (пример из SDK:
+    `async for chunk in await client.aio.models.generate_content_stream(...)`)."""
+    async def _stream(*, model, contents, config=None):
         async def gen():
             if hang_sec:
                 await asyncio.sleep(hang_sec)
@@ -76,19 +71,22 @@ def test_gemini_stream_timeout_covers_a_hanging_first_chunk():
         bot.STREAM_CHUNK_TIMEOUT_SEC = original_cap
 
 
-def test_gemini_stream_call_is_not_awaited():
-    # Контракт SDK: generate_content_stream — обычная функция. Если бы обёртка снова
-    # стала await-ить её, тест падал бы с TypeError, а не проходил вхолостую.
+def test_gemini_stream_call_is_awaited():
+    # Контракт SDK 2.27.0: generate_content_stream это async def, обёртка обязана
+    # ждать вызов. Синхронный мок (старое поведение) даёт TypeError при await.
+    import inspect
+    from google.genai.models import AsyncModels
+    assert inspect.iscoroutinefunction(AsyncModels.generate_content_stream)
     calls = []
 
-    def sync_only(*, model, contents, config=None):
+    async def async_only(*, model, contents, config=None):
         calls.append(model)
         async def gen():
             yield SimpleNamespace(text="ok")
         return gen()
 
     fake_client = MagicMock()
-    fake_client.aio.models.generate_content_stream = sync_only
+    fake_client.aio.models.generate_content_stream = async_only
     original_client = bot.client
     bot.client = fake_client
     try: