import { Client, type ClientOptions, type ProcedureRequestOptions, type QueryRequestOptions } from "@atcute/client";
import type { XRPCProcedures, XRPCQueries } from "@atcute/lexicons/ambient";
import type { InferOutput, XRPCLexBodyParam, XRPCProcedureMetadata, XRPCQueryMetadata } from "@atcute/lexicons/validations";
import type { ReadableStream } from "node:stream/web";
import { RateLimitThreshold } from "rate-limit-threshold";
/** Taken from @atcute/client */
type RequiredKeysOf<TType extends object> = TType extends any ? Exclude<{
    [Key in keyof TType]: TType extends Record<Key, TType[Key]> ? Key : never;
}[keyof TType], undefined> : never;
/** Taken from @atcute/client */
type HasRequiredKeys<TType extends object> = RequiredKeysOf<TType> extends never ? false : true;
/** Taken from @atcute/client */
export type ResponseFormat = "json" | "blob" | "bytes" | "stream";
/** Taken from @atcute/client */
export type FormattedResponse<TDef> = {
    json: TDef extends XRPCQueryMetadata<any, infer Body extends XRPCLexBodyParam, any> ? InferOutput<Body["schema"]> : TDef extends XRPCProcedureMetadata<any, any, infer Body extends XRPCLexBodyParam, any> ? InferOutput<Body["schema"]> : unknown;
    blob: Blob;
    bytes: Uint8Array;
    stream: ReadableStream<Uint8Array>;
};
/**
 * An XRPC agent with rate-limited requests.
 */
export declare class RateLimitedAgent<TQueries extends XRPCQueries = XRPCQueries, TProcedures extends XRPCProcedures = XRPCProcedures> {
    private limiter;
    labelers: Set<string>;
    client: Client;
    constructor(options: ClientOptions, limiter: RateLimitThreshold);
    get<TName extends keyof TQueries, TInit extends QueryRequestOptions<TQueries[TName]>>(name: TName, ...options: HasRequiredKeys<TInit> extends true ? [init: TInit] : [init?: TInit]): Promise<TInit extends {
        as: infer TFormat;
    } ? TFormat extends ResponseFormat ? FormattedResponse<TQueries[TName]>[TFormat] : TFormat extends null ? null : never : TQueries[TName] extends XRPCQueryMetadata<any, infer Body extends XRPCLexBodyParam, any> ? InferOutput<Body["schema"]> : never>;
    post<TName extends keyof TProcedures, TInit extends ProcedureRequestOptions<TProcedures[TName]>>(name: TName, ...options: HasRequiredKeys<TInit> extends true ? [init: TInit] : [init?: TInit]): Promise<TInit extends {
        as: infer TFormat;
    } ? TFormat extends ResponseFormat ? FormattedResponse<TProcedures[TName]>[TFormat] : TFormat extends null ? null : never : TProcedures[TName] extends XRPCProcedureMetadata<any, any, infer Body extends XRPCLexBodyParam, any> ? InferOutput<Body["schema"]> : never>;
    /**
     * Create a new agent with the atproto_proxy header set.
     * @param did The proxy service DID.
     * @param service The proxy service identifier.
     */
    withProxy(did: `did:${string}:${string}`, service: `#${string}`): RateLimitedAgent;
}
export {};