ossrules.md

review-fetch-phase

Fetches canonical PR review state and renders derived state artifacts. Use when the user wants the state acquisition phase only (fetch, render, summarize) for a review-framework PR.

Install
npx skills add 'https://github.com/prisma/orm/tree/main/skills-contrib/review-fetch-phase'
Download bundle ↓
main · fac8604 ↗Scanned 2026-09-17

Contributors

GitHub-linked commit authors for this SKILL.md at the saved revision. Co-authors and history before file renames are not included.

File history ↗

scripts/fetch-review-state.mjs

scripts/fetch-review-state.mjsBrowse 11 files
View on GitHub
4,053 tokens

16,191 bytes
Token encoding: o200k_base
Snapshot fac8604

← Back to SKILL.md
#!/usr/bin/env node import { spawnSync } from 'node:child_process';import { realpathSync } from 'node:fs';import { mkdir, writeFile } from 'node:fs/promises';import { dirname, resolve } from 'node:path';import { fileURLToPath } from 'node:url';import { renderReviewStateMarkdown as renderReviewStateMarkdownImpl } from './render-review-state.mjs';import {  assertReviewStateV2,  formatCanonicalJson,  normalizeReviewStateV2,} from './review-artifacts.mjs'; const EXIT_SUCCESS = 0;const EXIT_OPERATIONAL = 1;const EXIT_CLI = 2; const SPAWN_MAX_BUFFER_BYTES = 16 * 1024 * 1024;const SUBPROCESS_TIMEOUT_MS = 30_000; const THREADS_QUERY = `  query($owner: String!, $repo: String!, $number: Int!, $threadsCursor: String) {    repository(owner: $owner, name: $repo) {      pullRequest(number: $number) {        id        url        number        title        state        headRefName        baseRefName        updatedAt        reviewThreads(first: 100, after: $threadsCursor) {          pageInfo { hasNextPage endCursor }          nodes {            id            isResolved            isOutdated            path            startLine            line            originalStartLine            originalLine            comments(first: 100) {              pageInfo { hasNextPage endCursor }              nodes {                id                url                author { login }                createdAt                body                reactionGroups { content users { totalCount } }              }            }          }        }      }    }  }`; const THREAD_COMMENTS_QUERY = `  query($threadId: ID!, $cursor: String) {    node(id: $threadId) {      ... on PullRequestReviewThread {        comments(first: 100, after: $cursor) {          pageInfo { hasNextPage endCursor }          nodes {            id            url            author { login }            createdAt            body            reactionGroups { content users { totalCount } }          }        }      }    }  }`; const REVIEWS_QUERY = `  query($owner: String!, $repo: String!, $number: Int!, $reviewsCursor: String) {    repository(owner: $owner, name: $repo) {      pullRequest(number: $number) {        reviews(first: 100, after: $reviewsCursor) {          pageInfo { hasNextPage endCursor }          nodes {            id            url            author { login }            state            submittedAt            body            reactionGroups { content users { totalCount } }          }        }      }    }  }`; const COMMENTS_QUERY = `  query($owner: String!, $repo: String!, $number: Int!, $commentsCursor: String) {    repository(owner: $owner, name: $repo) {      pullRequest(number: $number) {        comments(first: 100, after: $commentsCursor) {          pageInfo { hasNextPage endCursor }          nodes {            id            url            author { login }            createdAt            body            reactionGroups { content users { totalCount } }          }        }      }    }  }`; function getHelpText() {  return [    'Usage:',    '  fetch-review-state.mjs [--pr <url>] [--out <path.md>|-] [--out-json <path.json>|-] [--help]',    '',    'Purpose:',    '  Fetch unresolved review threads, submitted review bodies, and PR issue comments.',    '  Emit canonical review-state.json (v2 script-first schema). Markdown is derived output.',    '',    'Flags:',    '  --pr <url>          GitHub pull request URL (for example: https://github.com/OWNER/REPO/pull/123).',    '                      If omitted, the script attempts to discover the PR for the current git branch.',    '  --out <path.md>|-   Markdown output path. Use "-" to write markdown to stdout. Omit to skip markdown output.',    '  --out-json <path.json>|-',    '                      JSON output path. If omitted and --out is a file path, defaults to same path with .json.',    '  --help              Show this help text and exit.',  ].join('\n');} function parseCliArgs(argv) {  const args = argv.slice(2);  const result = { prUrl: null, outPath: null, outJsonPath: null, help: false };  if (args.includes('--help')) {    result.help = true;    return result;  }   const knownFlags = new Set(['--pr', '--out', '--out-json']);  let index = 0;  while (index < args.length) {    const arg = args[index];    if (!arg.startsWith('--') || !knownFlags.has(arg)) {      throw { code: EXIT_CLI, message: `error: unknown flag "${arg}"` };    }     index += 1;    if (index >= args.length) {      throw { code: EXIT_CLI, message: `error: ${arg} requires a value` };    }     const value = args[index];    if (arg === '--pr') {      result.prUrl = value;    } else if (arg === '--out') {      result.outPath = value;    } else if (arg === '--out-json') {      result.outJsonPath = value;    }    index += 1;  }   if (result.outPath !== null && result.outPath !== '-' && !result.outPath.endsWith('.md')) {    throw { code: EXIT_CLI, message: 'error: --out file path must end with .md' };  }  if (    result.outJsonPath !== null &&    result.outJsonPath !== '-' &&    !result.outJsonPath.endsWith('.json')  ) {    throw { code: EXIT_CLI, message: 'error: --out-json file path must end with .json' };  }  if (result.outPath === '-' && result.outJsonPath === '-') {    throw { code: EXIT_CLI, message: 'error: --out - cannot be combined with --out-json -' };  }   return result;} function renderReviewStateMarkdown(payload, options) {  return renderReviewStateMarkdownImpl(payload, options);} function parsePrUrl(url) {  if (typeof url !== 'string' || url.trim() === '') {    return null;  }   const match = url    .trim()    .match(/^https?:\/\/github\.com\/([^/]+)\/([^/]+)\/pull\/(\d+)(?:\/)?(?:#.*)?$/i);  if (!match) {    return null;  }   return {    owner: match[1],    repo: match[2].replace(/\.git$/, ''),    number: Number.parseInt(match[3], 10),  };} function runSync(command, args, input) {  const result = spawnSync(command, args, {    encoding: 'utf-8',    input: input ?? undefined,    maxBuffer: SPAWN_MAX_BUFFER_BYTES,    timeout: SUBPROCESS_TIMEOUT_MS,  });  if (result.error) {    let detail;    if (result.error.code === 'ETIMEDOUT') {      detail = `${command} timed out after ${SUBPROCESS_TIMEOUT_MS / 1000} seconds`;    } else if (result.error.code === 'ERR_CHILD_PROCESS_STDIO_MAXBUFFER') {      detail = `${command} output exceeded ${SPAWN_MAX_BUFFER_BYTES} bytes; raise SPAWN_MAX_BUFFER_BYTES`;    } else {      detail = `failed to execute ${command}: ${result.error.message}`;    }    return { stdout: '', stderr: detail, status: result.status ?? 1 };  }  if (result.signal) {    return {      stdout: result.stdout ?? '',      stderr: `${command} was terminated by signal ${result.signal}`,      status: result.status ?? 1,    };  }  return { stdout: result.stdout, stderr: result.stderr, status: result.status };} function checkPreconditions({ requireGit }) {  if (requireGit) {    const git = runSync('which', ['git']);    if (git.status !== 0) {      return { ok: false, code: EXIT_OPERATIONAL, message: 'error: git not found on PATH' };    }  }  const gh = runSync('which', ['gh']);  if (gh.status !== 0) {    return { ok: false, code: EXIT_OPERATIONAL, message: 'error: gh not found on PATH' };  }   const auth = runSync('gh', ['auth', 'status']);  if (auth.status !== 0) {    return {      ok: false,      code: EXIT_OPERATIONAL,      message: 'error: gh is not authenticated; run "gh auth login" and try again',    };  }   return { ok: true };} function getCurrentBranch() {  const result = runSync('git', ['rev-parse', '--abbrev-ref', 'HEAD']);  if (result.status !== 0) {    return null;  }  return result.stdout.trim();} function discoverPrUrl(branchName) {  const result = runSync('gh', [    'pr',    'list',    '--head',    branchName,    '--state',    'all',    '--json',    'url',  ]);   if (result.status !== 0) {    return { code: EXIT_OPERATIONAL, error: 'error: gh pr list failed' };  }   let list;  try {    list = JSON.parse(result.stdout);  } catch {    return { code: EXIT_OPERATIONAL, error: 'error: gh pr list returned invalid JSON' };  }   if (!Array.isArray(list) || list.length === 0) {    return {      code: EXIT_OPERATIONAL,      error: `error: no pull request found for current branch "${branchName}"; pass --pr <url>`,    };  }   if (list.length > 1) {    return {      code: EXIT_OPERATIONAL,      error: `error: multiple pull requests found for current branch "${branchName}"; pass --pr <url>`,    };  }   return { url: list[0].url };} function fetchGraphQL(query, variables) {  const body = JSON.stringify({ query, variables });  const result = runSync('gh', ['api', 'graphql', '--input', '-'], body);  if (result.status !== 0) {    return { code: EXIT_OPERATIONAL, error: result.stderr || 'error: GitHub API request failed' };  }   try {    const parsed = JSON.parse(result.stdout);    if (Array.isArray(parsed?.errors) && parsed.errors.length > 0) {      const messages = parsed.errors        .map((err) =>          typeof err?.message === 'string' && err.message.length > 0            ? err.message            : JSON.stringify(err),        )        .join('; ');      return {        code: EXIT_OPERATIONAL,        error: `error: GitHub GraphQL returned errors: ${messages}`,      };    }    return { data: parsed };  } catch {    return { code: EXIT_OPERATIONAL, error: 'error: GitHub API returned invalid JSON' };  }} function paginateConnection(owner, repo, number, query, cursorVar, cursorValue) {  const response = fetchGraphQL(query, {    owner,    repo,    number,    [cursorVar]: cursorValue ?? null,  });   if (response.error) {    return response;  }   const pr = response.data?.data?.repository?.pullRequest;  if (!pr) {    return { code: EXIT_OPERATIONAL, error: 'error: pull request not found in GraphQL response' };  }   return { pr };} function paginateThreadComments(threadId, cursor) {  const response = fetchGraphQL(THREAD_COMMENTS_QUERY, { threadId, cursor: cursor ?? null });  if (response.error) {    return response;  }  const connection = response.data?.data?.node?.comments;  if (!connection) {    return {      code: EXIT_OPERATIONAL,      error: 'error: thread comments connection missing in GraphQL response',    };  }  return { connection };} function paginateAll(owner, repo, number) {  let pr = null;  let reviewThreads = [];  let threadCursor = null;   for (;;) {    const page = paginateConnection(      owner,      repo,      number,      THREADS_QUERY,      'threadsCursor',      threadCursor,    );    if (page.error) {      return page;    }    pr = page.pr;    const connection = page.pr.reviewThreads;    reviewThreads = reviewThreads.concat(connection?.nodes ?? []);    if (!connection?.pageInfo?.hasNextPage) {      break;    }    threadCursor = connection.pageInfo.endCursor;  }   for (const thread of reviewThreads) {    let commentCursor = thread?.comments?.pageInfo?.endCursor ?? null;    while (thread?.comments?.pageInfo?.hasNextPage) {      const next = paginateThreadComments(thread.id, commentCursor);      if (next.error) {        return next;      }      thread.comments.nodes = (thread.comments.nodes ?? []).concat(next.connection.nodes ?? []);      thread.comments.pageInfo = next.connection.pageInfo ?? {        hasNextPage: false,        endCursor: null,      };      commentCursor = thread.comments.pageInfo.endCursor;    }  }   let reviews = [];  let reviewCursor = null;  for (;;) {    const page = paginateConnection(      owner,      repo,      number,      REVIEWS_QUERY,      'reviewsCursor',      reviewCursor,    );    if (page.error) {      return page;    }    const connection = page.pr.reviews;    reviews = reviews.concat(connection?.nodes ?? []);    if (!connection?.pageInfo?.hasNextPage) {      break;    }    reviewCursor = connection.pageInfo.endCursor;  }   let issueComments = [];  let commentsCursor = null;  for (;;) {    const page = paginateConnection(      owner,      repo,      number,      COMMENTS_QUERY,      'commentsCursor',      commentsCursor,    );    if (page.error) {      return page;    }    const connection = page.pr.comments;    issueComments = issueComments.concat(connection?.nodes ?? []);    if (!connection?.pageInfo?.hasNextPage) {      break;    }    commentsCursor = connection.pageInfo.endCursor;  }   return {    pr,    reviewThreads,    reviews,    issueComments,  };} function deriveOutJsonPath(outPath, outJsonPath) {  if (outJsonPath) {    return outJsonPath;  }  if (!outPath || outPath === '-') {    return null;  }  return outPath.replace(/\.md$/i, '.json');} async function writeOutput(outPath, text) {  if (!outPath || outPath === '-') {    process.stdout.write(text);    return;  }  await mkdir(dirname(outPath), { recursive: true });  await writeFile(outPath, text, 'utf8');} async function main() {  let options;  try {    options = parseCliArgs(process.argv);  } catch (error) {    process.stderr.write(`${error.message}\n`);    process.exit(error.code ?? EXIT_CLI);  }   if (options.help) {    process.stdout.write(`${getHelpText()}\n`);    process.exit(EXIT_SUCCESS);  }   const preconditions = checkPreconditions({ requireGit: !options.prUrl });  if (!preconditions.ok) {    process.stderr.write(`${preconditions.message}\n`);    process.exit(preconditions.code);  }   let prUrl = options.prUrl;  let sourceBranch = null;  if (!prUrl) {    sourceBranch = getCurrentBranch();    if (!sourceBranch || sourceBranch === 'HEAD') {      process.stderr.write(        'error: cannot discover PR when in detached HEAD state; pass --pr <url>\n',      );      process.exit(EXIT_OPERATIONAL);    }    const discovered = discoverPrUrl(sourceBranch);    if (discovered.error) {      process.stderr.write(`${discovered.error}\n`);      process.exit(discovered.code ?? EXIT_OPERATIONAL);    }    prUrl = discovered.url;  }   const parsedPr = parsePrUrl(prUrl);  if (!parsedPr) {    process.stderr.write(      'error: invalid --pr value (expected GitHub PR URL like https://github.com/OWNER/REPO/pull/123)\n',    );    process.exit(EXIT_CLI);  }   if (!sourceBranch) {    sourceBranch = getCurrentBranch();    if (sourceBranch === 'HEAD') {      sourceBranch = null;    }  }   const payload = paginateAll(parsedPr.owner, parsedPr.repo, parsedPr.number);  if (payload.error) {    process.stderr.write(`${payload.error}\n`);    process.exit(payload.code ?? EXIT_OPERATIONAL);  }   const fetchedAt = new Date().toISOString();  const reviewState = normalizeReviewStateV2({    fetchedAt,    sourceBranch,    pr: payload.pr,    reviewThreads: payload.reviewThreads,    reviews: payload.reviews,    issueComments: payload.issueComments,  });  assertReviewStateV2(reviewState);   const jsonText = formatCanonicalJson(reviewState);  const outJsonPath = deriveOutJsonPath(options.outPath, options.outJsonPath);  const markdown = renderReviewStateMarkdown(reviewState, {    sourcePath: outJsonPath && outJsonPath !== '-' ? outJsonPath : undefined,  });   if (options.outPath !== null) {    await writeOutput(options.outPath, markdown);  }  if (outJsonPath) {    await writeOutput(outJsonPath, jsonText);  }   process.exit(EXIT_SUCCESS);} const isMain = (function computeIsMain() {  try {    const invokedScriptPath = process.argv[1] ? realpathSync(resolve(process.argv[1])) : null;    const currentModulePath = realpathSync(fileURLToPath(import.meta.url));    return invokedScriptPath !== null && invokedScriptPath === currentModulePath;  } catch {    return false;  }})(); if (isMain) {  main().catch((error) => {    const message = error?.message ? String(error.message) : String(error);    process.stderr.write(`${message}\n`);    process.exit(EXIT_OPERATIONAL);  });} export { deriveOutJsonPath, parseCliArgs, parsePrUrl, renderReviewStateMarkdown };
Referenced from SKILL.md
SKILL.mdView in source ↗
Source excerpt starting at line 42.
```bashnode ./scripts/fetch-review-state.mjs --pr <PR_URL> --out-json <output-dir>/review-state.json```
← All Prisma ORM skillsProject instructions →