Send from the OpenAI Agents SDK

import { Agent, run, tool } from "@openai/agents";
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({
  name: "send_ticket_update",
  description: "Tell a customer that their support ticket changed status.",
  parameters: z.object({
    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 execute({ 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 `Sent. requestId: ${requestId}`;
  },
});

const agent = new Agent({
  name: "Support agent",
  instructions: "You are a support agent. Tell customers when their ticket changes status, then reply with the requestId.",
  tools: [sendTicketUpdate],
});

const result = await run(agent, "Ticket T-4521 for user_123 is resolved. Let the customer know.");
console.log(result.finalOutput);

import asyncio
import uuid
from typing import Literal

from agents import Agent, Runner
from agents.decorators import tool
from courier import AsyncCourier

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


@tool
async def send_ticket_update(
    user_id: str, ticket_id: str, status: Literal["in_progress", "resolved"]
) -> str:
    """Tell a customer that their support ticket changed status.

    Args:
        user_id: The customer's Courier user ID.
        ticket_id: The support ticket ID.
        status: The ticket's new status.
    """
    response = await courier.send.message(
        message={
            "to": {"user_id": user_id},
            "template": "nt_01kx4h2jdafq8bk9aftxak4b40",
            "data": {"ticket_id": ticket_id, "status": status},
        },
        idempotency_key=str(uuid.uuid4()),
    )
    return f"Sent. requestId: {response.request_id}"


agent = Agent(
    name="Support agent",
    instructions="You are a support agent. Tell customers when their ticket changes status, then reply with the requestId.",
    tools=[send_ticket_update],
)


async def main() -> None:
    result = await Runner.run(
        agent, "Ticket T-4521 for user_123 is resolved. Let the customer know."
    )
    print(result.final_output)


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

import { Agent, createMCPToolStaticFilter, MCPServerStreamableHttp, run } from "@openai/agents";

const courierMcp = new MCPServerStreamableHttp({
  name: "courier",
  url: "https://mcp.courier.com",
  requestInit: { headers: { api_key: process.env.COURIER_API_KEY! } },
  toolFilter: createMCPToolStaticFilter({
    allowed: ["send_message_template", "trace_message"],
  }),
});

const agent = new Agent({
  name: "Support agent",
  instructions:
    "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: [courierMcp],
});

try {
  await courierMcp.connect();
  const result = await run(agent, "Ticket T-4521 for user_123 is resolved. Let the customer know.");
  console.log(result.finalOutput);
} finally {
  await courierMcp.close();
}

import asyncio
import os

from agents import Agent, Runner
from agents.mcp import MCPServerStreamableHttp, create_static_tool_filter


async def main() -> None:
    async with MCPServerStreamableHttp(
        name="courier",
        params={
            "url": "https://mcp.courier.com",
            "headers": {"api_key": os.environ["COURIER_API_KEY"]},
        },
        tool_filter=create_static_tool_filter(
            allowed_tool_names=["send_message_template", "trace_message"]
        ),
    ) as courier_mcp:
        agent = Agent(
            name="Support agent",
            instructions=(
                "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_mcp],
        )
        result = await Runner.run(
            agent, "Ticket T-4521 for user_123 is resolved. Let the customer know."
        )
        print(result.final_output)


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