SDK

import { Client, Machine } from "@indexable/sdk"

// A machine for this agent, removed
// when this scope ends.
await using machine = await Machine.create({
  image: "ix/debian:12",
  name: "agent-7",
  lifetime: "ephemeral",
})
await machine.writeFile("/task.md", prompt)
const run = await machine.exec(["./agent", "/task.md"], { check: true })
console.log(run.stdout)

// Every restore is a new machine.
const snap = await machine.snapshot()
const snapshots = new Client().snapshots
const forks = await Promise.all(
  ["a", "b", "c"].map((n) =>
    snapshots.restore(snap.snapshotId, `agent-7-${n}`),
  ),
)

const ix = new Client()

// Ephemeral: removed when the scope ends.
await using scratch = await ix.machines.create({ lifetime: "ephemeral" })

// A deadline: the platform removes it after 20 minutes,
// even if this process dies first.
const ci = await ix.machines.create({
  ttl: "20m",
  name: "ci-run-418",
})

// Persistent, the default: scope exit only releases the handle.
await using dev = await ix.machines.create({ name: "dev" })
const again = await ix.machines.connect("dev")

// exec returns at once. Read the output while it runs.
const proc = machine.exec(["npm", "test"])
for await (const chunk of proc.stdout) process.stdout.write(chunk)
const { exitCode } = await proc

// Write to stdin.
const sort = machine.exec(["sort"], { stdin: true })
await sort.stdin.write("b\na\n")
await sort.stdin.close()
console.log((await sort).stdout)

// Stop a command.
const slow = machine.exec(["sleep", "600"])
setTimeout(() => slow.kill(), 5000)
await slow