Human in the
loop
AI agents

1import { mkdir, readdir, rm, writeFile } from "node:fs/promises";
2import { basename } from "node:path";
3import { createInterface } from "node:readline/promises";
4import { Agents, schema, tool } from "@camelai/run";
5
6// A throwaway folder for the agent to tidy.
7const dir = "playground";
8await mkdir(dir, { recursive: true });
9for (const f of ["notes.md", "build.log", "cache.tmp", "old-draft.tmp"]) await writeFile(`${dir}/${f}`, "x");
10
11const agents = new Agents();
12const agent = await agents.upsert("approval-ts", {
13  model: "openrouter/openai/gpt-6-luna",
14  instructions: "You tidy the user's playground folder with your tools.",
15  tools: {
16    list_files: tool({
17      description: "List the files in the playground",
18      input: schema.Object({}),
19      execute: () => readdir(dir),
20    }),
21    delete_file: tool({
22      description: "Delete a file from the playground",
23      input: schema.Object({ name: schema.String() }),
Waits here24      needsApproval: true, // the run stops and waits for a person before each call
25      execute: async ({ name }) => (await rm(`${dir}/${basename(name)}`), { deleted: name }),
26    }),
27  },
28});
29
30const cli = createInterface({ input: process.stdin, output: process.stdout });
31let run = await agent.run(process.argv.slice(2).join(" ") || "Delete the temporary files.", { user: "me" });
32while (run.status === "input_required") {
33  const input = run.inputs[0];
34  const yes = (await cli.question(`${input.message} ${input.detail.argumentsPreview ?? JSON.stringify(input.detail.arguments)} [y/N] `)).trim() === "y";
Answer35  run = await input.answer(yes, { from: "me" });
36}
37console.log(run.text, "\nleft:", await readdir(dir));
38cli.close();
39await agents.close();