Tools that come apart.
On purpose.

1import { readFile } from "node:fs/promises";2import { resolve } from "node:path";3import { agent, artifact, monitor, step } from "@foundry.sh/marbles";4import { z } from "zod";5 61// Another workflow collects reports and appends them to incidents.md.7// This one watches that file and decides what happens next.8 92const triage = agent({10  provider: "codex",11  prompt: `Is the last entry in this file an incident?12    Reply with JSON only: {"isIncident": boolean, "reason": string}`,13});14 15const verdict = z.object({ isIncident: z.boolean(), reason: z.string() });16const brief = artifact({ name: "investigation-brief", type: "text/markdown" });17 18const assess = step("assess")19  .input(z.object({ entry: z.string() }))20  .do(async ({ input: { entry }, agents, report, log }) => {21    const session = await agents.session(triage);22    const reply = await session.generate(entry);23    const { isIncident, reason } = verdict.parse(JSON.parse(reply.text));24 253    if (!isIncident) {26      log(`Not an incident: ${reason}`);27      return { isIncident };28    }29 30    const draft = await session.generate("Write an investigation brief.");31    await report.artifact(brief, { "brief.md": draft.text });32    return { isIncident };33  });34 354monitor("incidents.md")36  .every("1m")37  .do(async ({ files, workspaces }) => {38    if (!files?.modified.length) return;39    const path = resolve(workspaces.current.root, "incidents.md");40    return assess({}, { entry: await readFile(path, "utf8") });41  });