Send from the Claude Agent SDK

import { createSdkMcpServer, query, tool } from "@anthropic-ai/claude-agent-sdk";
import { randomUUID } from "node:crypto";
import Courier from "@trycourier/courier";
import { z } from "zod";

// Reads COURIER_API_KEY from the environment.
const courier = new Courier();

const sendTicketUpdate = tool(
  "send_ticket_update",
  "Tell a customer that their support ticket changed status.",
  {
    user_id: z.string().describe("The customer's Courier user ID"),
    ticket_id: z.string().describe("The support ticket ID"),
    status: z.enum(["in_progress", "resolved"]),
  },
  async ({ user_id, ticket_id, status }) => {
    const { requestId } = await courier.send.message({
      message: {
        to: { user_id },
        template: "nt_01kx4h2jdafq8bk9aftxak4b40",
        data: { ticket_id, status },
      },
      "Idempotency-Key": randomUUID(),
    });
    return { content: [{ type: "text", text: `Sent. requestId: ${requestId}` }] };
  },
);

const notifications = createSdkMcpServer({
  name: "notifications",
  version: "1.0.0",
  tools: [sendTicketUpdate],
});

for await (const message of query({
  prompt: "Ticket T-4521 for user_123 is resolved. Let the customer know.",
  options: {
    systemPrompt: "You are a support agent. Tell customers when their ticket changes status, then reply with the requestId.",
    mcpServers: { notifications },
    tools: [],
    allowedTools: ["mcp__notifications__send_ticket_update"],
  },
})) {
  if (message.type === "result" && message.subtype === "success") {
    console.log(message.result);
  }
}

import asyncio
import uuid
from typing import Any

from claude_agent_sdk import (
    ClaudeAgentOptions,
    ResultMessage,
    create_sdk_mcp_server,
    query,
    tool,
)
from courier import AsyncCourier

# Reads COURIER_API_KEY from the environment.
courier = AsyncCourier()


@tool(
    "send_ticket_update",
    "Tell a customer that their support ticket changed status.",
    {
        "type": "object",
        "properties": {
            "user_id": {"type": "string", "description": "The customer's Courier user ID"},
            "ticket_id": {"type": "string", "description": "The support ticket ID"},
            "status": {"type": "string", "enum": ["in_progress", "resolved"]},
        },
        "required": ["user_id", "ticket_id", "status"],
    },
)
async def send_ticket_update(args: dict[str, Any]) -> dict[str, Any]:
    response = await courier.send.message(
        message={
            "to": {"user_id": args["user_id"]},
            "template": "nt_01kx4h2jdafq8bk9aftxak4b40",
            "data": {"ticket_id": args["ticket_id"], "status": args["status"]},
        },
        idempotency_key=str(uuid.uuid4()),
    )
    return {"content": [{"type": "text", "text": f"Sent. requestId: {response.request_id}"}]}


notifications = create_sdk_mcp_server(
    name="notifications",
    version="1.0.0",
    tools=[send_ticket_update],
)


async def main() -> None:
    options = ClaudeAgentOptions(
        system_prompt="You are a support agent. Tell customers when their ticket changes status, then reply with the requestId.",
        mcp_servers={"notifications": notifications},
        tools=[],
        allowed_tools=["mcp__notifications__send_ticket_update"],
    )
    async for message in query(
        prompt="Ticket T-4521 for user_123 is resolved. Let the customer know.",
        options=options,
    ):
        if isinstance(message, ResultMessage) and message.subtype == "success":
            print(message.result)


if __name__ == "__main__":
    asyncio.run(main())

import { query } from "@anthropic-ai/claude-agent-sdk";

for await (const message of query({
  prompt: "Ticket T-4521 for user_123 is resolved. Let the customer know.",
  options: {
    systemPrompt:
      "You are a support agent. To notify a customer, send the published Courier template nt_01kx4h2jdafq8bk9aftxak4b40 with ticket_id and status in data, then reply with the requestId.",
    mcpServers: {
      courier: {
        type: "http",
        url: "https://mcp.courier.com",
        headers: { api_key: process.env.COURIER_API_KEY! },
      },
    },
    tools: [],
    allowedTools: ["mcp__courier__send_message_template"],
  },
})) {
  if (message.type === "result" && message.subtype === "success") {
    console.log(message.result);
  }
}

import asyncio
import os

from claude_agent_sdk import ClaudeAgentOptions, ResultMessage, query


async def main() -> None:
    options = ClaudeAgentOptions(
        system_prompt=(
            "You are a support agent. To notify a customer, send the published "
            "Courier template nt_01kx4h2jdafq8bk9aftxak4b40 with ticket_id and "
            "status in data, then reply with the requestId."
        ),
        mcp_servers={
            "courier": {
                "type": "http",
                "url": "https://mcp.courier.com",
                "headers": {"api_key": os.environ["COURIER_API_KEY"]},
            }
        },
        tools=[],
        allowed_tools=["mcp__courier__send_message_template"],
    )
    async for message in query(
        prompt="Ticket T-4521 for user_123 is resolved. Let the customer know.",
        options=options,
    ):
        if isinstance(message, ResultMessage) and message.subtype == "success":
            print(message.result)


if __name__ == "__main__":
    asyncio.run(main())