Function ingestCodexReview

core/codex/native-integrations.js:386–452

(options = {})

  const hint = String(authorHint || 'codex').toLowerCase();
  return author.includes(hint) || body.includes('@codex') || body.includes('codex review');
}

function severityForBody(body) {
  const match = String(body || '').match(/\b(P0|P1|P2|P3)\b/i);
  return match ? match[1].toUpperCase() : null;
}

function ingestCodexReview(options = {}) {
  const projectRoot = path.resolve(options.projectRoot || process.cwd());
  const repo = options.repo || 'current-repo';
  const prNumber = options.prNumber || options.pr || 'current';
  const authorHint = options.authorHint || 'codex';
  const raw = typeof options.input === 'string' ? JSON.parse(options.input) : (options.input || []);
  const allItems = normalizeReviewItems(raw);
  const findings = allItems
    .filter((item) => looksLikeCodexReviewItem(item, authorHint))
    .map((item) => {
      const body = itemBody(item);
      return {
        id: item.id || item.node_id || null,
        source: item.source || item.type || 'github-review',
        author: itemAuthor(item),
        severity: severityForBody(body),
        path: item.path || null,
        line: item.line || item.original_line || null,
        url: item.html_url || item.url || null,
        body,
      };
    });

  const counts = findings.reduce((acc, finding) => {
    const key = finding.severity || 'unclassified';
    acc[key] = (acc[key] || 0) + 1;
    return acc;
  }, {});

  const nextActions = [];
  if ((counts.P0 || 0) + (counts.P1 || 0) > 0) {
    nextActions.push('Run local Citadel verification before merge.');
    nextActions.push(`Consider commenting "@codex fix the P1/P0 issue" only after confirming the finding belongs.`);
  }
  if (findings.length === 0) {
    nextActions.push('No Codex review findings were detected in the provided input.');
  }

  const result = {
    repo,
    prNumber,
    source: 'codex-github-review',
    ingestedAt: nowIso(options),
    totalItems: allItems.length,
    codexItems: findings.length,
    counts,
    findings,
    nextActions,
  };

  if (options.write) {