diff --git a/src/sdlc_hub/modules/jira/hooks.py b/src/sdlc_hub/modules/jira/hooks.py index 6fd0af1..17e2a9e 100644 --- a/src/sdlc_hub/modules/jira/hooks.py +++ b/src/sdlc_hub/modules/jira/hooks.py @@ -52,33 +52,41 @@ def check_setup(conn, cmds, files_dir) -> None: def _assign_boards(conn, cmds) -> None: - """Доска проекта задачи в params ensure_sprint (design #7): метки временного ключа — из его ensure_issue в пакете, - иначе из зеркала; 422 — задача вне проектов, разные доски, нет доски, канбан, тип ещё не известен.""" + """Доска проекта задачи в params ensure_sprint (design #7) и ensure_fields со story_points (оценка через доску, + sp-estimation-board): метки временного ключа — из его ensure_issue в пакете, иначе из зеркала; 422 — задача вне + проектов, разные доски, нет доски, канбан, тип ещё не известен.""" temp_labels = {c["params"]["temp_key"]: c["params"].get("labels") or [] for c in cmds if c["type"] == "ensure_issue"} found = jira_projects.light_list(conn) for i, c in enumerate(cmds, 1): - if c["type"] != "ensure_sprint": + points = c["type"] == "ensure_fields" and "story_points" in c["params"] + if c["type"] != "ensure_sprint" and not points: continue + goal, kanban = ("оценки", KANBAN_POINTS) if points else ("спринта", KANBAN_SPRINT) key = c["params"]["key"] labels = temp_labels[key] if key in temp_labels else (mirror.labels_of(conn, key) or []) own = [p for p in found if p["label"] in labels] if not own: - raise CommandError(f"команда {i}: {key} не входит ни в один проект — доску для спринта не определить") + raise CommandError(f"команда {i}: {key} не входит ни в один проект — доску для {goal} не определить") if len({p["board_id"] for p in own}) > 1: raise CommandError(f"команда {i}: {key} в проектах {', '.join(p['label'] for p in own)} с разными досками") p = own[0] - err = _board_error(p["label"], p["board_id"], p["board_type"]) + err = _board_error(p["label"], p["board_id"], p["board_type"], kanban) if err: raise CommandError(f"команда {i}: {err}") c["params"] = {**c["params"], "board_id": p["board_id"]} -def _board_error(label, board_id, board_type) -> str | None: - """Общие тексты 422 для ensure_sprint и команд спринта: доски нет, канбан, тип ещё не известен; None — доска годится.""" +KANBAN_SPRINT = "спринтов нет" +KANBAN_POINTS = "оценка — только на scrum-доске" + + +def _board_error(label, board_id, board_type, kanban=KANBAN_SPRINT) -> str | None: + """Общие тексты 422 для ensure_sprint, команд спринта и оценки: доски нет, канбан (хвост текста — kanban), тип ещё + не известен; None — доска годится.""" if board_id is None: return f"у проекта {label} нет доски Jira" if board_type == "kanban": - return f"у проекта {label} канбан-доска, спринтов нет" + return f"у проекта {label} канбан-доска, {kanban}" if board_type is None: return f"тип доски проекта {label} ещё не известен — дождитесь обновления из Jira" return None @@ -282,8 +290,8 @@ def check_confirmed(conn, cmd) -> tuple[bool, dict | None]: def retry_params(cmd) -> dict: - """Повтор ensure_sprint и команд спринта берёт доску заново (она в params ставится при постановке).""" - drop = cmd["type"] in ("ensure_sprint", *commands.SPRINT_TYPES) + """Повтор ensure_sprint, команд спринта и ensure_fields берёт доску заново (она в params ставится при постановке).""" + drop = cmd["type"] in ("ensure_sprint", "ensure_fields", *commands.SPRINT_TYPES) return {k: v for k, v in cmd["params"].items() if not (drop and k == "board_id")} diff --git a/tests/test_queue.py b/tests/test_queue.py index 661d559..d6544f0 100644 --- a/tests/test_queue.py +++ b/tests/test_queue.py @@ -895,6 +895,82 @@ def test_retry_premigration_sprint_without_board(conn, add_project): # Review assert queue.batch_view(conn, r["id"])["commands"][0]["params"] == {"key": "A-1", "sprint": "Спринт 2", "board_id": 4216} + +def fields_sp(key, sp=1): + return {"type": "ensure_fields", "params": {"key": key, "story_points": sp}} + + +def test_story_points_gets_project_board(conn, add_project): # сценарий «Оценка задачи проекта» + add_project(conn) + mirror.apply_state(conn, [{"key": "AURORA-1692", "labels": ["AWPCA"]}], []) + b = queue.create_batch(conn, "x", "claude", [fields_sp("AURORA-1692")]) + assert queue.batch_view(conn, b["id"])["commands"][0]["params"] == {"key": "AURORA-1692", "story_points": 1, "board_id": 4216} + + +@pytest.mark.parametrize("setup, key, msg", [ + (dict(board_id=5120, board_type="kanban"), "AURORA-1", + "команда 1: у проекта STOCKS_DRRK канбан-доска, оценка — только на scrum-доске"), + (dict(board_id=5120, board_type=None), "AURORA-1", "тип доски проекта STOCKS_DRRK ещё не известен"), + (dict(board_id=None, board_type=None), "AURORA-1", "у проекта STOCKS_DRRK нет доски Jira"), + (dict(board_id=5120, board_type="scrum"), "AURORA-77", + "команда 1: AURORA-77 не входит ни в один проект — доску для оценки не определить"), + (dict(board_id=5120, board_type="scrum"), "AURORA-12", "с разными досками"), +]) +def test_story_points_board_rejected(conn, add_project, setup, key, msg): # сценарии «Оценка вне проектов», «на канбане» + add_project(conn) + add_project(conn, "STOCKS_DRRK", **setup) + mirror.apply_state(conn, [{"key": "AURORA-1", "labels": ["STOCKS_DRRK"]}, {"key": "AURORA-77", "labels": ["kind-dev"]}, + {"key": "AURORA-12", "labels": ["AWPCA", "STOCKS_DRRK"]}], []) + with pytest.raises(CommandError, match=msg): + queue.create_batch(conn, "x", "claude", [fields_sp(key)]) + assert conn.execute("SELECT COUNT(*) AS n FROM batch").fetchone()["n"] == 0 + + +def test_fields_without_points_no_board(conn, add_project): # сценарий «Поля без оценки — без доски» + add_project(conn) + mirror.apply_state(conn, [{"key": "AURORA-77", "labels": ["kind-dev"]}], []) + b = queue.create_batch(conn, "x", "claude", [{"type": "ensure_fields", "params": {"key": "AURORA-77", "duedate": "2026-10-30"}}]) + assert "board_id" not in queue.batch_view(conn, b["id"])["commands"][0]["params"] + + +def test_story_points_for_new_issue_uses_batch_labels(conn, add_project): + add_project(conn) + b = queue.create_batch(conn, "x", "claude", [ + {"type": "ensure_issue", "params": {"temp_key": "new:1", "issue_type": "task", "summary": "Н"}}, fields_sp("new:1")], + project="AWPCA") + assert queue.batch_view(conn, b["id"])["commands"][1]["params"]["board_id"] == 4216 + + +def test_fields_and_sprint_same_issue(conn, add_project): + add_project(conn) + mirror.apply_state(conn, [{"key": "A-1", "labels": ["AWPCA"]}], []) + b = queue.create_batch(conn, "x", "claude", [fields_sp("A-1"), sprint("A-1")]) + assert [c["params"]["board_id"] for c in queue.batch_view(conn, b["id"])["commands"][:2]] == [4216, 4216] + + +def test_client_board_id_in_fields_rejected(conn, add_project): + add_project(conn) + with pytest.raises(CommandError, match="лишние параметры board_id"): + queue.create_batch(conn, "x", "claude", [{"type": "ensure_fields", "params": {"key": "A-1", "story_points": 1, "board_id": 1}}]) + + +def test_retry_story_points_recomputes_board(conn, add_project): + add_project(conn) + mirror.apply_state(conn, [{"key": "AURORA-1692", "labels": ["AWPCA"]}], []) + b = queue.create_batch(conn, "x", "claude", [fields_sp("AURORA-1692")]) + cid = queue.batch_view(conn, b["id"])["commands"][0]["id"] + conn.execute("UPDATE jira_project SET board_id = 5120, board_type = 'scrum'") + r = queue.retry_command(conn, cid, "claude") + assert queue.batch_view(conn, r["id"])["commands"][0]["params"]["board_id"] == 5120 + + +def test_retry_fields_without_points_keeps_params(conn, add_project): + add_project(conn) + p = {"key": "AURORA-77", "duedate": "2026-10-30"} + b = queue.create_batch(conn, "x", "claude", [{"type": "ensure_fields", "params": dict(p)}]) + r = queue.retry_command(conn, queue.batch_view(conn, b["id"])["commands"][0]["id"], "claude") + assert queue.batch_view(conn, r["id"])["commands"][0]["params"] == p + def meta(name="AWPCA_Sprint_4"): return {"type": "ensure_sprint_meta", "params": {"sprint": name, "start_date": "2026-10-28", "end_date": "2026-11-11"}} def close(name="AWPCA_Sprint_3_Corrections", to="AWPCA_Sprint_4"):