@nestjs/platform-ws
Advanced tools
Comparing version 10.2.6 to 10.2.7
@@ -115,17 +115,22 @@ "use strict"; | ||
httpServer.on('upgrade', (request, socket, head) => { | ||
const baseUrl = 'ws://' + request.headers.host + '/'; | ||
const pathname = new URL(request.url, baseUrl).pathname; | ||
const wsServersCollection = this.wsServersRegistry.get(port); | ||
let isRequestDelegated = false; | ||
for (const wsServer of wsServersCollection) { | ||
if (pathname === wsServer.path) { | ||
wsServer.handleUpgrade(request, socket, head, (ws) => { | ||
wsServer.emit('connection', ws, request); | ||
}); | ||
isRequestDelegated = true; | ||
break; | ||
try { | ||
const baseUrl = 'ws://' + request.headers.host + '/'; | ||
const pathname = new URL(request.url, baseUrl).pathname; | ||
const wsServersCollection = this.wsServersRegistry.get(port); | ||
let isRequestDelegated = false; | ||
for (const wsServer of wsServersCollection) { | ||
if (pathname === wsServer.path) { | ||
wsServer.handleUpgrade(request, socket, head, (ws) => { | ||
wsServer.emit('connection', ws, request); | ||
}); | ||
isRequestDelegated = true; | ||
break; | ||
} | ||
} | ||
if (!isRequestDelegated) { | ||
socket.destroy(); | ||
} | ||
} | ||
if (!isRequestDelegated) { | ||
socket.destroy(); | ||
catch (err) { | ||
socket.end('HTTP/1.1 400\r\n' + err.message); | ||
} | ||
@@ -132,0 +137,0 @@ }); |
{ | ||
"name": "@nestjs/platform-ws", | ||
"version": "10.2.6", | ||
"version": "10.2.7", | ||
"description": "Nest - modern, fast, powerful node.js web framework (@platform-ws)", | ||
@@ -22,3 +22,3 @@ "author": "Kamil Mysliwiec", | ||
"tslib": "2.6.2", | ||
"ws": "8.13.0" | ||
"ws": "8.14.2" | ||
}, | ||
@@ -25,0 +25,0 @@ "peerDependencies": { |
23451
213