2020-02-24 08:31:40 -05:00
|
|
|
// Copyright 2018-2020 the Deno authors. All rights reserved. MIT license.
|
2020-02-22 18:51:04 -05:00
|
|
|
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";
|
2020-03-18 19:25:55 -04:00
|
|
|
import { delay } from "../../util/async.ts";
|
2020-02-22 18:51:04 -05:00
|
|
|
|
2020-04-30 06:47:53 -04:00
|
|
|
const { test } = Deno;
|
2020-03-18 19:25:55 -04:00
|
|
|
|
|
|
|
async function startServer(): Promise<Deno.Process> {
|
|
|
|
const server = Deno.run({
|
2020-04-30 11:23:40 -04:00
|
|
|
// TODO(lucacasonato): remove unstable once possible
|
|
|
|
cmd: [
|
|
|
|
Deno.execPath(),
|
|
|
|
"--allow-net",
|
|
|
|
"--allow-read",
|
|
|
|
"--unstable",
|
|
|
|
"server.ts",
|
|
|
|
],
|
2020-02-22 18:51:04 -05:00
|
|
|
cwd: "examples/chat",
|
2020-03-28 13:03:49 -04:00
|
|
|
stdout: "piped",
|
2020-02-22 18:51:04 -05:00
|
|
|
});
|
|
|
|
try {
|
|
|
|
assert(server.stdout != null);
|
|
|
|
const r = new TextProtoReader(new BufReader(server.stdout));
|
|
|
|
const s = await r.readLine();
|
2020-04-28 12:40:43 -04:00
|
|
|
assert(s !== null && s.includes("chat server starting"));
|
2020-03-20 09:38:34 -04:00
|
|
|
} catch (err) {
|
2020-03-18 19:25:55 -04:00
|
|
|
server.stdout!.close();
|
2020-02-22 18:51:04 -05:00
|
|
|
server.close();
|
|
|
|
}
|
|
|
|
|
2020-03-18 19:25:55 -04:00
|
|
|
return server;
|
|
|
|
}
|
2020-02-22 18:51:04 -05:00
|
|
|
|
2020-03-15 08:03:25 -04:00
|
|
|
test({
|
2020-04-30 06:47:53 -04:00
|
|
|
name: "[examples/chat] GET / should serve html",
|
2020-03-15 08:03:25 -04:00
|
|
|
async fn() {
|
2020-03-18 19:25:55 -04:00
|
|
|
const server = await startServer();
|
|
|
|
try {
|
2020-03-24 12:24:58 -04:00
|
|
|
const resp = await fetch("http://127.0.0.1:8080/");
|
2020-03-18 19:25:55 -04:00
|
|
|
assertEquals(resp.status, 200);
|
|
|
|
assertEquals(resp.headers.get("content-type"), "text/html");
|
2020-04-10 09:51:17 -04:00
|
|
|
const html = await resp.text();
|
2020-03-18 19:25:55 -04:00
|
|
|
assert(html.includes("ws chat example"), "body is ok");
|
|
|
|
} finally {
|
|
|
|
server.close();
|
|
|
|
server.stdout!.close();
|
|
|
|
}
|
|
|
|
await delay(10);
|
2020-03-28 13:03:49 -04:00
|
|
|
},
|
2020-03-15 08:03:25 -04:00
|
|
|
});
|
|
|
|
|
|
|
|
test({
|
2020-04-30 06:47:53 -04:00
|
|
|
name: "[examples/chat] GET /ws should upgrade conn to ws",
|
2020-03-15 08:03:25 -04:00
|
|
|
async fn() {
|
2020-03-18 19:25:55 -04:00
|
|
|
const server = await startServer();
|
|
|
|
let ws: WebSocket | undefined;
|
|
|
|
try {
|
2020-03-24 12:24:58 -04:00
|
|
|
ws = await connectWebSocket("http://127.0.0.1:8080/ws");
|
2020-03-18 19:25:55 -04:00
|
|
|
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();
|
|
|
|
}
|
2020-03-28 13:03:49 -04:00
|
|
|
},
|
2020-03-15 08:03:25 -04:00
|
|
|
});
|