Claude Managed Agents (Beta)

import Anthropic from "@anthropic-ai/sdk";
import { createRaindropClaudeManagedAgents } from "@raindrop-ai/claude-managed-agents";

// 1. Create the Raindrop client
const raindrop = createRaindropClaudeManagedAgents({
  writeKey: process.env.RAINDROP_WRITE_KEY,  // Optional
  userId: "user_123",
});

// 2. Wrap the Anthropic SDK
const wrapped = raindrop.wrap(new Anthropic());

// 3. Use the SDK normally — sessions are tracked automatically
const session = await wrapped.beta.sessions.create({
  agent: agentId,
  environment_id: envId,
  title: "My session",
});

const stream = await wrapped.beta.sessions.events.stream(session.id);

await wrapped.beta.sessions.events.send(session.id, {
  events: [
    {
      type: "user.message",
      content: [{ type: "text", text: "List files in the current directory" }],
    },
  ],
});

for await (const event of stream) {
  if (event.type === "agent.message") {
    for (const block of event.content) {
      process.stdout.write(block.text);
    }
  } else if (event.type === "session.status_idle") {
    break;
  }
}

// 4. Flush before shutdown
await raindrop.shutdown();

const raindrop = createRaindropClaudeManagedAgents({
  writeKey: "your-write-key",   // Optional — omitting disables telemetry
  userId: "user_123",           // Default user ID for all sessions
  convoId: "conv_456",          // Default conversation ID
  projectId: "support-prod",    // Optional: route events to a specific project (slug)
  eventName: "managed_agent_session",  // Default event name

  traces: {
    enabled: true,              // Default: true
    debug: false,               // Logs trace shipping
  },

  events: {
    enabled: true,              // Default: true
    debug: false,               // Logs event shipping
  },
});

const raindrop = createRaindropClaudeManagedAgents({
  writeKey: "your-write-key",
  projectId: "support-prod",
});

const wrapped = raindrop.wrap(client, {
  userId: "different_user",
  convoId: "specific_conversation",
  properties: { environment: "production", tier: "enterprise" },
});

await raindrop.users.identify({
  userId: "user_123",
  traits: {
    email: "user@example.com",
    plan: "pro",
    orgId: "org_456",
  },
});

await raindrop.signals.track({
  name: "thumbs_up",
  type: "feedback",
  sentiment: "POSITIVE",
  comment: "Agent handled the task well",
});

// Thumbs down with comment
await raindrop.signals.track({
  name: "thumbs_down",
  type: "feedback",
  sentiment: "NEGATIVE",
  comment: "Agent used the wrong tool",
});

// User edit
await raindrop.signals.track({
  name: "user_edit",
  type: "edit",
  after: "The corrected response text",
});

// Add properties
await raindrop.events.setProperties(eventId, {
  latencyMs: 1234,
  cached: true,
});

// Add attachments
await raindrop.events.addAttachments(eventId, [
  {
    type: "code",
    name: "generated.py",
    value: "print('hello')",
    role: "output",
    language: "python",
  },
]);

// Mark as complete (triggers immediate shipping)
await raindrop.events.finish(eventId);

// Serverless: flush at end of request
await raindrop.flush();

// Long-running: shutdown gracefully
process.on("SIGTERM", async () => {
  await raindrop.shutdown();
  process.exit(0);
});

const raindrop = createRaindropClaudeManagedAgents({
  writeKey: process.env.RAINDROP_WRITE_KEY,
  events: { debug: true },
  traces: { debug: true },
});

RAINDROP_AI_DEBUG=1 node your-script.js

const raindrop = createRaindropClaudeManagedAgents({
  writeKey: process.env.RAINDROP_WRITE_KEY,
  userId: "user_123",
  selfDiagnostics: {
    // Default signals (used when `signals` is omitted):
    signals: {
      missing_context: {
        description: "Critical information or access is missing and the user cannot provide it.",
        sentiment: "NEGATIVE",
      },
      repeatedly_broken_tool: {
        description: "A tool has failed on multiple attempts, preventing task completion.",
        sentiment: "NEGATIVE",
      },
      capability_gap: {
        description: "The task requires a capability you do not have.",
        sentiment: "NEGATIVE",
      },
      complete_task_failure: {
        description: "You tried and failed to deliver what the user asked.",
        sentiment: "NEGATIVE",
      },
    },
  },
});

// IMPORTANT: create the agent through the wrapped client so the tool is injected
const wrapped = raindrop.wrap(new Anthropic());
const agent = await wrapped.beta.agents.create({
  name: "My Agent",
  model: "claude-sonnet-4-6",
  tools: [{ type: "agent_toolset_20260401" }],
});

{
  "signal_name": "self diagnostics - missing_context",
  "signal_type": "agent",
  "properties": {
    "category": "missing_context",
    "detail": "User asked to fix deployment but no access to logs."
  }
}