summaryrefslogtreecommitdiff
path: root/std/ws/test.ts
diff options
context:
space:
mode:
authorKitson Kelly <me@kitsonkelly.com>2020-03-29 04:03:49 +1100
committerGitHub <noreply@github.com>2020-03-28 13:03:49 -0400
commitbced52505f32d6cca4f944bb610a8a26767908a8 (patch)
treeda49a5df4b7bd6f8306248069228cd6bd0db1303 /std/ws/test.ts
parent1397b8e0e7c85762e19d88fde103342bfa563360 (diff)
Update to Prettier 2 and use ES Private Fields (#4498)
Diffstat (limited to 'std/ws/test.ts')
-rw-r--r--std/ws/test.ts46
1 files changed, 23 insertions, 23 deletions
diff --git a/std/ws/test.ts b/std/ws/test.ts
index f1efa8e40..583750bb1 100644
--- a/std/ws/test.ts
+++ b/std/ws/test.ts
@@ -14,7 +14,7 @@ import {
readFrame,
unmask,
writeFrame,
- createWebSocket
+ createWebSocket,
} from "./mod.ts";
import { encode, decode } from "../strings/mod.ts";
import Writer = Deno.Writer;
@@ -50,7 +50,7 @@ test("[ws] read masked text frame", async () => {
0x9f,
0x4d,
0x51,
- 0x58
+ 0x58,
])
)
);
@@ -136,8 +136,8 @@ test("[ws] acceptable", () => {
const ret = acceptable({
headers: new Headers({
upgrade: "websocket",
- "sec-websocket-key": "aaa"
- })
+ "sec-websocket-key": "aaa",
+ }),
});
assertEquals(ret, true);
@@ -148,12 +148,12 @@ test("[ws] acceptable", () => {
["host", "127.0.0.1:9229"],
[
"sec-websocket-extensions",
- "permessage-deflate; client_max_window_bits"
+ "permessage-deflate; client_max_window_bits",
],
["sec-websocket-key", "dGhlIHNhbXBsZSBub25jZQ=="],
["sec-websocket-version", "13"],
- ["upgrade", "WebSocket"]
- ])
+ ["upgrade", "WebSocket"],
+ ]),
})
);
});
@@ -161,25 +161,25 @@ test("[ws] acceptable", () => {
test("[ws] acceptable should return false when headers invalid", () => {
assertEquals(
acceptable({
- headers: new Headers({ "sec-websocket-key": "aaa" })
+ headers: new Headers({ "sec-websocket-key": "aaa" }),
}),
false
);
assertEquals(
acceptable({
- headers: new Headers({ upgrade: "websocket" })
+ headers: new Headers({ upgrade: "websocket" }),
}),
false
);
assertEquals(
acceptable({
- headers: new Headers({ upgrade: "invalid", "sec-websocket-key": "aaa" })
+ headers: new Headers({ upgrade: "invalid", "sec-websocket-key": "aaa" }),
}),
false
);
assertEquals(
acceptable({
- headers: new Headers({ upgrade: "websocket", "sec-websocket-ky": "" })
+ headers: new Headers({ upgrade: "websocket", "sec-websocket-ky": "" }),
}),
false
);
@@ -205,7 +205,7 @@ test("[ws] write and read masked frame", async () => {
isLastFrame: true,
mask,
opcode: OpCode.TextFrame,
- payload: encode(msg)
+ payload: encode(msg),
},
buf
);
@@ -282,19 +282,19 @@ function dummyConn(r: Reader, w: Writer): Conn {
write: (x): Promise<number> => w.write(x),
close: (): void => {},
localAddr: { transport: "tcp", hostname: "0.0.0.0", port: 0 },
- remoteAddr: { transport: "tcp", hostname: "0.0.0.0", port: 0 }
+ remoteAddr: { transport: "tcp", hostname: "0.0.0.0", port: 0 },
};
}
function delayedWriter(ms: number, dest: Writer): Writer {
return {
write(p: Uint8Array): Promise<number> {
- return new Promise<number>(resolve => {
+ return new Promise<number>((resolve) => {
setTimeout(async (): Promise<void> => {
resolve(await dest.write(p));
}, ms);
});
- }
+ },
};
}
test({
@@ -308,7 +308,7 @@ test({
sock.send("first"),
sock.send("second"),
sock.ping(),
- sock.send(new Uint8Array([3]))
+ sock.send(new Uint8Array([3])),
]);
const bufr = new BufReader(buf);
const first = await readFrame(bufr);
@@ -322,7 +322,7 @@ test({
assertEquals(ping.opcode, OpCode.Ping);
assertEquals(third.opcode, OpCode.BinaryFrame);
assertEquals(bytes.equal(third.payload, new Uint8Array([3])), true);
- }
+ },
});
test("[ws] createSecKeyHasCorrectLength", () => {
@@ -337,7 +337,7 @@ test("[ws] WebSocket should throw `Deno.errors.ConnectionReset` when peer closed
const eofReader: Deno.Reader = {
read(_: Uint8Array): Promise<number | Deno.EOF> {
return Promise.resolve(Deno.EOF);
- }
+ },
};
const conn = dummyConn(eofReader, buf);
const sock = createWebSocket({ conn });
@@ -355,7 +355,7 @@ test("[ws] WebSocket shouldn't throw `Deno.errors.UnexpectedEof` on recive()", a
const eofReader: Deno.Reader = {
read(_: Uint8Array): Promise<number | Deno.EOF> {
return Promise.resolve(Deno.EOF);
- }
+ },
};
const conn = dummyConn(eofReader, buf);
const sock = createWebSocket({ conn });
@@ -373,10 +373,10 @@ test({
let timer: number | undefined;
const lazyWriter: Deno.Writer = {
write(_: Uint8Array): Promise<number> {
- return new Promise(resolve => {
+ return new Promise((resolve) => {
timer = setTimeout(() => resolve(0), 1000);
});
- }
+ },
};
const conn = dummyConn(buf, lazyWriter);
const sock = createWebSocket({ conn });
@@ -384,7 +384,7 @@ test({
const p = Promise.all([
sock.send("hello").catch(onError),
sock.send(new Uint8Array([1, 2])).catch(onError),
- sock.ping().catch(onError)
+ sock.ping().catch(onError),
]);
sock.closeForce();
assertEquals(sock.isClosed, true);
@@ -396,5 +396,5 @@ test({
// Wait for another event loop turn for `timeout` op promise
// to resolve, otherwise we'll get "op leak".
await delay(10);
- }
+ },
});