import "./main.js";
import { getter, uncurryThis } from "ext:core/primordials";
import type * as Vendor from "./vendor_types.js";
export type * from "./vendor_types.js";
export type ReadableStream<R = unknown> = Vendor.ReadableStream<R>;
export type WritableStream<W = unknown> = Vendor.WritableStream<W>;
export type TransformStream<I = unknown, O = unknown> = Vendor.TransformStream<
  I,
  O
>;
export type ReadableByteStreamController = Vendor.ReadableByteStreamController;
export type ReadableStreamBYOBRequest = Vendor.ReadableStreamBYOBRequest;
export type TransformStreamDefaultController<O = unknown> =
  Vendor.TransformStreamDefaultController<O>;

export const {
  ReadableStream,
  WritableStream,
  TransformStream,
  ReadableByteStreamController,
  ReadableStreamBYOBRequest,
  TransformStreamDefaultController,
} = globalThis;
export const streamLocked = getter(ReadableStream.prototype, "locked");
export const streamReader: <R>(
  stream: Vendor.ReadableStream<R>,
) => Vendor.ReadableStreamDefaultReader<R> = uncurryThis(
  ReadableStream.prototype.getReader,
);
export const streamTee: <R>(
  stream: Vendor.ReadableStream<R>,
) => [Vendor.ReadableStream<R>, Vendor.ReadableStream<R>] = uncurryThis(
  ReadableStream.prototype.tee,
);
export const streamCancel: (
  stream: Vendor.ReadableStream<unknown>,
  reason?: unknown,
) => Promise<void> = uncurryThis(ReadableStream.prototype.cancel);
export const read = uncurryThis(ReadableStreamDefaultReader.prototype.read) as <
  R,
>(
  reader: Vendor.ReadableStreamDefaultReader<R>,
) => Promise<Vendor.ReadResult<R>>;
export const release: (
  reader: Vendor.ReadableStreamDefaultReader<unknown>,
) => void = uncurryThis(
  ReadableStreamDefaultReader.prototype.releaseLock,
);
export const readerCancel: (
  reader: Vendor.ReadableStreamDefaultReader<unknown>,
  reason?: unknown,
) => Promise<void> = uncurryThis(
  ReadableStreamDefaultReader.prototype.cancel,
);
export const enqueue = uncurryThis(
  ReadableByteStreamController.prototype.enqueue,
);
export const close = uncurryThis(ReadableByteStreamController.prototype.close);
export const errorStream = uncurryThis(
  ReadableByteStreamController.prototype.error,
);
export const byobRequest = getter(
  ReadableByteStreamController.prototype,
  "byobRequest",
);
export const respond = uncurryThis(ReadableStreamBYOBRequest.prototype.respond);
export function finish(controller: Vendor.ReadableByteStreamController): void {
  const request = byobRequest(controller);
  close(controller);
  if (request) respond(request, 0);
}