Function collectClawSweeperEvents

src/repair/notify-events.ts:100–147

({
  applyRows,
  runRecord,
  ledger,
  runId,
}: {
  applyRows: JsonValue;
  runRecord?: JsonValue | null;
  ledger: ClawSweeperEventLedger;
  runId?: string | undefined;
})

}

export function collectClawSweeperEvents({
  applyRows,
  runRecord,
  ledger,
  runId,
}: {
  applyRows: JsonValue;
  runRecord?: JsonValue | null;
  ledger: ClawSweeperEventLedger;
  runId?: string | undefined;
}): { considered: number; events: ClawSweeperEvent[]; skipped: JsonObject[] } {
  const seen = new Set(ledger.notifications.map((entry) => entry.key));
  const events: ClawSweeperEvent[] = [];
  const skipped: JsonObject[] = [];
  let considered = 0;

  for (const raw of Array.isArray(applyRows) ? applyRows : []) {
    const row = asJsonObject(raw);
    if (runId && stringOrNull(row.run_id) !== runId) continue;
    const event = buildApplyEvent(row);
    if (!event) continue;
    considered += 1;
    if (seen.has(event.key)) {
      skipped.push(skippedRow(event, "notification already sent"));
      continue;
    }
    seen.add(event.key);
    events.push(event);
  }

  const record = asJsonObject(runRecord);
  const recordRunId = stringOrNull(record.run_id);
  if (Object.keys(record).length > 0 && (!runId || !recordRunId || recordRunId === runId)) {
    for (const raw of Array.isArray(record.fix_actions) ? record.fix_actions : []) {
      const event = buildFixEvent(asJsonObject(raw), record);
      if (!event) continue;
      considered += 1;
      if (seen.has(event.key)) {
        skipped.push(skippedRow(event, "notification already sent"));
        continue;
      }
      seen.add(event.key);
      events.push(event);
    }
  }

  return { considered, events, skipped };
}

export function buildApplyEvent(row: JsonObject): ClawSweeperEvent | null {
  const action = stringOrNull(row.action);