summaryrefslogtreecommitdiffstats
path: root/test/websocket/websocketinit.js
diff options
context:
space:
mode:
authorDaniel Baumann <daniel.baumann@progress-linux.org>2024-05-21 20:56:19 +0000
committerDaniel Baumann <daniel.baumann@progress-linux.org>2024-05-21 20:56:19 +0000
commit0b6210cd37b68b94252cb798598b12974a20e1c1 (patch)
treee371686554a877842d95aa94f100bee552ff2a8e /test/websocket/websocketinit.js
parentInitial commit. (diff)
downloadnode-undici-0b6210cd37b68b94252cb798598b12974a20e1c1.tar.xz
node-undici-0b6210cd37b68b94252cb798598b12974a20e1c1.zip
Adding upstream version 5.28.2+dfsg1+~cs23.11.12.3.upstream/5.28.2+dfsg1+_cs23.11.12.3upstream
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to '')
-rw-r--r--test/websocket/websocketinit.js45
1 files changed, 45 insertions, 0 deletions
diff --git a/test/websocket/websocketinit.js b/test/websocket/websocketinit.js
new file mode 100644
index 0000000..4dda3b4
--- /dev/null
+++ b/test/websocket/websocketinit.js
@@ -0,0 +1,45 @@
+'use strict'
+
+const { test } = require('tap')
+const { WebSocketServer } = require('ws')
+const { WebSocket, Dispatcher, Agent } = require('../..')
+
+test('WebSocketInit', (t) => {
+ t.plan(2)
+
+ class WsDispatcher extends Dispatcher {
+ constructor () {
+ super()
+ this.agent = new Agent()
+ }
+
+ dispatch () {
+ t.pass()
+ return this.agent.dispatch(...arguments)
+ }
+ }
+
+ t.test('WebSocketInit as 2nd param', (t) => {
+ t.plan(1)
+
+ const server = new WebSocketServer({ port: 0 })
+
+ server.on('connection', (ws) => {
+ ws.send(Buffer.from('hello, world'))
+ })
+
+ t.teardown(server.close.bind(server))
+
+ const ws = new WebSocket(`ws://localhost:${server.address().port}`, {
+ dispatcher: new WsDispatcher()
+ })
+
+ ws.onerror = t.fail
+
+ ws.addEventListener('message', async (event) => {
+ t.equal(await event.data.text(), 'hello, world')
+ server.close()
+ ws.close()
+ })
+ })
+})