aboutsummaryrefslogtreecommitdiff
path: root/test/bun.js/websocket-server.test.ts
diff options
context:
space:
mode:
authorGravatar Colin McDonnell <colinmcd94@gmail.com> 2022-11-09 15:40:40 -0800
committerGravatar GitHub <noreply@github.com> 2022-11-09 15:40:40 -0800
commitf7f1b604443c030afe29d1059b90f72c69afe081 (patch)
tree8f2397447b2a84dab02850007264b72cc565f5d6 /test/bun.js/websocket-server.test.ts
parentda257336b0b70df8c31da647496899cf70670000 (diff)
downloadbun-f7f1b604443c030afe29d1059b90f72c69afe081.tar.gz
bun-f7f1b604443c030afe29d1059b90f72c69afe081.tar.zst
bun-f7f1b604443c030afe29d1059b90f72c69afe081.zip
Add bun-types, add typechecking, add `child_process` types (#1475)
* Add bun-types to packages * Improve typing * Fix types in tests * Fix dts tests * Run formatter * Fix all type errors * Add strict mode, fix type errors * Add ffi changes * Move workflows to root * Add workflows * Remove labeler * Add child_process types * Fix synthetic defaults issue * Remove docs * Move scripts * Run prettier * Include examples in typechecking * captureStackTrace types * moved captureStackTrace types to globals * Address reviews Co-authored-by: Colin McDonnell <colinmcd@alum.mit.edu> Co-authored-by: Dylan Conway <dylan.conway567@gmail.com>
Diffstat (limited to 'test/bun.js/websocket-server.test.ts')
-rw-r--r--test/bun.js/websocket-server.test.ts57
1 files changed, 28 insertions, 29 deletions
diff --git a/test/bun.js/websocket-server.test.ts b/test/bun.js/websocket-server.test.ts
index 7c7869fad..dd88d6707 100644
--- a/test/bun.js/websocket-server.test.ts
+++ b/test/bun.js/websocket-server.test.ts
@@ -1,6 +1,6 @@
import { serve } from "bun";
import { describe, expect, it } from "bun:test";
-import { gcTick } from "gc";
+import { gcTick } from "./gc";
var port = 4321;
function getPort() {
@@ -25,7 +25,7 @@ describe("websocket server", () => {
close(ws) {
ws[method](
"all",
- method === "publishBinary" ? Buffer.from("bye!") : "bye!"
+ method === "publishBinary" ? Buffer.from("bye!") : "bye!",
);
},
},
@@ -39,16 +39,16 @@ describe("websocket server", () => {
});
try {
- const first = await new Promise((resolve2, reject2) => {
+ const first = await new Promise<WebSocket>((resolve2, reject2) => {
var socket = new WebSocket(
- `ws://${server.hostname}:${server.port}`
+ `ws://${server.hostname}:${server.port}`,
);
socket.onopen = () => resolve2(socket);
});
- const second = await new Promise((resolve2, reject2) => {
+ const second = await new Promise<WebSocket>((resolve2, reject2) => {
var socket = new WebSocket(
- `ws://${server.hostname}:${server.port}`
+ `ws://${server.hostname}:${server.port}`,
);
socket.onmessage = (ev) => {
var msg = ev.data;
@@ -107,7 +107,7 @@ describe("websocket server", () => {
},
});
- await new Promise((resolve_, reject) => {
+ await new Promise<void>((resolve_, reject) => {
resolve = resolve_;
const websocket = new WebSocket(`ws://${server.hostname}:${server.port}`);
websocket.onopen = () => {
@@ -138,8 +138,7 @@ describe("websocket server", () => {
if (
server.upgrade(req, {
data: "hello world",
-
- headers: 1238,
+ headers: 1238 as any,
})
) {
reject();
@@ -155,7 +154,7 @@ describe("websocket server", () => {
},
});
- await new Promise((resolve_, reject) => {
+ await new Promise<void>((resolve_, reject) => {
resolve = resolve_;
const websocket = new WebSocket(`ws://${server.hostname}:${server.port}`);
websocket.onopen = () => websocket.close();
@@ -194,7 +193,7 @@ describe("websocket server", () => {
},
});
- await new Promise((resolve, reject) => {
+ await new Promise<void>((resolve, reject) => {
const websocket = new WebSocket(`ws://${server.hostname}:${server.port}`);
websocket.onopen = () => {
websocket.send("hello world");
@@ -253,7 +252,7 @@ describe("websocket server", () => {
},
});
- return new Promise((resolve, reject) => {
+ return new Promise<void>((resolve, reject) => {
const websocket = new WebSocket(`ws://${server.hostname}:${server.port}`);
websocket.onopen = () => {
websocket.send("hello world");
@@ -312,7 +311,7 @@ describe("websocket server", () => {
return new Response("noooooo hello world");
},
});
- return new Promise((resolve, reject) => {
+ return new Promise<void>((resolve, reject) => {
const websocket = new WebSocket(`ws://${server.hostname}:${server.port}`);
websocket.onopen = () => {
websocket.send("hello world");
@@ -367,7 +366,7 @@ describe("websocket server", () => {
},
});
- await new Promise((resolve, reject) => {
+ await new Promise<boolean>((resolve, reject) => {
var counter = 0;
const websocket = new WebSocket(`ws://${server.hostname}:${server.port}`);
websocket.onopen = () => {
@@ -399,7 +398,7 @@ describe("websocket server", () => {
});
it("does not upgrade for non-websocket connections", async () => {
- await new Promise(async (resolve, reject) => {
+ await new Promise<void>(async (resolve, reject) => {
var server = serve({
port: getPort(),
websocket: {
@@ -425,7 +424,7 @@ describe("websocket server", () => {
});
it("does not upgrade for non-websocket servers", async () => {
- await new Promise(async (resolve, reject) => {
+ await new Promise<void>(async (resolve, reject) => {
var server = serve({
port: getPort(),
@@ -465,7 +464,7 @@ describe("websocket server", () => {
},
});
- await new Promise((resolve, reject) => {
+ await new Promise<void>((resolve, reject) => {
const websocket = new WebSocket(`ws://${server.hostname}:${server.port}`);
websocket.onmessage = (e) => {
@@ -487,7 +486,7 @@ describe("websocket server", () => {
});
it("publishText()", async () => {
- await new Promise((resolve, reject) => {
+ await new Promise<void>((resolve, reject) => {
var server = serve({
port: getPort(),
websocket: {
@@ -515,7 +514,7 @@ describe("websocket server", () => {
it("publishBinary()", async () => {
const bytes = Buffer.from("hello");
- await new Promise((resolve, reject) => {
+ await new Promise<void>((resolve, reject) => {
var server = serve({
port: getPort(),
websocket: {
@@ -542,7 +541,7 @@ describe("websocket server", () => {
});
it("sendText()", async () => {
- await new Promise((resolve, reject) => {
+ await new Promise<void>((resolve, reject) => {
var server = serve({
port: getPort(),
websocket: {
@@ -570,7 +569,7 @@ describe("websocket server", () => {
it("sendBinary()", async () => {
const bytes = Buffer.from("hello");
- await new Promise((resolve, reject) => {
+ await new Promise<void>((resolve, reject) => {
var server = serve({
port: getPort(),
websocket: {
@@ -616,7 +615,7 @@ describe("websocket server", () => {
},
});
- await new Promise((resolve, reject) => {
+ await new Promise<void>((resolve, reject) => {
const websocket = new WebSocket(`ws://${server.hostname}:${server.port}`);
websocket.onmessage = (e) => {
@@ -654,14 +653,14 @@ describe("websocket server", () => {
fetch(req, server) {
if (
server.upgrade(req, {
- count: 0,
+ data: { count: 0 },
})
)
return new Response("noooooo hello world");
},
});
- await new Promise((resolve, reject) => {
+ await new Promise<void>((resolve, reject) => {
const websocket = new WebSocket(`ws://${server.hostname}:${server.port}`);
websocket.onerror = (e) => {
reject(e);
@@ -708,7 +707,7 @@ describe("websocket server", () => {
it("send rope strings", async () => {
var ropey = "hello world".repeat(10);
- var sendQueue = [];
+ var sendQueue: any[] = [];
for (var i = 0; i < 100; i++) {
sendQueue.push(ropey + " " + i);
}
@@ -737,7 +736,7 @@ describe("websocket server", () => {
},
});
- await new Promise((resolve, reject) => {
+ await new Promise<void>((resolve, reject) => {
const websocket = new WebSocket(`ws://${server.hostname}:${server.port}`);
websocket.onerror = (e) => {
reject(e);
@@ -771,7 +770,7 @@ describe("websocket server", () => {
// this test sends 100 messages to 10 connected clients via pubsub
it("pub/sub", async () => {
var ropey = "hello world".repeat(10);
- var sendQueue = [];
+ var sendQueue: any[] = [];
for (var i = 0; i < 100; i++) {
sendQueue.push(ropey + " " + i);
gcTick();
@@ -817,7 +816,7 @@ describe("websocket server", () => {
const connections = new Array(10);
const websockets = new Array(connections.length);
var doneCounter = 0;
- await new Promise((done) => {
+ await new Promise<void>((done) => {
for (var i = 0; i < connections.length; i++) {
var j = i;
var resolve, reject, resolveConnection, rejectConnection;
@@ -831,7 +830,7 @@ describe("websocket server", () => {
});
gcTick();
const websocket = new WebSocket(
- `ws://${server.hostname}:${server.port}`
+ `ws://${server.hostname}:${server.port}`,
);
websocket.onerror = (e) => {
reject(e);