veryfront/run-events

import {
  assertRunEventSchemaValidator,
  fromRunEventWireName,
  getRunEventClass,
  isRunEventType,
  parseTypedRunEventRow,
  toRunEventWireName,
} from "veryfront/run-events";

import { register, tryResolve } from "veryfront/extensions/contracts";
import { createZodAdapter } from "@veryfront/ext-schema-zod";
import {
  isRunEventType,
  parseTypedRunEventRow,
  RUN_EVENT_PAYLOAD_SCHEMAS,
} from "veryfront/run-events";

// Register a validator only when nothing has: outside a Veryfront app this
// installs the Zod adapter, inside one it keeps the validator bootstrap owns.
if (!tryResolve("SchemaValidator")) {
  register("SchemaValidator", createZodAdapter());
}

const apiUrl = "https://api.veryfront.example";
const runId = "<RUN_ID>";
const token = "<TOKEN>";

const response = await fetch(`${apiUrl}/runs/${runId}/events?format=typed`, {
  headers: { Authorization: `Bearer ${token}` },
});
const body = await response.json() as { data: unknown[] };

for (const raw of body.data) {
  const row = parseTypedRunEventRow(raw);
  if (!isRunEventType(row.event_type)) {
    // A type this build predates: the envelope is still valid, so keep the
    // row and render its raw payload rather than dropping it.
    console.log(row.event_type, row.span_id, row.payload);
    continue;
  }
  // The sixteen control-plane `AGENT_RUN_*` types have no payload schema:
  // the API owns their shape and sanitizes it before a reader ever sees
  // it, so fall back to the already-validated raw payload for those.
  const schema = RUN_EVENT_PAYLOAD_SCHEMAS[row.event_type];
  const result = schema?.().safeParse(row.payload);
  console.log(row.event_type, row.span_id, result?.success ? result.data : row.payload);
}