houseplan-card/scripts/wait-verdict.mjs

#!/usr/bin/env node
// Детерминированное ожидание вердикта / CI (#496).
//
// Runbook велит автору ждать вердикт опросом: раз в 90 секунд, не более 110 раз,
// смотреть на метку. В исполнении LLM каждый тик — это ход модели с чтением JSON
// и рассуждением «ничего не изменилось» — десятки пустых ходов на одно ревью.
// Этот скрипт делает опрос сам и ГОВОРИТ только при смене состояния: одинаковое
// состояние не будит никого. Что доставляется: смена статусной метки (вердикт),
// отказ конвейера (комментарий «Ревью не запускалось» — конфликт ребейза или,
// отдельно, красный/не найденный Validate на материале, #810; «Автоматическое
// ревью не отработало»), исход слияния кандидата (#768: по каталогу `OUTCOME_SIGNS`
// `merge-candidate.mjs` — отменено, конфликт, красный или не дождавшийся
// Validate кандидат, ушедший dev, отказ push, сбой шага), маршрут вердикта show
// (#726: трек повышен до ask / вопрос владельцу), `blocked`, `review-4`, а при
// `--sha` — исход Validate на этом SHA. Исторические комментарии до последнего
// запроса S4/S7 образуют baseline: иначе новый раунд немедленно завершался по
// старому failure. Событие текущего раунда, даже опубликованное до запуска
// waiter, доставляется сразу (#546).
//
// Скрипт НИЧЕГО не пишет: ни меток, ни комментариев, ни запусков. Новое ревью
// или релиз начинаются только по текущей авторизации человека.
//
//   node scripts/wait-verdict.mjs --issue 437 [--sha <tip>] [--interval 90] [--max 110]
//
// Коды выхода: 0 — статус сменился (вердикт есть, читать метку и комментарий;
// причина исхода слияния печатается и тогда, когда метка уже ушла в S6);
// 3 — доставлено событие, требующее действия (отказ конвейера, конфликт,
// неудавшееся слияние, blocked, review-4, красный Validate) — даже если метка
// ещё S7; 4 — лимит ожидания, состояние прежнее; 2 — ошибка вызова. Исход
// `rereview` (дифф изменился при ребейзе) печатается, но ожидание идёт дальше:
// новый заход ревью конвейер запускает сам. Успешное слияние признака в
// каталоге не имеет — о нём говорит метка S8 (код 0).

import { spawnSync } from 'node:child_process';
import { isMainModule } from './spawn-portable.mjs';
import { outcomeOf } from './merge-candidate.mjs';

export const REVIEW_LABELS = ['S4-spec-review', 'S7-code-review'];
const STATUS = ['S1-new', 'S2-analysis', 'S3-spec', 'S4-spec-review', 'S5-ready', 'S6-in-progress', 'S7-code-review', 'S8-merged'];

/**
 * Комментарии конвейера, которые требуют действия автора или владельца.
 * Исходы `merge-candidate.mjs` узнаются раньше, по его каталогу
 * (`OUTCOME_EVENTS` ниже); `stale` и `merge-conflict` здесь — префиксы для тел
 * до #752 и признаки, которые по `kind` импортирует `process-metrics.mjs`.
 *
 * #810: «**Ревью не запускалось:**» — общий префикс двух комментариев
 * `_process.yml` до ревью: «Конфликт с dev — вернуть автору без ревью» и
 * «Validate красный — вернуть автору без ревью» (красный или не найденный
 * прогон на материале — не конфликт). Причину даёт продолжение первой строки;
 * эти же признаки `validate-red`, `conflict` и `not-run` (семейство без
 * узнанной причины) `process-metrics.mjs` берёт по `kind` (К3 #728) — один
 * источник, не копия.
 */
export const PIPELINE_EVENTS = [
  { re: /^\*\*Ревью не запускалось:\*\* Validate(?: с мутантами)? на материале /m, kind: 'validate-red', text: 'конвейер: Validate на материале красный/не найден — разобрать прогон, править код не обязательно' },
  { re: /^\*\*Ревью не запускалось:\*\* ветка \S+ не ребейзится на /m, kind: 'conflict', text: 'конвейер: ветка не ребейзится на dev — конфликт разрешает автор' },
  { re: /^\*\*Ревью не запускалось:\*\*/m, kind: 'not-run', text: 'конвейер: ревью не запускалось, причина не распознана — читать комментарий' },
  { re: /^\*\*Слияние отменено/m, kind: 'stale', text: 'конвейер: слияние отменено — вершина ветки ушла от проверенного SHA (#312)' },
  { re: /^\*\*Код-ревью зелёное — вердикт выше в силе/m, kind: 'merge-conflict', text: 'конвейер: вердикт зелёный, слияние конфликтует — ребейз (rebase-on-dev.mjs) и снова S7' },
  { re: /^Автоматическое ревью не отработало/m, kind: 'failure', text: 'конвейер: прогон ревью упал — метка не менялась, смотреть логи, сообщить владельцу' },
  { re: /^Лимит циклов ревью исчерпан/m, kind: 'exhausted', text: 'конвейер: лимит циклов исчерпан — решение владельца' },
  // #726: маршрут вердикта show. После исчерпания: тот же комментарий может нести
  // и маршрут, но решение тогда за владельцем — первым находится `exhausted`.
  { re: /^\*\*Ревью show: решать есть что — трек повышен до `track:ask`\.\*\*/m, kind: 'reclassify', text: 'конвейер: трек повышен до ask: полное ТЗ в теле issue, всю ветку (включая тесты и документы) не пушить до S5' },
  { re: /^\*\*Ревью show: решать есть что — вопрос владельцу\.\*\*/m, kind: 'owner-question', text: 'конвейер: вопрос владельцу о треке show — ждёт владельца' },
  { re: /^Конвейер ревью не запущен:/m, kind: 'refused', text: 'конвейер отказал (blocked/review-4) — читать комментарий' },
];

/**
 * #768: исходы слияния кандидата — по общему каталогу `OUTCOME_SIGNS`
 * (`outcomeOf`), а не копиями регулярок: прежний список знал два заголовка из
 * одиннадцати, и отказ в окне «комментарий уже есть, метка ещё S7» ждал до
 * лимита, а после смены метки печаталась одна смена статуса без причины.
 *
 * Ключ — `action` признака, внутри — `stage` (`merge` после зелёного вердикта,
 * `rebase` — страж ребейза до ревью). `code`: 3 — нужно действие автора или
 * владельца; `null` — исход не терминальный (`rereview`: задача уже снова в
 * S7, новый заход ревью конвейер запускает сам) — строка печатается, ожидание
 * идёт дальше. Новый исход каталога краснит тест #768, пока у него нет строки
 * в таблице теста; без строки здесь он доставляется общим текстом с кодом 3.
 */
export const OUTCOME_EVENTS = Object.freeze({
  'reject-stale': { kind: 'stale', code: 3, text: 'конвейер: слияние отменено — вершина ветки ушла от проверенного SHA (#312)' },
  conflict: { kind: 'merge-conflict', code: 3, text: 'конвейер: вердикт зелёный, слияние конфликтует — ребейз (rebase-on-dev.mjs) и снова S7' },
  'validation-red': { kind: 'validation-red', code: 3, text: 'конвейер: вердикт зелёный, но кандидат после ребейза на dev красный — разобрать прогон Validate и снова S7' },
  'validation-missing': { kind: 'validation-missing', code: 3, text: 'конвейер: вердикт зелёный, Validate на кандидате не дождались — слияния нет; после зелёного Validate на кандидате снова S7, править код не нужно' },
  'give-up': { kind: 'give-up', code: 3, text: 'конвейер: вердикт зелёный, dev движется быстрее слияния — снова S7, когда dev успокоится' },
  'push-refused-workflow': {
    merge: { kind: 'push-refused-workflow', code: 3, text: 'конвейер: вердикт зелёный, но GitHub не принял push кандидата — он меняет workflow-файл, у токена нет права: ребейз и push делает автор либо право выдаёт владелец (#705)' },
    rebase: { kind: 'push-refused-workflow', code: 3, text: 'конвейер: ревью не запускалось — GitHub не принял push ребейза, ветка меняет workflow-файл: ребейз и push делает автор либо право выдаёт владелец (#705)' },
  },
  'push-refused': {
    merge: { kind: 'push-refused', code: 3, text: 'конвейер: вердикт зелёный, но GitHub отклонил push в dev — причина в комментарии, устранить и снова S7 (#705)' },
    rebase: { kind: 'push-refused', code: 3, text: 'конвейер: ревью не запускалось — GitHub отклонил push ребейза, причина в комментарии (#705)' },
  },
  error: { kind: 'merge-error', code: 3, text: 'конвейер: вердикт зелёный, шаг слияния упал — сбой в комментарии, после разбора снова S7' },
  rereview: { kind: 'rereview', code: null, text: 'конвейер: дифф изменился при ребейзе на dev — вердикт к нему не применим, новый заход ревью запускается сам; ждём его вердикт' },
});

/** Событие по телу комментария: исход слияния по каталогу, иначе свой комментарий конвейера. */
export function pipelineEventOf(body) {
  const text = String(body || '');
  const sign = outcomeOf(text);
  if (sign) {
    const entry = OUTCOME_EVENTS[sign.action];
    const event = entry && (entry.kind ? entry : entry[sign.stage]);
    // Исход, которого таблица ещё не знает: молчать нельзя — это и был дефект #768.
    return event || { kind: sign.action, code: 3, text: `конвейер: исход слияния \`${sign.action}\` — читать комментарий` };
  }
  return PIPELINE_EVENTS.find((e) => e.re.test(text)) || null;
}

/** Последнее применение S4/S7 — устойчивый якорь текущего раунда ревью. */
export function reviewRequestFromEvents(events = []) {
  const requests = events
    .filter((event) => event?.event === 'labeled' && REVIEW_LABELS.includes(event?.label?.name))
    .map((event) => ({
      id: String(event.id || event.node_id || event.createdAt || event.created_at || ''),
      at: event.createdAt || event.created_at || null,
      label: event.label.name,
    }))
    .filter((request) => Number.isFinite(Date.parse(String(request.at || ''))));
  requests.sort((a, b) => Date.parse(a.at) - Date.parse(b.at) || a.id.localeCompare(b.id));
  return requests.at(-1) || null;
}

function eventBelongsToReview(comment, request) {
  if (!request) return true; // Совместимость с чистыми/старыми snapshot без timeline.
  const eventAt = Date.parse(String(comment.at || ''));
  const requestAt = Date.parse(String(request.at || ''));
  return Number.isFinite(eventAt) && Number.isFinite(requestAt) && eventAt >= requestAt;
}

/** Снимок → нормализованное состояние. */
export function stateOf(snapshot) {
  const labels = snapshot.labels || [];
  const status = STATUS.find((l) => labels.includes(l)) || null;
  const events = (snapshot.comments || [])
    .map((c) => ({ id: c.id, at: c.createdAt, event: pipelineEventOf(c.body) }))
    .filter((c) => c.event && eventBelongsToReview(c, snapshot.reviewRequest));
  const last = events.at(-1) || null;
  return {
    status,
    blocked: labels.includes('blocked'),
    exhausted: labels.includes('review-4'),
    lastEventId: last ? String(last.id) : null,
    lastEvent: last ? last.event : null,
    reviewRequest: snapshot.reviewRequest || null,
    validate: snapshot.validate || null,
  };
}

/**
 * Решение по паре состояний: что сказать и заканчивать ли.
 * `prev` — предыдущее состояние (null на первом тике).
 */
export function decide(prev, next) {
  const lines = [];
  let code = null;
  if (prev && prev.status !== next.status) {
    lines.push(`метка: ${prev.status || '—'} → ${next.status || '—'}`);
    code = 0;
  }
  if (next.lastEventId && (!prev || prev.lastEventId !== next.lastEventId)) {
    lines.push(next.lastEvent.text);
    // `code: null` — исход не терминальный (rereview): сказать и ждать дальше.
    const eventCode = next.lastEvent.code === undefined ? 3 : next.lastEvent.code;
    if (code === null && eventCode !== null) code = eventCode;
  }
  if (next.exhausted && (!prev || !prev.exhausted)) { lines.push('review-4: лимит циклов — решение владельца'); code = 3; }
  if (next.blocked && (!prev || !prev.blocked)) { lines.push('blocked: задача ждёт владельца, ждать вердикт бессмысленно'); code = 3; }
  if (next.validate && (!prev || !prev.validate || prev.validate.conclusion !== next.validate.conclusion || prev.validate.status !== next.validate.status)) {
    if (next.validate.status === 'completed' && next.validate.conclusion !== 'success') {
      lines.push(`Validate на SHA красный: ${next.validate.conclusion}${next.validate.url ? ` ${next.validate.url}` : ''}`);
      if (code === null) code = 3;
    } else if (next.validate.status === 'completed') {
      lines.push(`Validate на SHA зелёный${next.validate.url ? ` ${next.validate.url}` : ''}`);
    }
  }
  // Первый тик: состояние печатается один раз как точка отсчёта, без завершения.
  if (!prev) {
    lines.unshift(`ожидание: статус ${next.status || '—'}${next.blocked ? ' +blocked' : ''}${next.exhausted ? ' +review-4' : ''}`);
    if (!REVIEW_LABELS.includes(next.status) && code === null) {
      lines.push('статус не ревьюшный — ждать нечего');
      code = 0;
    }
  }
  return { lines, done: code !== null, code };
}

export async function waitForVerdict({
  readSnapshot, intervalMs = 90_000, maxTicks = 30, sleep = (ms) => new Promise((r) => setTimeout(r, ms)), log = console.log,
}) {
  let prev = null;
  for (let tick = 1; tick <= maxTicks; tick++) {
    const next = stateOf(await readSnapshot());
    const { lines, done, code } = decide(prev, next);
    for (const line of lines) log(`[${new Date().toISOString().slice(11, 19)}] ${line}`);
    if (done) return code;
    prev = next;
    if (tick < maxTicks) await sleep(intervalMs);
  }
  log(`лимит ожидания (${maxTicks} × ${Math.round(intervalMs / 1000)} с): состояние не менялось — прогон мог упасть, смотреть Actions`);
  return 4;
}

function gh(args) {
  const r = spawnSync('gh', args, { encoding: 'utf8', maxBuffer: 64 * 1024 * 1024 });
  if (r.error || r.status !== 0) throw new Error(`gh ${args.join(' ')} → ${(r.stderr || r.error?.message || '').trim()}`);
  return JSON.parse(r.stdout || 'null');
}

export function ghSnapshotReader({ number, repo, sha }) {
  return async () => {
    const view = gh(['issue', 'view', String(number), '--repo', repo, '--json', 'labels,comments']);
    const pages = gh(['api', '--paginate', '--slurp', `repos/${repo}/issues/${number}/events?per_page=100`]);
    const timelineEvents = Array.isArray(pages?.[0]) ? pages.flat() : (Array.isArray(pages) ? pages : []);
    const snapshot = {
      labels: (view.labels || []).map((l) => l.name),
      comments: (view.comments || []).map((c) => ({ id: c.id || c.url || c.createdAt, createdAt: c.createdAt, body: c.body })),
      reviewRequest: reviewRequestFromEvents(timelineEvents),
    };
    if (sha) {
      try {
        const runs = gh(['run', 'list', '--repo', repo, '--workflow', 'validate.yml', '--commit', sha, '--limit', '5', '--json', 'status,conclusion,url']);
        const done = runs.find((r) => r.status === 'completed') || runs[0];
        if (done) snapshot.validate = { status: done.status, conclusion: done.conclusion, url: done.url };
      } catch { /* Validate — дополнение, не условие */ }
    }
    return snapshot;
  };
}

if (isMainModule(import.meta.url)) {
  const argv = process.argv.slice(2);
  const value = (name, fallback = '') => {
    const eq = argv.find((a) => a.startsWith(`--${name}=`));
    if (eq) return eq.slice(name.length + 3);
    const at = argv.indexOf(`--${name}`);
    return at >= 0 ? (argv[at + 1] || '') : fallback;
  };
  const number = Number(value('issue'));
  if (!Number.isInteger(number) || number <= 0) { console.error('нужен --issue <номер>'); process.exit(2); }
  const repo = value('repo', 'Matysh/houseplan-card');
  const sha = value('sha') || null;
  const intervalMs = Number(value('interval', '90')) * 1000;
  const maxTicks = Number(value('max', '110'));
  waitForVerdict({ readSnapshot: ghSnapshotReader({ number, repo, sha }), intervalMs, maxTicks })
    .then((code) => { process.exitCode = code; })
    .catch((error) => { console.error(`wait-verdict: ${error.message}`); process.exitCode = 2; });
}