From b1461292aeced43d054bfa0965202679f7ae2678 Mon Sep 17 00:00:00 2001
From: Gros Frumos <grosfrumos@macmini.local>
Date: Tue, 17 Mar 2026 18:35:47 +0200
Subject: [PATCH] =?UTF-8?q?kin:=20KIN-OBS-030=20=D0=94=D0=BE=D0=B1=D0=B0?=
 =?UTF-8?q?=D0=B2=D0=B8=D1=82=D1=8C=20=D0=B8=D0=BD=D1=81=D1=82=D1=80=D1=83?=
 =?UTF-8?q?=D0=BC=D0=B5=D0=BD=D1=82=D0=B0=D1=86=D0=B8=D1=8E=20PM-=D1=88?=
 =?UTF-8?q?=D0=B0=D0=B3=D0=B0=20=D0=B2=20pipeline=5Flog?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 tests/test_api.py | 29 +++++++++++++++++++++++++++++
 1 file changed, 29 insertions(+)

diff --git a/tests/test_api.py b/tests/test_api.py
index 7e11514..51ff305 100644
--- a/tests/test_api.py
+++ b/tests/test_api.py
@@ -2310,3 +2310,32 @@ def test_get_pipeline_logs_not_found(client):
     r = client.get("/api/pipelines/9999/logs")
     assert r.status_code == 200
     assert r.json() == []
+
+
+def test_get_pipeline_logs_since_id_returns_pm_entries(client):
+    """KIN-OBS-025: poll since_id возвращает PM-записи с role='pm' в extra_json."""
+    import json as _json
+    from core.db import init_db
+    from core import models
+    pid = _seed_pipeline(api_module.DB_PATH, task_id="PM-001")
+    conn = init_db(api_module.DB_PATH)
+    # Вставляем не-PM запись, которая будет отфильтрована
+    e0 = models.write_log(conn, pid, "Pipeline start")
+    # Вставляем PM-записи с ретроспективными ts
+    models.write_log(conn, pid, "PM start: task planning",
+                     ts="2026-03-17T10:00:00", extra={"role": "pm"})
+    models.write_log(conn, pid, "PM done: 2 steps planned, success=True, cost=$0.0100, tokens=1000",
+                     ts="2026-03-17T10:00:05",
+                     extra={"role": "pm", "steps_count": 2, "tokens_used": 1000, "cost_usd": 0.01})
+    conn.close()
+
+    r = client.get(f"/api/pipelines/{pid}/logs?since_id={e0['id']}")
+    assert r.status_code == 200
+    logs = r.json()
+    assert len(logs) == 2
+    pm_roles = [log["extra_json"]["role"] for log in logs if log.get("extra_json")]
+    assert all(role == "pm" for role in pm_roles)
+    # Убеждаемся что PM done содержит метрики
+    done_log = next(log for log in logs if "PM done" in log["message"])
+    assert done_log["extra_json"]["steps_count"] == 2
+    assert done_log["extra_json"]["tokens_used"] == 1000