123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174
// Copyright 2019 Yusuke Sakurai. All rights reserved. MIT license.import {  runIfMain,  setFilter,  test} from "./vendor/https/deno.land/std/testing/mod.ts";import { listenAndServe } from "./server.ts";import { StringReader } from "./vendor/https/deno.land/std/io/readers.ts";import { StringWriter } from "./vendor/https/deno.land/std/io/writers.ts";import {  assertEquals,  assertThrowsAsync} from "./vendor/https/deno.land/std/testing/asserts.ts";import { encode } from "./vendor/https/deno.land/std/strings/encode.ts";import { createAgent } from "./agent.ts";import { delay } from "./vendor/https/deno.land/std/util/async.ts";import { it } from "./test_util.ts";
let port = 8880;
test(async function server() {  const listener = listenAndServe(    {      hostname: "0.0.0.0",      port    },    async req => {      await req.respond({        status: 200,        headers: new Headers({          "content-type": "text/plain",          "content-length": "5"        }),        body: new StringReader("hello")      });    }  );  const agent = createAgent("http://127.0.0.1:" + port);  try {    const { headers, status, body } = await agent.send({      path: "/",      method: "GET"    });    assertEquals(headers.get("content-length"), "5");    assertEquals(status, 200);    assertEquals(headers.get("content-type"), "text/plain");    const dest = new StringWriter();    await Deno.copy(dest, body);    assertEquals(dest.toString(), "hello");  } finally {    agent.conn.close();    listener.close();  }});/*it("server", t => {  port++;  t.beforeAfterAll(() => {    const l = listenAndServe(      { port },      async req => {        await req.respond({          status: 200,          body: "ok"        });      },      {        keepAliveTimeout: 10      }    );    return () => l.close();  });  t.run("keepAliveTimeout", async () => {    const agent = createAgent(`http://127.0.0.1:${port}`);    try {      const req = {        path: "/",        method: "POST",        headers: new Headers({          host: "deno.land"        }),        body: "hello"      };      const { status, finalize } = await agent.send(req);      await finalize();      assertEquals(200, status);      await delay(100);      await assertThrowsAsync(async () => {        await agent.send(req);      });    } finally {      agent.conn.close();    }  });}); */test(async function serverKeepAliveTimeoutMax() {  port++;  const listener = listenAndServe(    {      hostname: "0.0.0.0",      port    },    async req => {      await req.respond({        status: 200,        headers: new Headers(),        body: encode("ok")      });    }  );  const agent = createAgent(`http://127.0.0.1:${port}`);  try {    const req = {      path: "/",      method: "POST",      headers: new Headers({        host: "deno.land",        "Keep-Alive": "max=0, timeout=1000"      }),      body: encode("hello")    };    const { status, finalize } = await agent.send(req);    await finalize();    assertEquals(200, status);    await assertThrowsAsync(async () => {      await agent.send(req);    });  } finally {    agent.conn.close();    listener.close();  }});
test(async function serverConnectionClose() {  port++;  const listener = listenAndServe(    {      hostname: "0.0.0.0",      port    },    async req => {      await req.respond({        status: 200,        headers: new Headers(),        body: encode("ok")      });    }  );  const agent = createAgent(`http://127.0.0.1:${port}`);  try {    const req = {      path: "/",      method: "POST",      headers: new Headers({        host: "deno.land",        connection: "close"      }),      body: encode("hello")    };    const { status, finalize } = await agent.send(req);    await finalize();    assertEquals(200, status);    await assertThrowsAsync(async () => {      await agent.send(req);    });  } finally {    agent.conn.close();    listener.close();  }});
runIfMain(import.meta);