_adapter_test.ts

// Copyright 2019-2020 Yusuke Sakurai. All rights reserved. MIT license.
import { BufReader, BufWriter } from "./vendor/https/deno.land/std/io/bufio.ts";
import { assertEquals } from "./vendor/https/deno.land/std/testing/asserts.ts";
import { classicAdapter, nativeAdapter } from "./_adapter.ts";
import { group } from "./_test_util.ts";

group("adapter", ({ test }) => {
  async function doTest() {
    const resp = await fetch("http://localhost:8899", {
      method: "POST",
      body: "hello",
    });
    assertEquals(resp.status, 200);
    assertEquals(resp.headers.get("content-type"), "text/html");
    assertEquals(await resp.text(), "hello");
  }
  test("classic", async () => {
    async function serve() {
      const l = Deno.listen({ port: 8899 });
      const conn = await l.accept();
      const bufReader = new BufReader(conn);
      const bufWriter = new BufWriter(conn);
      const adapter = classicAdapter({ conn, bufReader, bufWriter });
      const req = await adapter.next({});
      await adapter.respond({
        status: 200,
        headers: new Headers({
          "content-type": "text/html",
        }),
        body: req!.body,
      });
      adapter.close();
      l.close();
    }
    serve();
    await doTest();
  });
  test("native", async () => {
    async function serve() {
      const l = Deno.listen({ port: 8899 });
      const conn = await l.accept();
      const adapter = nativeAdapter(conn);
      const req = await adapter.next({});
      await adapter.respond({
        status: 200,
        headers: new Headers({
          "content-type": "text/html",
        }),
        body: req!.body,
      });
      adapter.close();
      l.close();
    }
    serve();
    await doTest();
  });
});