import { APIResource } from "../../core/resource.mjs"; import * as MessagesAPI from "../agents/messages.mjs"; import { MessagesArrayPage } from "../agents/messages.mjs"; import { APIPromise } from "../../core/api-promise.mjs"; import { type ArrayPageParams, PagePromise } from "../../core/pagination.mjs"; import { Stream } from "../../core/streaming.mjs"; import { RequestOptions } from "../../internal/request-options.mjs"; export declare class Messages extends APIResource { /** * Get response messages associated with a run. */ list(runID: string, query?: MessageListParams | null | undefined, options?: RequestOptions): PagePromise; /** * Retrieve Stream For Run */ stream(runID: string, body?: MessageStreamParams | undefined, options?: RequestOptions): APIPromise>; } export type MessageStreamResponse = unknown; export interface MessageListParams extends ArrayPageParams { } export interface MessageStreamParams { /** * Agent ID for agent-direct mode with 'default' conversation. Use with * conversation_id='default' in the URL path. */ agent_id?: string | null; /** * Number of entries to read per batch. */ batch_size?: number | null; /** * Whether to include periodic keepalive ping messages in the stream to prevent * connection timeouts. */ include_pings?: boolean | null; /** * Offline threading ID to look up the run_id. Bypasses active run lookup if run_id * not provided. */ otid?: string | null; /** * Seconds to wait between polls when no new data. */ poll_interval?: number | null; /** * Run ID to stream directly, bypassing run lookup. Use for recovery from duplicate * requests. */ run_id?: string | null; /** * Sequence id to use as a cursor for pagination. Response will start streaming * after this chunk sequence id */ starting_after?: number; } export declare namespace Messages { export { type MessageStreamResponse as MessageStreamResponse, type MessageListParams as MessageListParams, type MessageStreamParams as MessageStreamParams, }; } export { type MessagesArrayPage }; //# sourceMappingURL=messages.d.mts.map