Function buildApplyEvent

src/repair/notify-events.ts:149–224

(row: JsonObject)

}

export function buildApplyEvent(row: JsonObject): ClawSweeperEvent | null {
  const action = stringOrNull(row.action);
  const status = stringOrNull(row.status);
  const repo = stringOrNull(row.repo);
  if (!action || !status || !repo) return null;

  const reason = stringOrNull(row.reason);
  const target = normalizeTarget(row.target);
  const title = stringOrNull(row.title);
  const runId = stringOrNull(row.run_id);
  const runUrl = stringOrNull(row.run_url);
  const clusterId = stringOrNull(row.cluster_id);
  const publishedAt = stringOrNull(row.published_at);
  const commit = stringOrNull(row.merge_commit_sha);
  const base = {
    repo,
    target,
    title,
    runId,
    runUrl,
    clusterId,
    publishedAt,
    action,
    status,
    reason,
  };

  if (MERGE_ACTIONS.has(action)) {
    if (status === "executed") {
      if (reason?.toLowerCase() === "already merged") return null;
      return createEvent({
        ...base,
        type: "clawsweeper.pr_merged",
        severity: "info",
        url: target ? `https://github.com/${repo}/pull/${target.slice(1)}` : null,
        discriminator: commit ?? stringOrNull(row.merged_at) ?? publishedAt ?? runId,
        details: row,
      });
    }
    if (["blocked", "failed"].includes(status)) {
      return createEvent({
        ...base,
        type: "clawsweeper.merge_blocked",
        severity: status === "failed" ? "error" : "warning",
        url: target ? `https://github.com/${repo}/pull/${target.slice(1)}` : null,
        discriminator: reason ?? publishedAt ?? runId,
        details: row,
      });
    }
  }

  if (CLOSE_ACTIONS.has(action)) {
    if (status === "executed") {
      return createEvent({
        ...base,
        type: "clawsweeper.item_closed",
        severity: "info",
        url: target ? `https://github.com/${repo}/issues/${target.slice(1)}` : null,