diff --git a/.github/workflows/evals-periodic.yml b/.github/workflows/evals-periodic.yml index 8abb9ba0c..45aeae1ce 100644 --- a/.github/workflows/evals-periodic.yml +++ b/.github/workflows/evals-periodic.yml @@ -150,7 +150,7 @@ jobs: - name: Emit run manifest (ALL periodic tests minus reasoned excludes) env: EVALS_ALL: "1" - run: EVALS_TIER=periodic bun --no-install run scripts/test-paid-shards.ts --tier periodic --emit-plan /tmp/paid-plan/manifest.json --slice-budget 420 --jobs 2 --max-parallel 36 + run: EVALS_TIER=periodic bun --no-install run scripts/test-paid-shards.ts --tier periodic --emit-plan /tmp/paid-plan/manifest.json --slice-budget 420 --jobs 2 --max-parallel 38 # Codex-only slices run on the host-run eval-codex-slices job; the # container executor runs every other slice. @@ -258,7 +258,7 @@ jobs: fail-fast: false # Every planned slice starts at once; test/evals-workflow-wiring.test.ts # fails when the live plan outgrows this cap. - max-parallel: 36 + max-parallel: 38 matrix: slice: ${{ fromJSON(needs.plan-slices.outputs.periodic_slices) }} steps: @@ -397,7 +397,7 @@ jobs: packages: read strategy: fail-fast: false - max-parallel: 36 + max-parallel: 38 matrix: slice: ${{ fromJSON(needs.plan-slices.outputs.periodic_codex_slices) }} steps: diff --git a/.github/workflows/windows-pregate-e2e.yml b/.github/workflows/windows-pregate-e2e.yml index 3c225d19b..96528e648 100644 --- a/.github/workflows/windows-pregate-e2e.yml +++ b/.github/workflows/windows-pregate-e2e.yml @@ -31,6 +31,7 @@ on: - 'lib/gate-diff/**' - 'lib/pregate/**' - 'lib/result-codes.ts' + - 'lib/result-codes-release.ts' - 'bin/gstack-wtree' - 'bin/gstack-slug' - 'bin/gstack-path-spelling.sh' diff --git a/CHANGELOG.md b/CHANGELOG.md index 05efb8229..8518777b9 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,5 +1,24 @@ # Changelog +## [1.91.116.0] - 2026-10-17 + +**Lanes and the coordinator now share a merge queue whose stamp claims are checked instead of trusted, risky changes need a cited owner approval before they ship, /review checks state machines cell by cell, pregate warns about timing assertions, and the update check notices when main moves without a version bump.** These are the field list 2 wave B items from the gbrain crew (W1-W4, W10, W12). + +### What this means for you + +- **`gstack-ship-queue` runs a shared merge queue.** `ready` prints one READY block and refuses when the tree differs from the pushed head. `stamp` checks every proof input, restamps through `gstack-restamp`, and resumes on an identical retry. The coordinator's `verify` reruns the tree receipt and recomputes a gate-ahead merge, so a lane's stamp claim is never taken on trust. Ship policy gains `gate_command`, `full_e2e` and `min_gstack_version`; a gstack older than a key it reads refuses with `POLICY_GSTACK_TOO_OLD`. See `docs/ship-policy.md#run-a-shared-merge-queue`. +- **Approval classes.** `.gstack/approval-classes.json` (read from the base branch) declares what needs an owner's approval. `gstack-ship-receipt write` refuses a branch that touches a class until the PR body cites `Approved by via for @`, bound to the effects being shipped. +- **/review's state-machines specialist** builds a kind × owner action matrix for diffs that change a state machine. `gstack-state-matrix check` reports every missing cell, and an untested cell is CRITICAL. +- **Pregate's `timing` check** warns on added test lines that bound wall or CPU time or sleep and then assert. Mark a deliberate bound with `gstack-timing-ok: `. /investigate gains a timing-flake playbook. +- **The update check sees a moved main.** At an equal VERSION it reports `UPGRADE_AVAILABLE + ` through the GitHub compare API (never `git fetch`). The cache is bound to HEAD and upstream, and snooze is keyed by SHA. /gstack-upgrade summarizes the commits instead of a CHANGELOG entry. +- **Pregate's docs lane** comes from #3215 by Cursor Agent: Markdown no test depends on is already a docs/no-tests empty lane. + +### For contributors + +- The release-path result codes live in `lib/result-codes-release.ts`, spread into `RESULT_CODES`, so `lib/result-codes.ts` stays inside the module-size ratchet. +- New paid case `review-army-state-matrix` (periodic, behavior). The periodic lane's `max-parallel` is 38 so every planned slice still starts at once. +- The scope-signal clarity test also accepts a signal printed by the helper its own selection line runs (SCOPE_STATE_MACHINE), and the hermetic update-check fixture writes the identity cache. + ## [1.91.115.0] - 2026-10-17 **Autoplan now enforces its round cap and spend budget and can export a public copy of a run, /eval-plan tests its preregistered diagnostics and checks every arm's model against repo rules before money moves, and a reviewer subagent can install gstack's read-only helpers in seconds.** These are the field list 2 wave A items from the gbrain crew (autoplan W5-W7, eval-plan W8/W9, reviewer install W11). diff --git a/VERSION b/VERSION index 51b1f1ca2..b7130a9f6 100644 --- a/VERSION +++ b/VERSION @@ -1 +1 @@ -1.91.115.0 +1.91.116.0 diff --git a/agents-digest/gstack-AGENTS.md b/agents-digest/gstack-AGENTS.md index f62f66dcf..e71867cf5 100644 --- a/agents-digest/gstack-AGENTS.md +++ b/agents-digest/gstack-AGENTS.md @@ -1,4 +1,4 @@ -# gstack digest v1.91.115.0 — regenerate/re-copy after upgrading gstack +# gstack digest v1.91.116.0 — regenerate/re-copy after upgrading gstack Behavioral rules from gstack (https://github.com/garrytan/gstack), compressed for agent hosts without a full skill install. The full skills add workflows, diff --git a/bin/gstack-approval-classes b/bin/gstack-approval-classes new file mode 100755 index 000000000..7d5ccee95 --- /dev/null +++ b/bin/gstack-approval-classes @@ -0,0 +1,84 @@ +#!/usr/bin/env bun +/** + * gstack-approval-classes — changes that need the owner's approval (field list 2, W2). + * + * gstack-approval-classes [check] [--base ] [--head ] [--diff-base ] [--json] + * gstack-approval-classes init [--force] + * gstack-approval-classes validate + * + * `check` reads the classes from the committed `origin/` copy of + * .gstack/approval-classes.json (never the working tree) and the migration + * rule from the base's ship policy, scans the branch's changes since the + * merge base, and prints `APPROVAL_CLASS: :` per hit, one + * `APPROVAL_SCOPE: @` per declared class with hits, and + * `APPROVAL_CLASSES: ok | found= | none` last. Built-in detectors only + * report. Exit 0 ok or none, 1 found, 3 when the base file is invalid or the + * base is unresolvable. Enforcement is gstack-ship-receipt write + * (APPROVAL_CITATION_MISSING). Logic: lib/approval-classes.ts. + */ +import { spawnSync } from 'node:child_process'; +import * as fs from 'node:fs'; +import * as path from 'node:path'; +import { APPROVAL_CLASSES_PATH, exampleApprovalClassesJson, loadWorkingApprovalClasses, renderApprovalScan, runApprovalScan } from '../lib/approval-classes'; +import { EXIT, exitTableHelp } from '../lib/headless-artifacts'; +import { resultLine } from '../lib/result-codes'; +import { resolveBaseBranch } from '../lib/ship-policy'; + +const HELP = `gstack-approval-classes — changes that need the owner's approval (docs/ship-policy.md#approval-classes) + + check [--base ] [--head ] [--diff-base ] [--json] + changes since the merge base with origin/ (default origin/HEAD's branch), at --head or the + working tree; classes come only from the committed ${APPROVAL_CLASSES_PATH} on origin/ + init [--force] write an example ${APPROVAL_CLASSES_PATH} + validate schema and containment check of the working-tree file (before you commit it) + +A declared class with hits needs a line in the PR body that gstack-ship-receipt write can resolve: + Approved by via [for @] + +${exitTableHelp()}`; + +function flag(args: string[], name: string): string | undefined { + const i = args.indexOf(name); + return i >= 0 ? args[i + 1] : undefined; +} + +function main(argv: string[]): number { + if (argv.includes('--help') || argv.includes('-h')) { process.stdout.write(HELP + '\n'); return EXIT.ok; } + const cmd = argv[0] && !argv[0].startsWith('--') ? argv[0] : 'check'; + const rest = cmd === argv[0] ? argv.slice(1) : argv; + const root = spawnSync('git', ['rev-parse', '--show-toplevel'], { encoding: 'utf8', timeout: 15_000 }); + if (root.status !== 0) { process.stderr.write('gstack-approval-classes: not inside a git repository\n'); return EXIT.usage; } + const repoRoot = root.stdout.trim(); + const file = path.join(repoRoot, APPROVAL_CLASSES_PATH); + + if (cmd === 'init') { + if (fs.existsSync(file) && !rest.includes('--force')) { process.stderr.write(`gstack-approval-classes: ${APPROVAL_CLASSES_PATH} exists (pass --force to overwrite)\n`); return EXIT.refused; } + fs.mkdirSync(path.dirname(file), { recursive: true }); + fs.writeFileSync(file, exampleApprovalClassesJson()); + process.stdout.write(`APPROVAL_CLASSES_INIT: ${APPROVAL_CLASSES_PATH} (edit, commit and merge it; check reads only the base copy)\n`); + return EXIT.ok; + } + if (cmd === 'validate') { + const load = loadWorkingApprovalClasses(repoRoot); + if ('absent' in load) { process.stdout.write(`APPROVAL_CLASSES: none (no ${APPROVAL_CLASSES_PATH})\n`); return EXIT.ok; } + if ('errors' in load) { for (const e of load.errors) process.stderr.write(resultLine('gstack-approval-classes validate', 'APPROVAL_CLASSES_INVALID', `${e.message} at ${e.path || ''}`) + '\n'); return EXIT.refused; } + if ('unavailable' in load || !load.config) return EXIT.fail; + process.stdout.write(`APPROVAL_CLASSES_VALID: ${APPROVAL_CLASSES_PATH} classes=${load.config.classes.length}\n`); + return EXIT.ok; + } + if (cmd !== 'check') { process.stderr.write(`gstack-approval-classes: unknown command ${cmd}\n${HELP}\n`); return EXIT.usage; } + + const json = rest.includes('--json'); + const base = resolveBaseBranch(repoRoot, flag(rest, '--base')); + const outcome = runApprovalScan({ repoRoot, base, head: flag(rest, '--head'), diffBase: flag(rest, '--diff-base') }); + if ('unavailable' in outcome) { process.stderr.write(resultLine('gstack-approval-classes', 'APPROVAL_SOURCE_UNAVAILABLE', `${outcome.unavailable}; classes are read only from the base, so nothing was checked`) + '\n'); return EXIT.refused; } + if ('errors' in outcome) { for (const e of outcome.errors) process.stderr.write(resultLine('gstack-approval-classes', 'APPROVAL_CLASSES_INVALID', `${e.message} at ${e.path || ''} (${outcome.source})`) + '\n'); return EXIT.refused; } + if ('error' in outcome && outcome.unreadable) { process.stderr.write(resultLine('gstack-approval-classes', 'APPROVAL_SOURCE_UNAVAILABLE', `${outcome.error}, so nothing was checked`) + '\n'); return EXIT.refused; } + if ('error' in outcome) { process.stderr.write(`gstack-approval-classes: ${outcome.error}\n`); return EXIT.usage; } + const { scan, absent } = outcome; + process.stdout.write(json ? JSON.stringify({ ...scan, absent }) + '\n' : renderApprovalScan(scan, absent)); + if (scan.hits.length) { process.stderr.write(resultLine('gstack-approval-classes', 'APPROVAL_CLASS_FOUND', `${scan.scopes.map(s => s.token).join(', ')} need an Approved by line`) + '\n'); return EXIT.fail; } + return EXIT.ok; +} + +process.exitCode = main(process.argv.slice(2)); diff --git a/bin/gstack-doctor-components.sh b/bin/gstack-doctor-components.sh index d5572418d..e0506885f 100644 --- a/bin/gstack-doctor-components.sh +++ b/bin/gstack-doctor-components.sh @@ -253,6 +253,19 @@ gstack_result_anchor() { DX_CAPTURE_INTERRUPTED) printf '%s' 'dx-capture-interrupted' ;; DX_CAPTURE_REDACTION_FAILED) printf '%s' 'dx-capture-redaction-failed' ;; DX_CAPTURE_INTERNAL) printf '%s' 'dx-capture-internal' ;; + POLICY_GSTACK_TOO_OLD) printf '%s' 'policy-gstack-too-old' ;; + QUEUE_NOT_READY) printf '%s' 'queue-not-ready' ;; + QUEUE_PROOF_MISSING) printf '%s' 'queue-proof-missing' ;; + QUEUE_STAMP_NOT_STAMP_ONLY) printf '%s' 'queue-stamp-not-stamp-only' ;; + QUEUE_VERIFY_MISMATCH) printf '%s' 'queue-verify-mismatch' ;; + QUEUE_GATE_MISSING) printf '%s' 'queue-gate-missing' ;; + GATE_AHEAD_ATTEMPT_INVALID) printf '%s' 'gate-ahead-attempt-invalid' ;; + PREGATE_TIMING_ASSERTION) printf '%s' 'pregate-timing-assertion' ;; + APPROVAL_CLASSES_INVALID) printf '%s' 'approval-classes-invalid' ;; + APPROVAL_CLASS_FOUND) printf '%s' 'approval-class-found' ;; + APPROVAL_CITATION_MISSING) printf '%s' 'approval-citation-missing' ;; + APPROVAL_SOURCE_UNAVAILABLE) printf '%s' 'approval-source-unavailable' ;; + STATE_MATRIX_INCOMPLETE) printf '%s' 'state-matrix-incomplete' ;; *) return 1 ;; esac } diff --git a/bin/gstack-ship-policy b/bin/gstack-ship-policy index 2c1d61d9b..206bd48c7 100755 --- a/bin/gstack-ship-policy +++ b/bin/gstack-ship-policy @@ -18,8 +18,8 @@ import * as path from 'node:path'; import { EXIT, exitTableHelp } from '../lib/headless-artifacts'; import { resultLine } from '../lib/result-codes'; import { - SHIP_POLICY_PATH, examplePolicyJson, explainPolicy, isUnavailable, loadPolicyFromBase, loadPolicyFromHead, - policyUnavailableLine, renderEffective, resolveBaseBranch, type LoadedPolicy, + POLICY_KEYS, POLICY_KEY_INTRODUCED, SHIP_POLICY_PATH, examplePolicyJson, explainPolicy, isUnavailable, loadPolicyFromBase, loadPolicyFromHead, + minimumReader, policyUnavailableLine, renderEffective, resolveBaseBranch, type LoadedPolicy, } from '../lib/ship-policy'; const HELP = `gstack-ship-policy — the repo ship policy (docs/ship-policy.md) @@ -86,13 +86,18 @@ function main(argv: string[]): number { if (cmd === 'validate' || cmd === 'show-effective') { const loaded = load(root, rest, cmd === 'validate' ? 'head' : 'base'); if (typeof loaded === 'number') return loaded; + const set = POLICY_KEYS.filter(k => loaded.values[k] && loaded.values[k] !== 'default'); + const introduced = Object.fromEntries(set.map(k => [k, POLICY_KEY_INTRODUCED[k]])); + const minReader = set.length ? minimumReader(introduced) : null; if (json) { - process.stdout.write(JSON.stringify({ valid: loaded.errors.length === 0, present: loaded.present, source: loaded.source, policy: loaded.policy, values: loaded.values, errors: loaded.errors }) + '\n'); + process.stdout.write(JSON.stringify({ valid: loaded.errors.length === 0, present: loaded.present, source: loaded.source, policy: loaded.policy, values: loaded.values, introduced, min_reader: minReader, errors: loaded.errors }) + '\n'); return loaded.errors.length ? EXIT.fail : EXIT.ok; } printErrors(loaded); if (cmd === 'validate') { process.stdout.write(loaded.errors.length ? `POLICY_INVALID: ${loaded.errors.length} error(s) in ${loaded.source.label}\n` : `POLICY_VALID: ${loaded.present ? loaded.source.label : `no ${SHIP_POLICY_PATH} (defaults apply)`}\n`); + for (const k of set) process.stdout.write(`KEY: ${k} introduced=${introduced[k]}\n`); + if (minReader) process.stdout.write(`MIN_READER: gstack ${minReader} (every lane that reads this policy needs at least this version)\n`); return loaded.errors.length ? EXIT.fail : EXIT.ok; } process.stdout.write(renderEffective(loaded, { base: flag(rest, '--base') ?? resolveBaseBranch(root) })); diff --git a/bin/gstack-ship-queue b/bin/gstack-ship-queue new file mode 100755 index 000000000..6135827bb --- /dev/null +++ b/bin/gstack-ship-queue @@ -0,0 +1,161 @@ +#!/usr/bin/env bun +/** + * gstack-ship-queue — the shared merge queue, one subcommand per protocol + * step (field list 2, W1; docs/ship-policy.md#run-a-shared-merge-queue). + * + * gstack-ship-queue ready --pr [--pregate ] [--gate-exit --gate-log ] + * gstack-ship-queue stamp --pr --version --expect-gated --expect-base + * [--expect-order ] [--allow-repo-commands] [--gate-exit --gate-log ] + * gstack-ship-queue verify --pr (--gated | --record ) [--receipt ] + * [--expect-head ] [--ref ] [--no-fetch] [--gate-exit --gate-log ] + * gstack-ship-queue gate-ahead --after --pr [--predecessor-ref ] [--allow-repo-commands] + * gstack-ship-queue gate-ahead --record --pr --attempt --exit --log + * gstack-ship-queue gate-ahead --list --pr + * + * Every subcommand takes --base (default origin/HEAD, else main) and + * ends with GSTACK_RESULT: skill=ship-queue status=complete|refused run=. + * gstack-restamp stays the primitive. Nothing here pushes. Logic: + * lib/ship-queue.ts, lib/ship-queue-gate.ts. + */ +import { spawnSync } from 'node:child_process'; +import * as path from 'node:path'; +import { EXIT, exitTableHelp, formatResult } from '../lib/headless-artifacts'; +import { versionAtRef } from '../lib/restamp'; +import { RESULT_CODES } from '../lib/result-codes'; +import { resolveBaseBranch } from '../lib/ship-policy'; +import { loadBasePolicy, ready, stamp, verify, type QueueContext, type StepOutput } from '../lib/ship-queue'; +import { attemptFile, listAttempts, prepareGateAhead, recordGateAhead, type QueueFailure } from '../lib/ship-queue-gate'; + +const HELP = `gstack-ship-queue — the shared merge queue's protocol steps (docs/ship-policy.md#run-a-shared-merge-queue) + + ready --pr [--pregate ] [--gate-exit --gate-log ] + READY # STAMP_VERSION=, CI at that head, PREGATE, gate state + stamp --pr --version --expect-gated --expect-base [--expect-order ] [--allow-repo-commands] + [--gate-exit --gate-log ] + restamp, commit and prove: QUEUE_STAMP: head= gated= tree= receipt= + verify --pr --gated | --record [--receipt ] [--expect-head ] [--ref ] [--no-fetch] + [--gate-exit --gate-log ] (full_e2e: --gated needs the lane's passing gate run on that head) + the coordinator's check from the PR's pushed head: VERIFY: ... and MERGE_CONDITION + gate-ahead --after --pr [--predecessor-ref ] [--allow-repo-commands] + prepare an attempt: merged, stamped worktree, gated sha and the gate command + gate-ahead --record --pr --attempt --exit --log + bind the gate result to that attempt's gated tree; removes its worktree + gate-ahead --list --pr attempts for a PR, newest last (the current one) + +--base : base branch (default: origin/HEAD, else main). Nothing here pushes. +${exitTableHelp()}`; + +function flag(args: string[], name: string): string | undefined { + const i = args.indexOf(name); + return i >= 0 ? args[i + 1] : undefined; +} + +function finish(cmd: string, out: StepOutput): number { + for (const line of out.lines) process.stdout.write(line + '\n'); + if (out.failure) { + const f = out.failure; + process.stderr.write(`gstack-ship-queue ${cmd}: ${f.message}; fix: ${f.fix ?? RESULT_CODES[f.code].fix} (${f.code})\n`); + } + process.stdout.write(formatResult('ship-queue', out.ok ? 'complete' : 'refused', out.run) + '\n'); + if (out.ok) return EXIT.ok; + return out.failure && ['QUEUE_VERIFY_MISMATCH', 'QUEUE_STAMP_NOT_STAMP_ONLY'].includes(out.failure.code) ? EXIT.fail : EXIT.refused; +} + +const shq = (s: string) => `'${s.replace(/'/g, `'\\''`)}'`; + +function usage(message: string): number { + process.stderr.write(`gstack-ship-queue: ${message}\n${HELP}\n`); + return EXIT.usage; +} + +function gateAhead(ctx: QueueContext, args: string[]): number { + const pr = flag(args, '--pr'); + if (!pr) return usage('gate-ahead needs --pr (records are keyed by PR)'); + if (args.includes('--list')) { + const all = listAttempts(ctx.repoRoot, pr); + for (const a of all) process.stdout.write(`ATTEMPT: ${a.attempt} state=${a.state} gated_tree=${a.gated_tree} predecessor=#${a.predecessor_pr}@${a.predecessor_head.slice(0, 12)}${a.result ? ` exit=${a.result.exit}` : ''}${a === all.at(-1) ? ' current' : ''}\n`); + if (!all.length) process.stdout.write(`ATTEMPT: none for #${pr}\n`); + return EXIT.ok; + } + if (args.includes('--record')) { + const attempt = flag(args, '--attempt'); + const exit = flag(args, '--exit'); + const log = flag(args, '--log'); + if (!attempt || exit === undefined || !/^-?\d+$/.test(exit) || !log) return usage('gate-ahead --record needs --attempt --exit --log '); + const r = recordGateAhead({ repoRoot: ctx.repoRoot, pr, attempt, exit: Number(exit), log: path.resolve(log) }); + if ('code' in r) return finish('gate-ahead', { ok: false, lines: [], failure: r, run: attemptFile(ctx.repoRoot, pr, attempt) }); + const cur = r.current && r.current.attempt !== attempt ? `no (superseded by ${r.current.attempt})` : 'yes'; + return finish('gate-ahead', { + ok: true, run: path.relative(ctx.repoRoot, r.file), + lines: [ + `GATE_RECORD: pr=${pr} attempt=${attempt} exit=${r.record.result!.exit} gated_tree=${r.record.gated_tree} log_sha256=${r.record.result!.log_sha256} current=${cur}`, + ...(r.repeated ? ['note: identical retry; the stored result is returned'] : []), + `record: ${r.file}`, + `next: send the record file with the READY report; the coordinator runs gstack-ship-queue verify --pr ${pr} --record once this PR is stamped`, + ], + }); + } + const after = flag(args, '--after'); + if (!after) return usage('gate-ahead needs --after , --record or --list'); + const policy = loadBasePolicy(ctx); + if ('message' in policy) return finish('gate-ahead', { ok: false, lines: [], failure: policy, run: 'none' }); + const at = versionAtRef(ctx.repoRoot, 'HEAD'); + const r = prepareGateAhead({ + repoRoot: ctx.repoRoot, base: ctx.base, pr, after, predecessorRef: flag(args, '--predecessor-ref'), allowRepoCommands: args.includes('--allow-repo-commands'), + policy: policy.policy, versionRel: 'rel' in at ? at.rel : 'VERSION', + }); + if ('code' in r) return finish('gate-ahead', { ok: false, lines: [], failure: r as QueueFailure, run: 'none' }); + const rec = r.record; + const log = path.join(path.dirname(rec.worktree), 'gate.log'); + const cmd = rec.gate_command ?? ''; + const superseded = listAttempts(ctx.repoRoot, pr).filter(a => a.attempt !== rec.attempt && a.state === 'prepared').map(a => a.attempt); + return finish('gate-ahead', { + ok: true, run: path.relative(ctx.repoRoot, r.file), + lines: [ + `GATE_AHEAD: pr=${pr} attempt=${rec.attempt} gated=${rec.gated_head} tree=${rec.gated_tree} merge_tree=${rec.merge_tree} predecessor=#${rec.predecessor_pr}@${rec.predecessor_head.slice(0, 12)} version=${rec.version}`, + `worktree: ${rec.worktree}`, + `record: ${r.file}`, + `GATE_COMMAND: ${rec.gate_command ?? 'none (the policy sets no gate_command; run the repo gate you would run on a PR head)'}`, + ...(superseded.length ? [`note: this attempt is now current; earlier unrecorded attempts (${superseded.join(', ')}) keep their worktrees until recorded`] : []), + `next: (cd ${shq(rec.worktree)} && ${cmd}) > ${shq(log)} 2>&1; gstack-ship-queue gate-ahead --record --pr ${pr} --attempt ${rec.attempt} --exit $? --log ${shq(log)}`, + ], + }); +} + +function main(argv: string[]): number { + const [cmd, ...args] = argv; + if (!cmd || cmd === '--help' || cmd === '-h' || cmd === 'help') { process.stdout.write(HELP + '\n'); return cmd ? EXIT.ok : EXIT.usage; } + const probe = spawnSync('git', ['rev-parse', '--show-toplevel'], { encoding: 'utf8', timeout: 15_000 }); + if (probe.status !== 0) return usage('not inside a git repository'); + const repoRoot = probe.stdout.trim(); + const gh = (a: string[]) => { const r = spawnSync('gh', a, { cwd: repoRoot, encoding: 'utf8', timeout: 60_000 }); return { ok: r.status === 0, out: r.stdout ?? '', err: r.stderr ?? (r.error ? String(r.error.message) : '') }; }; + const ctx: QueueContext = { repoRoot, base: resolveBaseBranch(repoRoot, flag(args, '--base')), gh }; + const pr = flag(args, '--pr'); + if (cmd === 'gate-ahead') return gateAhead(ctx, args); + if (!pr || !/^\d+$/.test(pr)) return usage(`${cmd} needs --pr `); + const gateExit = flag(args, '--gate-exit'); + if (gateExit !== undefined && !/^-?\d+$/.test(gateExit)) return usage('--gate-exit needs an exit code'); + const gate = { gateExit: gateExit === undefined ? undefined : Number(gateExit), gateLog: flag(args, '--gate-log') }; + if (cmd === 'ready') return finish('ready', ready(ctx, { pr, pregate: flag(args, '--pregate'), ...gate })); + if (cmd === 'stamp') { + const version = flag(args, '--version'); + const expectGated = flag(args, '--expect-gated'); + const expectBase = flag(args, '--expect-base'); + if (!version || !expectGated || !expectBase) return usage('stamp needs --version --expect-gated --expect-base '); + return finish('stamp', stamp(ctx, { + pr, version, expectGated, expectBase, expectOrder: flag(args, '--expect-order')?.split(',').map(s => s.trim()).filter(Boolean), + allowRepoCommands: args.includes('--allow-repo-commands'), ...gate, + failAfter: process.env.GSTACK_SHIP_QUEUE_FAIL_AFTER, + })); + } + if (cmd === 'verify') { + const record = flag(args, '--record'); + return finish('verify', verify(ctx, { + pr, gated: flag(args, '--gated'), record: record ? path.resolve(record) : undefined, receipt: flag(args, '--receipt'), + expectHead: flag(args, '--expect-head'), ref: flag(args, '--ref'), noFetch: args.includes('--no-fetch'), ...gate, + })); + } + return usage(`unknown subcommand ${cmd}`); +} + +process.exitCode = main(process.argv.slice(2)); diff --git a/bin/gstack-ship-receipt b/bin/gstack-ship-receipt index f8441f1a7..bd3baa6aa 100755 --- a/bin/gstack-ship-receipt +++ b/bin/gstack-ship-receipt @@ -6,7 +6,8 @@ * [--predecessor ] [--gate ] [--ci ] [--spend-usd ] * [--session-kind ] [--artifacts-consumed /] [--run ] [--thread ] * [--receipt ] [--policy