123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111
// Copyright 2018-2022 the oak authors. All rights reserved. MIT license.
import {  assertEquals,  assertInstanceOf,  assertStrictEquals,  unreachable,} from "./test_deps.ts";
import { HttpServer } from "./http_server_native.ts";import { NativeRequest } from "./http_server_native_request.ts";
import { Application } from "./application.ts";import { isNode } from "./util.ts";
const { test } = Deno;
function createMockConn() {  return {    localAddr: { transport: "tcp", hostname: "localhost", port: 8000 },    remoteAddr: { transport: "tcp", hostname: "remote", port: 4567 },    rid: 1,  } as Deno.Conn;}
test({  name: "NativeRequest",  ignore: isNode(),  async fn() {    const respondWithStack: Array<Response | Promise<Response>> = [];    const request = new Request("http://localhost:8000/", {      method: "POST",      body: `{"a":"b"}`,    });    const conn = createMockConn();    const nativeRequest = new NativeRequest(      {        request,        respondWith(v) {          respondWithStack.push(v);          return Promise.resolve();        },      },      { conn },    );    assertEquals(nativeRequest.url, `/`);    assertEquals(respondWithStack.length, 1);    const response = new Response("hello deno");    nativeRequest.respond(response);    assertStrictEquals(await respondWithStack[0], response);  },});
test({  name: "HttpServer closes gracefully after serving requests",  ignore: isNode(),  async fn() {    const app = new Application();    const listenOptions = { port: 4505 };
    const server = new HttpServer(app, listenOptions);    server.listen();
    const expectedBody = "test-body";
    (async () => {      for await (const nativeRequest of server) {        nativeRequest.respond(new Response(expectedBody));      }    })();
    try {      const response = await fetch(`http://localhost:${listenOptions.port}`);      assertEquals(await response.text(), expectedBody);    } catch {      unreachable();    } finally {      server.close();    }  },});
test({  name:    "HttpServer manages errors from mis-use in the application handler gracefully",  ignore: isNode(),  async fn() {    const app = new Application();    const listenOptions = { port: 4506 };
    const server = new HttpServer(app, listenOptions);    server.listen();
    (async () => {      for await (const nativeRequest of server) {        // deno-lint-ignore no-explicit-any        nativeRequest.respond(null as any);      }    })();
    try {      await fetch(`http://localhost:${listenOptions.port}`);      unreachable();    } catch (e) {      assertInstanceOf(e, TypeError);    } finally {      server.close();    }  },});