import { PaginatedData } from '../types/paginatedData';
export declare const fetchAll: <T>(reqFunction: (reqParams: any) => Promise<PaginatedData<T>>, reqParams?: any, maxLimit?: number) => Promise<T[]>;
export declare const fetchAllWithOffset: <T>(reqFunction: (reqParams: any) => Promise<{
    pagination: {
        limit: number;
        offset: number;
        total: number;
    };
    data: T[];
}>, reqParams?: any, maxLimit?: number) => Promise<T[]>;
export declare function fetchFirstChunkAndRemainingAsync<T>(reqFunction: (reqParams: any) => Promise<PaginatedData<T>>, reqParams?: any): Promise<[T[], Promise<T[]>]>;
export declare function urlSafeFetchInChunks<T>(ids: (string | number)[], fetchFunction: (chunk: (string | number)[]) => Promise<{
    results: T[];
} | T[]>, options?: {
    chunkSize: number;
}): Promise<T[]>;
export declare function derivePatchRequestFields<T extends object>(current: T, updated: Partial<T>, fieldsString?: string): {
    updatedFields: string[];
    payload: Partial<T>;
};
export declare function requestStream(url: string, body: Record<string, any>, token: string, onStreamedChunk?: (chunk: string, response: string) => void, signal?: AbortSignal): Promise<string>;
/**
 * Split a raw SSE buffer on the `\n\n` event boundary. When `done`, the trailing
 * fragment is flushed as a final event; otherwise it is returned in `rest` to be
 * prepended to the next chunk.
 */
export declare function splitSseBuffer(buffer: string, done: boolean): {
    events: string[];
    rest: string;
};
/** Parse one SSE event block into its JSON payload; null for `[DONE]`, keep-alives, or non-JSON. */
export declare function parseSseEvent(event: string): Record<string, unknown> | null;
/**
 * Consume the Bedrock SSE stream from `/core/api/protected/ai/ai-generation/stream`
 * and accumulate text. The endpoint emits `data: {"type":"content_delta","delta":"…"}`
 * frames, a `data: {"type":"error","error":"…"}` on failure, and a `data: [DONE]`
 * terminator (PIT-7145). Calls `onText(delta, fullText)` per content chunk and
 * returns the full text; throws on error frames / network failures. Replaces the
 * legacy Replicate NDJSON parsing now that platform AI surfaces run on the
 * `routine` tier (Bedrock).
 */
export declare function requestAiStream(url: string, body: Record<string, any>, token: string, onText?: (delta: string, fullText: string) => void, signal?: AbortSignal): Promise<string>;