From 9190061ba4b28dfdb1efafa8a662da2a0809add4 Mon Sep 17 00:00:00 2001
From: Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com>
Date: Mon, 17 Oct 2022 07:24:20 -0700
Subject: Update websocket-server.test.ts
---
test/bun.js/websocket-server.test.ts | 41 ++++++++++++++++++++++++++++++++++++
1 file changed, 41 insertions(+)
(limited to 'test')
diff --git a/test/bun.js/websocket-server.test.ts b/test/bun.js/websocket-server.test.ts
index dc9321f6a..61cd08f7a 100644
--- a/test/bun.js/websocket-server.test.ts
+++ b/test/bun.js/websocket-server.test.ts
@@ -12,6 +12,47 @@ function getPort() {
}
describe("websocket server", () => {
+ it("close inside open", async () => {
+ var resolve;
+ var server = serve({
+ port: getPort(),
+ websocket: {
+ open(ws) {},
+ message(ws, msg) {},
+ close() {
+ resolve();
+ },
+ },
+ fetch(req, server) {
+ if (
+ server.upgrade(req, {
+ data: "hello world",
+
+ // check that headers works
+ headers: {
+ "x-a": "text/plain",
+ },
+ })
+ ) {
+ if (server.upgrade(req)) {
+ throw new Error("should not upgrade twice");
+ }
+ return;
+ }
+
+ return new Response("noooooo hello world");
+ },
+ });
+
+ await new Promise((resolve_, reject) => {
+ resolve = resolve_;
+ const websocket = new WebSocket(`ws://localhost:${server.port}`);
+ websocket.onopen = () => websocket.close();
+ websocket.onmessage = (e) => {};
+ websocket.onerror = (e) => {};
+ });
+ server.stop();
+ });
it("can do hello world", async () => {
var server = serve({
port: getPort(),
--
cgit v1.2.3
/spawn-abort-signal-rebased'>ciro/spawn-abort-signal-rebased
| Unnamed repository; edit this file 'description' to name the repository. | |
Derrick Farris
Jarred Sumner
Michał Warda