Stream events and retrieve results

import { HarnessEventGapError, type RunHandle } from "@agentium/harness";

export async function observe(handle: RunHandle, after = 0) {
  try {
    for await (const event of handle.events({ after })) {
      console.log(event.sequence, event.payload.type);
      after = event.sequence;
    }
  } catch (error) {
    if (!(error instanceof HarnessEventGapError)) throw error;
    // The client missed retained events. Replace its partial view with a
    // settled result, rather than presenting an incomplete stream as complete.
    console.log("Replay gap; earliest usable cursor:", error.earliestCursor);
  }
  return handle.result();
}

import type { HarnessIdentity, HarnessResult, HarnessRuntime } from "@agentium/harness";

export function resultArtifacts(
  runtime: HarnessRuntime,
  identity: HarnessIdentity,
  result: HarnessResult,
) {
  return (result.artifacts ?? []).map(({ id }) => ({
    id,
    value: runtime.getArtifact(identity, result.sessionId, id),
  }));
}