12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667
// Copyright 2018-2021 the oak authors. All rights reserved. MIT license.
import type { Application, State } from "./application.ts";import { assert, serve, serveTLS } from "./deps.ts";import type { BufReader, BufWriter } from "./deps.ts";import type { Server } from "./types.d.ts";import { isListenTlsOptions } from "./util.ts";
interface StdServer extends AsyncIterable<ServerRequest> {  listener: Deno.Listener;  close(): void;  [Symbol.asyncIterator](): AsyncIterableIterator<ServerRequest>;}
/** An interface that aligns to the parts of `std/http/server`'s * `ServerRequest` that actually is consumed by oak. */export interface ServerRequest {  body: Deno.Reader;  conn: Deno.Conn;  headers: Headers;  method: string;  r: BufReader;  respond(response: ServerResponse): Promise<void>;  url: string;  w: BufWriter;}
/** An interface that aligns to what oak returns and is compatible with * `std/http/server`'s `request.respond()`. */export interface ServerResponse {  status: number;  headers: Headers;  body: Uint8Array | Deno.Reader | undefined;}
// deno-lint-ignore no-explicit-anyexport class HttpServerStd<AS extends State = Record<string, any>>  implements Server<ServerRequest> {  #options: Deno.ListenOptions | Deno.ListenTlsOptions;  #server: StdServer | undefined;
  constructor(    _app: Application<AS>,    options: Deno.ListenOptions | Deno.ListenTlsOptions,  ) {    this.#options = options;  }
  close(): void {    if (this.#server) {      this.#server.close();    }  }
  listen() {    this.#server = isListenTlsOptions(this.#options)      ? serveTLS(this.#options)      : serve(this.#options);    return this.#server.listener;  }
  [Symbol.asyncIterator](): AsyncIterableIterator<ServerRequest> {    assert(this.#server);    return this.#server[Symbol.asyncIterator]();  }}