12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970
// Copyright 2018-2020 the Deno authors. All rights reserved. MIT license.import { assert, assertEquals } from "../../testing/asserts.ts";import { TextProtoReader } from "../../textproto/mod.ts";import { BufReader } from "../../io/bufio.ts";import { connectWebSocket, WebSocket } from "../../ws/mod.ts";import { delay } from "../../util/async.ts";
const { test, build } = Deno;
async function startServer(): Promise<Deno.Process> {  const server = Deno.run({    cmd: [Deno.execPath(), "--allow-net", "--allow-read", "server.ts"],    cwd: "examples/chat",    stdout: "piped",  });  try {    assert(server.stdout != null);    const r = new TextProtoReader(new BufReader(server.stdout));    const s = await r.readLine();    assert(s !== Deno.EOF && s.includes("chat server starting"));  } catch (err) {    server.stdout!.close();    server.close();  }
  return server;}
// TODO: https://github.com/denoland/deno/issues/4108const ignore = build.os == "win";
test({  ignore,  name: "GET / should serve html",  async fn() {    const server = await startServer();    try {      const resp = await fetch("http://127.0.0.1:8080/");      assertEquals(resp.status, 200);      assertEquals(resp.headers.get("content-type"), "text/html");      const html = await resp.text();      assert(html.includes("ws chat example"), "body is ok");    } finally {      server.close();      server.stdout!.close();    }    await delay(10);  },});
test({  ignore,  name: "GET /ws should upgrade conn to ws",  async fn() {    const server = await startServer();    let ws: WebSocket | undefined;    try {      ws = await connectWebSocket("http://127.0.0.1:8080/ws");      const it = ws.receive();      assertEquals((await it.next()).value, "Connected: [1]");      ws.send("Hello");      assertEquals((await it.next()).value, "[1]: Hello");    } finally {      server.close();      server.stdout!.close();      ws!.conn.close();    }  },});