Update routes.py

src/api/routes.py

@@ -49,7 +49,22 @@ async def chat_completions(request: Request):
                         # stop early if requested (e.g. client disconnected)
                         if stop_event.is_set():
                             break
+                        chunk_count += 1
+                        now = time.time()
                         loop.call_soon_threadsafe(q.put_nowait, chunk)
+                        loop.call_soon_threadsafe(
+                            q.put_nowait,
+                            {"__chunk": chunk, "ts": now, "count": chunk_count},
+                        )
+                    # финальный лог
+                    loop.call_soon_threadsafe(
+                        q.put_nowait,
+                        {
+                            "__done": True,
+                            "duration": time.time() - start,
+                            "chunks": chunk_count,
+                        },
+                    )
                 except Exception as e:
                     # Pass exception to the async side so we can surface an error or terminate cleanly
                     loop.call_soon_threadsafe(q.put_nowait, {"__error": str(e)})