import { EventEmitter } from 'node:events';
import { IncomingMessage } from 'node:http';
import { Readable } from 'node:stream';
import { PaginationResult } from '@visulima/pagination';
import { U as UploadFile, B as BaseStorage, a as UploadError, b as UploadEventType } from "./storage.d-C9EdfTf1.js";
import { M as MediaTransformer } from "./media-transformer.d-Co37isNg.js";
type WebRequest = globalThis.Request;
type WebResponse = globalThis.Response;
interface BaseResponse {
  headers: Record<string, number | string>;
  statusCode: number;
}
interface StreamingResponse extends BaseResponse {
  /** Total size of the stream (for Content-Length header) */
  size?: number;
  /** Stream of data to send */
  stream: Readable;
}
interface RequestEvent {
  request: Pick<IncomingMessage, "headers" | "method" | "url">;
}
type AsyncHandler<Request, Response> = (request: Request, response: Response) => Promise<void | ResponseFile<UploadFile> | ResponseList<UploadFile> | StreamingResponse>;
type Handlers = "delete" | "download" | "get" | "head" | "options" | "patch" | "post" | "put";
type MethodHandler<Request, Response> = { [h in Handlers]?: AsyncHandler<Request, Response>; };
type UploadEvent<TFile extends UploadFile> = RequestEvent & TFile;
type UploadErrorEvent = RequestEvent & UploadError;
type ResponseFile<TFile extends UploadFile> = BaseResponse & TFile & {
  /** Optional stream for streaming responses instead of content buffer */
  stream?: Readable;
};
type ResponseList<TFile extends UploadFile> = BaseResponse & {
  data: PaginationResult<TFile> | TFile[];
};
interface BaseHandler<TFile extends UploadFile> extends EventEmitter {
  emit: ((event: "error", error: UploadErrorEvent) => boolean) & ((event: UploadEventType, payload: UploadEvent<TFile>) => boolean);
  fetch: (request: WebRequest) => Promise<WebResponse>;
  off: ((event: "error", listener: (error: UploadErrorEvent) => void) => this) & ((event: UploadEventType, listener: (payload: UploadEvent<TFile>) => void) => this);
  on: ((event: "error", listener: (error: UploadErrorEvent) => void) => this) & ((event: UploadEventType, listener: (payload: UploadEvent<TFile>) => void) => this);
}
interface UploadOptions<TFile extends UploadFile> {
  disableTerminationForFinishedUploads?: boolean;
  /** Maximum file size for multipart parser (default: min(storage.maxUploadSize, 1GB)) */
  maxFileSize?: number;
  /** Maximum header size for multipart parser (default: 64KB) */
  maxHeaderSize?: number;
  mediaTransformer?: MediaTransformer;
  storage: BaseStorage<TFile>;
}
export { AsyncHandler as A, BaseHandler as B, Handlers as H, MethodHandler as M, ResponseFile as R, UploadOptions as U, ResponseList as a, RequestEvent as b, UploadErrorEvent as c, UploadEvent as d };