Function registerReviewTools

mcp/src/tools/review.ts:7–121

(server: McpServer, client: McpClient)

import { attachmentsArraySchema } from "./attachments.js";

export function registerReviewTools(server: McpServer, client: McpClient): void {
  server.registerTool(
    "list_pending_messages",
    {
      title: "List outbound messages awaiting approval",
      annotations: { readOnlyHint: true },
      description:
        "Use when the user asks what's awaiting approval, or after a `send_message`/`reply_to_message` returned `pending_review` and they want to see the queue. Lists held **outbound** messages (held by the agent's outbound policy or content scan) sorted by soonest-expiring first. Body content is summary-only — call `get_pending_message` for the full draft of one. Read-only; cheap, but don't poll it on a loop. Note: this lists OUTBOUND holds only — a held **inbound** message (screening review) is surfaced by the `email.pending_review` webhook (with its `message_id`), not here, and is resolved with the same `approve_message`/`reject_message` tools.",
      inputSchema: strictInputSchema({}),
    },
    async () => runTool(async () => ({ messages: await client.listPendingMessages() })),
  );

  server.registerTool(
    "get_pending_message",
    {
      title: "Get a pending-approval message",
      annotations: { readOnlyHint: true },
      description:
        "Fetch the full draft (subject, recipients, body, attachments) of one outbound message awaiting human approval. Body content is only present while the message is `pending_review` — after a terminal transition the server scrubs it.",
      inputSchema: strictInputSchema({
        message_id: z.string().describe("The pending message ID (msg_…)."),
      }),
    },
    async (args) => runTool(() => client.getPendingMessage(args.message_id)),
  );

  // Map the snake_case approve override args to the SDK's ApproveRequest
  // (camelCase body fields). An explicitly-passed empty attachments array
  // must survive as a strip override, so map by key-presence.
  const mapOverrides = (overrides: {
    subject?: string;
    body_text?: string;
    body_html?: string;
    to?: string[];
    cc?: string[];
    bcc?: string[];
    attachments?: Array<{ filename: string; content_type: string; data: string }>;
  }) => ({
    ...(overrides.subject !== undefined ? { subject: overrides.subject } : {}),
    ...(overrides.body_text !== undefined ? { body: overrides.body_text } : {}),
    ...(overrides.body_html !== undefined ? { htmlBody: overrides.body_html } : {}),
    ...(overrides.to !== undefined ? { to: overrides.to } : {}),
    ...(overrides.cc !== undefined ? { cc: overrides.cc } : {}),
    ...(overrides.bcc !== undefined ? { bcc: overrides.bcc } : {}),
    ...(overrides.attachments !== undefined
      ? {
          attachments: overrides.attachments.map((a) => ({
            filename: a.filename,
            contentType: a.content_type,
            data: a.data,
          })),
        }
      : {}),
  });

  server.registerTool(
    "approve_message",