this.authenticate(req, (err) => {
if (err) {
socket.write(`HTTP/1.1 ${StatusCodes.UNAUTHORIZED} Unauthorized\r\n\r\n`);
- socket.destroy(err);
+ socket.destroy();
return;
}
this.webSocketServer.handleUpgrade(req, socket, head, (ws: WebSocket) => {
}
}
- private authenticate(req: IncomingMessage, next: (err: Error) => void): void {
+ private authenticate(req: IncomingMessage, next: (err?: Error) => void): void {
if (this.isBasicAuthEnabled() === true) {
if (this.isValidBasicAuth(req) === false) {
next(new Error('Unauthorized'));
} else {
- next(undefined);
+ next();
}
} else {
- next(undefined);
+ next();
}
}