Reproduce CI Failures and Open Pull Requests Automatically

Read the newest CI failure mail in your inbox, reproduce it on a small machine
with a 20-minute window, and tell me the failing test and the likely cause.
Stop the machine when you are done.

import { AgentLoadout } from "@agent-loadout/sdk";

const agent = new AgentLoadout({ apiKey: process.env.AGENT_LOADOUT_TOKEN! });
const [inbox] = await agent.inboxes.list();

for await (const event of agent.events.subscribe(inbox.id, { types: ["message.received"] })) {
  const message = await agent.messages.get(String(event.data.message_id));
  if (!message.from.address.endsWith("@ci.example") || message.screening?.verdict !== "clean") continue;

  let machine = await agent.machines.create({ size: "small", ttl_seconds: 1200, name: "ci-fix" });
  try {
    const deadline = Date.now() + 5 * 60_000;
    while (machine.state === "provisioning" && Date.now() < deadline) {
      await new Promise(resolve => setTimeout(resolve, 2000));
      machine = await agent.machines.get(machine.id);
    }
    if (machine.state !== "ready") throw new Error(`Machine is not ready: ${machine.state}`);

    // Replace this URL with your repository. Private repositories also need authentication.
    const result = await agent.machines.run(machine.id, { command: "git clone https://github.com/acme/app && cd app && bun install && bun test", timeout_seconds: 600 });
    await agent.messages.reply(message.id, { text: result.exit_code === 0 ? "Passes on a clean machine." : `Reproduced:\n${result.stderr.slice(-2000)}`, idempotency_key: `ci-${message.id}` });
    await agent.threads.update(message.thread_id, { add_labels: ["ci"], read: true });
  } finally {
    await agent.machines.stop(machine.id);
  }
}

agent-loadout events tail inb_… | jq -r 'select(.type=="message.received") | .data.message_id'
agent-loadout machines create --size small --ttl 1200 --name ci-fix
agent-loadout machines run mch_… --command "cd app && bun test" --timeout 600
agent-loadout machines stop mch_…