import { z } from "zod"; /** * MCP tool: check_messages * * Phase A v0.1 real-time A2A messaging — inbox-style polling for * messages. Real-time push comes via the SSE listener + hook (the * same path that surfaces transfer.created). This tool covers: * - on-demand "what messages have I received" queries * - thread retrieval ("show me thread X") * - unread filtering ("what haven't I read yet") * - reconnect recovery when SSE was disconnected */ declare const schema: z.ZodObject<{ thread_id: z.ZodOptional; unread_only: z.ZodOptional; since: z.ZodOptional; limit: z.ZodOptional; }, "strip", z.ZodTypeAny, { limit?: number | undefined; thread_id?: string | undefined; unread_only?: boolean | undefined; since?: string | undefined; }, { limit?: number | undefined; thread_id?: string | undefined; unread_only?: boolean | undefined; since?: string | undefined; }>; export type CheckMessagesInput = z.infer; export declare function createCheckMessagesTool(args: { apiBase: string; apiKey: string; agentId: string; }): { name: "check_messages"; description: string; schema: z.ZodObject<{ thread_id: z.ZodOptional; unread_only: z.ZodOptional; since: z.ZodOptional; limit: z.ZodOptional; }, "strip", z.ZodTypeAny, { limit?: number | undefined; thread_id?: string | undefined; unread_only?: boolean | undefined; since?: string | undefined; }, { limit?: number | undefined; thread_id?: string | undefined; unread_only?: boolean | undefined; since?: string | undefined; }>; handler: (input: CheckMessagesInput) => Promise<{ isError: boolean; content: { type: "text"; text: string; }[]; } | { content: { type: "text"; text: string; }[]; isError?: undefined; }>; }; export {};