summaryrefslogtreecommitdiff
path: root/cli/tests/websocketstream_test.ts
diff options
context:
space:
mode:
authorDavid Sherret <dsherret@users.noreply.github.com>2021-08-11 10:20:47 -0400
committerGitHub <noreply@github.com>2021-08-11 10:20:47 -0400
commit15a763152f9d392cb80692262f8de5ef8ae15495 (patch)
treefcd1a59777f95920bf3502519983d6cc0d882a9a /cli/tests/websocketstream_test.ts
parenta0285e2eb88f6254f6494b0ecd1878db3a3b2a58 (diff)
chore: move test files to testdata directory (#11601)
Diffstat (limited to 'cli/tests/websocketstream_test.ts')
-rw-r--r--cli/tests/websocketstream_test.ts82
1 files changed, 0 insertions, 82 deletions
diff --git a/cli/tests/websocketstream_test.ts b/cli/tests/websocketstream_test.ts
deleted file mode 100644
index 5b4d19f6e..000000000
--- a/cli/tests/websocketstream_test.ts
+++ /dev/null
@@ -1,82 +0,0 @@
-// Copyright 2018-2021 the Deno authors. All rights reserved. MIT license.
-
-import {
- assertEquals,
- assertThrows,
- assertThrowsAsync,
-} from "../../test_util/std/testing/asserts.ts";
-
-Deno.test("fragment", () => {
- assertThrows(() => new WebSocketStream("ws://localhost:4242/#"));
- assertThrows(() => new WebSocketStream("ws://localhost:4242/#foo"));
-});
-
-Deno.test("duplicate protocols", () => {
- assertThrows(() =>
- new WebSocketStream("ws://localhost:4242", {
- protocols: ["foo", "foo"],
- })
- );
-});
-
-Deno.test("connect & close custom valid code", async () => {
- const ws = new WebSocketStream("ws://localhost:4242");
- await ws.connection;
- ws.close({ code: 1000 });
- await ws.closed;
-});
-
-Deno.test("connect & close custom invalid reason", async () => {
- const ws = new WebSocketStream("ws://localhost:4242");
- await ws.connection;
- assertThrows(() => ws.close({ code: 1000, reason: "".padEnd(124, "o") }));
- ws.close();
- await ws.closed;
-});
-
-Deno.test("echo string", async () => {
- const ws = new WebSocketStream("ws://localhost:4242");
- const { readable, writable } = await ws.connection;
- await writable.getWriter().write("foo");
- const res = await readable.getReader().read();
- assertEquals(res.value, "foo");
- ws.close();
- await ws.closed;
-});
-
-Deno.test("echo string tls", async () => {
- const ws = new WebSocketStream("wss://localhost:4243");
- const { readable, writable } = await ws.connection;
- await writable.getWriter().write("foo");
- const res = await readable.getReader().read();
- assertEquals(res.value, "foo");
- ws.close();
- await ws.closed;
-});
-
-Deno.test("websocket error", async () => {
- const ws = new WebSocketStream("wss://localhost:4242");
- await Promise.all([
- assertThrowsAsync(
- () => ws.connection,
- Deno.errors.UnexpectedEof,
- "tls handshake eof",
- ),
- assertThrowsAsync(
- () => ws.closed,
- Deno.errors.UnexpectedEof,
- "tls handshake eof",
- ),
- ]);
-});
-
-Deno.test("echo uint8array", async () => {
- const ws = new WebSocketStream("ws://localhost:4242");
- const { readable, writable } = await ws.connection;
- const uint = new Uint8Array([102, 111, 111]);
- await writable.getWriter().write(uint);
- const res = await readable.getReader().read();
- assertEquals(res.value, uint);
- ws.close();
- await ws.closed;
-});