A2A servers

export interface A2AServerOptions {
    agents: Record<string, Agent>;
    basePath?: string;
    provider?: {
        organization: string;
        url?: string;
    };
    version?: string;
    /** Maximum process-local tasks, including active work. Default 10000. */
    maxTasks?: number;
}

export interface A2AV1Identity {
    tenantId: string;
    userId: string;
}

export interface A2AV1ServerOptions {
    agents: Record<string, Pick<Agent, "name" | "run">>;
    /** Absolute URL of this JSON-RPC endpoint. */
    url: string;
    basePath?: string;
    cardPath?: string;
    /** Passed to the host verifier; the verifier must validate token audience. */
    audience: string;
    authenticate: (request: Request, audience: string) => Promise<A2AV1Identity | null>;
    maxTasks?: number;
    /** Local history retention and follow-up admission bound; default 128. */
    maxHistoryMessages?: number;
    /** Domain-specific interrupted results remain distinguishable from success. */
    completionState?: (output: RunOutput) => "TASK_STATE_COMPLETED" | "TASK_STATE_INPUT_REQUIRED" | "TASK_STATE_AUTH_REQUIRED" | "TASK_STATE_FAILED";
}

/**
 * Mount an A2A-compliant server on an Express app.
 *
 * - Serves `/.well-known/agent.json` with the Agent Card
 * - Handles JSON-RPC 2.0 requests at the basePath for message/send, message/stream, tasks/get, tasks/cancel
 */
export declare function createA2AServer(app: any, opts: A2AServerOptions): void;

/** A2A 1.0 JSON-RPC using the optional official SDK. Local task state is
 * process-local and ownership-scoped; this adapter does not promise recovery. */
export declare function createA2AV1Server(app: Express, options: A2AV1ServerOptions): Promise<{
    card: A2AV1Card;
}>;

/** Optional A2A 1.0 JSON-RPC bridge. Polling only; all state remains in the durable store. */
export declare function createDurableA2AV1Server(options: DurableA2AV1ServerOptions): Promise<Router>;

export interface DurableA2AV1ServerOptions extends DurableProtocolHost {
    name: string;
    /** Absolute public JSON-RPC URL; mount the returned router at its origin. */
    url: string;
    audience: string;
    authenticate(request: Request, audience: string): Promise<DurableReader | null>;
    cardPath?: string;
    /** Blocking SendMessage waits only this long; timeout does not cancel admitted work. */
    waitTimeoutMs?: number;
    pollIntervalMs?: number;
}

/**
 * Generate an A2A Agent Card from a Agentium Agent.
 * The card is served at /.well-known/agent.json per the A2A spec.
 */
export declare function generateAgentCard(agent: Agent, serverUrl: string, provider?: {
    organization: string;
    url?: string;
}, version?: string): A2AAgentCard;

/**
 * Generate a combined Agent Card that lists multiple agents as skills.
 */
export declare function generateMultiAgentCard(agents: Record<string, Agent>, serverUrl: string, provider?: {
    organization: string;
    url?: string;
}, version?: string): A2AAgentCard;