Give your AI agent
an inbox

import Anthropic from '@anthropic-ai/sdk';
import { Nuntly } from '@nuntly/sdk';

const anthropic = new Anthropic();
const nuntly = new Nuntly({ apiKey: process.env.NUNTLY_API_KEY });

// Called when Nuntly fires message.agent.triggered
export async function handleInbound(event: {
  messageId: string;
  from: string;
  subject: string;
}) {
  // Fetch full message content — no MIME parsing
  const content = await nuntly.inbound.messages.content(event.messageId);

  // Load thread context from agent memory
  const state = await nuntly.inbound.agents.memory.get({
    scope: 'thread',
    threadId: content.threadId,
  });

  // Process with your AI model
  const response = await anthropic.messages.create({
    model: 'claude-opus-4-6',
    max_tokens: 1024,
    system: 'You are a helpful customer support agent.',
    messages: [
      ...(state?.history ?? []),
      {
        role: 'user',
        content: `From: ${event.from}\nSubject: ${event.subject}\n\n${content.text}`,
      },
    ],
  });

  const reply = response.content[0].text;

  // Send the reply via Nuntly Reply API
  await nuntly.inbound.messages.reply(event.messageId, {
    subject: `Re: ${event.subject}`,
    html: `<p>${reply}</p>`,
  });

  // Persist conversation history in thread memory
  await nuntly.inbound.agents.memory.upsert({
    scope: 'thread',
    threadId: content.threadId,
    data: { history: [...(state?.history ?? []), { role: 'assistant', content: reply }] },
  });
}