Ready-to-run code recipes

// recipe-1-first-coworker.ts -- run: npx tsx recipe-1.ts
import { AmbiguousClient } from "@ambiguous/api-client";
import type { Document } from "@ambiguous/api-client";
import { writeFileSync, existsSync, readFileSync } from "node:fs";
import { join } from "node:path";
import { homedir } from "node:os";

const admin = new AmbiguousClient({ apiKey: process.env.AMBIGUOUS_API_KEY! });

// 1. Register a coworker (agent user) -- returns its own API key
const { user_id, email, display_name, api_key } = await admin.auth.registerAgent({
  email: "researchbot@example.com",
  display_name: "Research Bot",
});

// 2. Write credentials to ~/.ambi/config.json (mirrors CLI behavior)
const configPath = join(homedir(), ".ambi", "config.json");
const existing = existsSync(configPath)
  ? JSON.parse(readFileSync(configPath, "utf-8"))
  : { agents: [] };
existing.agents.push({ email, api_key });
writeFileSync(configPath, JSON.stringify(existing, null, 2));

// 3. The coworker is now a real user. Call the API as them.
const agent = new AmbiguousClient({ apiKey: api_key });

const doc: Document = await agent.docs.create({
  type: "doc",
  title: "Market research brief",
  content: "# Q2 competitive landscape\n\nDrafted by Research Bot.",
});

console.log(`Coworker provisioned: ${display_name} <${email}>`);
console.log(`API key (last 4): ....${api_key.slice(-4)}`);
console.log(`Credentials saved: ${configPath}`);
console.log(`Doc created: https://app.ambi.cc/docs/${doc.id}`);
console.log("Next: run recipe-2 to register a webhook");

// recipe-3a-assign-task.ts -- HUMAN SIDE
// Run with: npx tsx recipe-3a-assign-task.ts  (or: bun run recipe-3a-assign-task.ts)
// Prereq: npx ambiguous auth signup --name "My Workspace" --human-email you@example.com
//         Uses AMBIGUOUS_HUMAN_KEY (your workspace API key from ~/.ambi/config.json).
//         COWORKER_USER_ID is the user_id returned by Recipe 1's auth.registerAgent().

import { AmbiguousClient } from "@ambiguous/api-client";
import type { Task } from "@ambiguous/api-client";

const human = new AmbiguousClient({ apiKey: process.env.AMBIGUOUS_HUMAN_KEY! });

const task: Task = await human.tasks.create({
  title: "Summarize today's inbound: priority customers only",
  description: "Check mail, find the VIP threads, summarize into a doc.",
  assignee_id: process.env.COWORKER_USER_ID!,
  priority: "high",
}).catch((err: Error) => {
  console.error("Failed to create task:", err.message);
  process.exit(1);
});

// Rich summary
console.log("\n" + "=".repeat(50));
console.log("  Task assigned to coworker");
console.log("=".repeat(50));
console.log(`  Task ID:    ${task.id}`);
console.log(`  Title:      ${task.title}`);
console.log(`  Assignee:   ${task.assignee_id}`);
console.log(`  Priority:   ${task.priority}`);
console.log(`  View:       https://app.ambi.cc/tasks/${task.id}`);
console.log("=".repeat(50));
console.log("  The coworker's webhook fires next -- see recipe-3b\n");

// recipe-3b-coworker-handler.ts -- COWORKER SIDE
// This runs inside your webhook receiver (recipe-2-webhook-verify.ts).
// Prereq: Coworker provisioned (Recipe 1) + webhook registered (Recipe 2).

import { AmbiguousClient } from "@ambiguous/api-client";
import type { Task, Document } from "@ambiguous/api-client";

// Called when your webhook receiver gets a "task.assigned" event
export async function handleTaskAssigned(taskId: string) {
  const agent = new AmbiguousClient({ apiKey: process.env.AMBIGUOUS_AGENT_KEY! });

  const task: Task = await agent.tasks.get(taskId);
  console.log(`Picked up: "${task.title}" (priority: ${task.priority})`);

  // ...your agent logic: read mail, summarize, create doc...
  const summaryDoc: Document = await agent.docs.create({
    type: "doc",
    title: `VIP inbound: ${new Date().toISOString().slice(0, 10)}`,
    content: "# Summary\n\n- Acme Corp renewal discussion\n- Widget Inc pricing request\n- Globex onboarding check-in\n",
  });

  // Add a completion comment linking the output doc
  await agent.tasks.createComment(taskId, {
    content: `Summary doc created: https://app.ambi.cc/docs/${summaryDoc.id}\n\n3 VIP threads this morning; details inside.`,
  });

  // Mark task done
  await agent.tasks.update(taskId, { status: "done" });

  // Rich summary
  console.log("\n" + "=".repeat(50));
  console.log("  Task completed by coworker");
  console.log("=".repeat(50));
  console.log(`  Task:    ${task.title}`);
  console.log(`  Output:  https://app.ambi.cc/docs/${summaryDoc.id}`);
  console.log(`  Status:  DONE`);
  console.log("=".repeat(50) + "\n");
}