Class NodeRequest

http_server_node.ts:50–143

};

export class NodeRequest implements ServerRequest {
  #request: IncomingMessage;
  #response: ServerResponse;
  #responded = false;

  get remoteAddr(): string | undefined {
    const addr = this.#request.socket.address();
    // deno-lint-ignore no-explicit-any
    return addr && (addr as any)?.address;
  }

  get headers(): Headers {
    return new Headers(this.#request.headers as Record<string, string>);
  }

  get method(): string {
    return this.#request.method ?? "GET";
  }

  get url(): string {
    return this.#request.url ?? "";
  }

  constructor(
    request: IncomingMessage,
    response: ServerResponse,
  ) {
    this.#request = request;
    this.#response = response;
  }

  // deno-lint-ignore no-explicit-any
  error(reason?: any) {
    if (this.#responded) {
      throw new Error("Request already responded to.");
    }
    let error;
    if (reason) {
      error = reason instanceof Error ? reason : new Error(String(reason));
    }
    this.#response.destroy(error);
    this.#responded = true;
  }

  getBody(): ReadableStream<Uint8ArrayArrayBuffer> | null {
    let body: ReadableStream<Uint8ArrayArrayBuffer> | null;
    if (this.method === "GET" || this.method === "HEAD") {
      body = null;
    } else {
      body = new ReadableStream<Uint8ArrayArrayBuffer>({
        start: (controller) => {
          this.#request.on("data", (chunk) => {
            controller.enqueue(chunk as Uint8ArrayArrayBuffer);
          });
          this.#request.on("error", (err: Error) => {
            controller.error(err);
          });
          this.#request.on("end", () => {