import * as _vobs_vobs from '@vobs/vobs';
import { VobsPlugin } from '@vobs/vobs';
import { RuntimeDebugContext } from '@vobs/runtime';
export { SSEClient, SSEConstructor, SSEOptions, WebSocketClient, WebSocketConstructor, WebSocketEventListener, WebSocketEventName, WebSocketOptions, WebSocketState, createSSE, createWebSocket } from './stream.js';

type HTTPMethod = 'DELETE' | 'GET' | 'HEAD' | 'OPTIONS' | 'PATCH' | 'POST' | 'PUT';
type HTTPResponseType = 'arrayBuffer' | 'blob' | 'json' | 'response' | 'text';
type HTTPHeaders = Record<string, string>;
type RetryDelay = number | ((attempt: number, error: Error) => number);
interface HTTPProgress {
    readonly loaded: number;
    readonly total: number | undefined;
    readonly percent: number | undefined;
}
type HTTPProgressHandler = (progress: HTTPProgress) => void;
interface RequestOptions {
    url: string;
    method?: HTTPMethod;
    baseURL?: string;
    headers?: HeadersInit;
    params?: Record<string, unknown> | URLSearchParams;
    body?: unknown;
    signal?: AbortSignal;
    /** @deprecated Use signal. */
    state?: AbortSignal;
    timeout?: number;
    retry?: number;
    retryDelay?: RetryDelay;
    shouldRetry?: (error: Error, attempt: number) => boolean | PromiseLike<boolean>;
    cache?: RequestCache;
    credentials?: RequestCredentials;
    mode?: RequestMode;
    responseType?: HTTPResponseType;
    onUploadProgress?: HTTPProgressHandler;
    onDownloadProgress?: HTTPProgressHandler;
    /** Share an in-flight request with the same dedupe key. */
    dedupe?: boolean;
    dedupeKey?: string;
    /** Optional context copied into DevTools request traces. */
    debugContext?: HTTPDebugContext;
}
interface RequestConfig extends Omit<RequestOptions, 'headers' | 'method'> {
    readonly method: HTTPMethod;
    headers: HTTPHeaders;
    readonly url: string;
}
interface HTTPResponse<T = unknown> {
    readonly data: T;
    readonly status: number;
    readonly statusText: string;
    readonly headers: Headers;
    readonly config: RequestConfig;
    readonly raw: Response | null;
}
/** Adapt an HTTP request to the fetcher contract used by Resource. */
type HTTPResourceRequest<T> = (signal: AbortSignal) => HTTPResponse<T> | PromiseLike<HTTPResponse<T>>;
declare function toResourceFetcher<T>(request: HTTPResourceRequest<T>): (signal: AbortSignal) => Promise<T>;
type HTTPAdapter = (config: RequestConfig) => Response | HTTPResponse<unknown> | PromiseLike<Response | HTTPResponse<unknown>>;
interface AxiosResponseLike<T = unknown> {
    readonly data: T;
    readonly status: number;
    readonly statusText?: string;
    readonly headers?: HeadersInit;
    readonly raw?: Response | null;
}
type AxiosRequestConfigLike = RequestConfig & {
    readonly data?: unknown;
};
type AxiosRequest = <T = unknown>(config: AxiosRequestConfigLike) => PromiseLike<AxiosResponseLike<T>>;
/** Bridges an Axios request function while preserving HTTPResponse<T>.data typing. */
declare function createAxiosAdapter(request?: AxiosRequest): HTTPAdapter;
/**
 * Creates an adapter for deterministic local handlers and test transports.
 * Returning a Response or HTTPResponse keeps full control over status and
 * headers; any other value becomes a successful 200 payload.
 */
declare function createMockAdapter(handler: (config: RequestConfig) => unknown | PromiseLike<unknown>): HTTPAdapter;
/** XMLHttpRequest adapter for upload and download progress events. */
declare function createXHRAdapter(): HTTPAdapter;
/** Explicit fetch transport for applications that do not want the built-in Axios transport. */
declare function createFetchAdapter(): HTTPAdapter;
interface HTTPClientOptions {
    baseURL?: string;
    headers?: HeadersInit;
    timeout?: number;
    adapter?: HTTPAdapter;
    retry?: number;
    retryDelay?: RetryDelay;
    shouldRetry?: (error: Error, attempt: number) => boolean | PromiseLike<boolean>;
    concurrency?: number;
    dedupe?: boolean;
}
interface InterceptorManager<T> {
    use<TResult = T>(onFulfilled?: (value: T) => TResult | PromiseLike<TResult>, onRejected?: (error: unknown) => TResult | PromiseLike<TResult>): number;
    eject(id: number): void;
    clear(): void;
}
interface HTTPInterceptors {
    readonly request: InterceptorManager<RequestConfig>;
    readonly response: InterceptorManager<HTTPResponse<unknown>>;
}
interface HTTPClient {
    readonly interceptors: HTTPInterceptors;
    request<T = unknown>(options: RequestOptions): Promise<HTTPResponse<T>>;
    get<T = unknown>(url: string, options?: Omit<RequestOptions, 'url' | 'method' | 'body'>): Promise<HTTPResponse<T>>;
    delete<T = unknown>(url: string, options?: Omit<RequestOptions, 'url' | 'method' | 'body'>): Promise<HTTPResponse<T>>;
    head<T = unknown>(url: string, options?: Omit<RequestOptions, 'url' | 'method' | 'body'>): Promise<HTTPResponse<T>>;
    post<T = unknown>(url: string, body?: unknown, options?: Omit<RequestOptions, 'url' | 'method' | 'body'>): Promise<HTTPResponse<T>>;
    put<T = unknown>(url: string, body?: unknown, options?: Omit<RequestOptions, 'url' | 'method' | 'body'>): Promise<HTTPResponse<T>>;
    patch<T = unknown>(url: string, body?: unknown, options?: Omit<RequestOptions, 'url' | 'method' | 'body'>): Promise<HTTPResponse<T>>;
}
interface ConcurrencyLimiter {
    <T>(task: () => T | PromiseLike<T>): Promise<T>;
}
declare class HTTPError extends Error {
    readonly status: number;
    readonly statusText: string;
    readonly data: unknown;
    readonly config: RequestConfig;
    readonly response: HTTPResponse<unknown>;
    constructor(response: HTTPResponse<unknown>);
}
declare class TimeoutError extends Error {
    readonly code = "ETIMEDOUT";
    /**
     * 超时时手上那个错误。
     *
     * 整链预算到点会把当前错误换成 TimeoutError —— 原来原错误就此丢掉（报告 P12：真实的
     * ECONNREFUSED 变成了无 cause 的超时）。挂在这里，排查时还有线索。
     */
    readonly cause?: unknown;
    constructor(timeout: number, cause?: unknown);
}
declare const HTTP_KEY: _vobs_vobs.InjectionKey<HTTPClient>;
interface HTTPPluginOptions extends HTTPClientOptions {
    client?: HTTPClient;
}
declare function createHTTPClient(options?: HTTPClientOptions): HTTPClient;
declare function httpPlugin(options?: HTTPPluginOptions): VobsPlugin;
declare function createConcurrencyLimiter(limit: number): ConcurrencyLimiter;

type HTTPDebugStatus = 'loading' | 'retrying' | 'success' | 'error' | 'cancelled';
type HTTPDebugCacheStatus = 'hit' | 'miss' | 'revalidated';
interface HTTPDebugContext extends RuntimeDebugContext {
    readonly cacheStatus?: HTTPDebugCacheStatus;
    /** Marks a request created from the DevTools request tester. */
    readonly test?: boolean;
}
interface HTTPDebugRequest {
    readonly id: number;
    readonly phase: 'start' | 'retry' | 'end';
    readonly status: HTTPDebugStatus;
    readonly url: string;
    readonly method: HTTPMethod;
    readonly headers: HTTPHeaders;
    readonly requestBody?: unknown;
    readonly startedAt: number;
    readonly endedAt?: number;
    readonly duration?: number;
    readonly attempt: number;
    readonly retries: number;
    readonly responseStatus?: number;
    readonly responseBody?: unknown;
    readonly error?: {
        readonly name: string;
        readonly message: string;
    };
    readonly context?: HTTPDebugContext;
}
interface HTTPDebugHooks {
    request?(event: HTTPDebugRequest): void;
}
declare function setHTTPDebugHooks(hooks: HTTPDebugHooks | null): HTTPDebugHooks | null;
declare function getHTTPDebugHooks(): HTTPDebugHooks | null;
declare function subscribeHTTPDebug(listener: NonNullable<HTTPDebugHooks['request']>): () => void;
declare function emitHTTPDebug(event: HTTPDebugRequest): void;

export { type AxiosRequest, type AxiosRequestConfigLike, type AxiosResponseLike, type ConcurrencyLimiter, type HTTPAdapter, type HTTPClient, type HTTPClientOptions, type HTTPDebugCacheStatus, type HTTPDebugContext, type HTTPDebugHooks, type HTTPDebugRequest, type HTTPDebugStatus, HTTPError, type HTTPHeaders, type HTTPInterceptors, type HTTPMethod, type HTTPPluginOptions, type HTTPProgress, type HTTPProgressHandler, type HTTPResourceRequest, type HTTPResponse, type HTTPResponseType, HTTP_KEY, type InterceptorManager, type RequestConfig, type RequestOptions, type RetryDelay, TimeoutError, createAxiosAdapter, createConcurrencyLimiter, createFetchAdapter, createHTTPClient, createMockAdapter, createXHRAdapter, emitHTTPDebug, getHTTPDebugHooks, httpPlugin, setHTTPDebugHooks, subscribeHTTPDebug, toResourceFetcher };