moon
/
enigma-bbs
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

#118: Crash on STDIO doors when logged in via WebSocket

This commit is contained in:
Bryan Ashby 2017-08-06 10:20:55 -06:00
parent 95696912ed
commit d5954f8198
1 changed files with 11 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
core/servers/login/websocket.js
View File

@ -13,7 +13,7 @@ const WebSocketServer = require('ws').Server;
const http = require('http'); const http = require('http');
const https = require('https'); const https = require('https');
const fs = require('graceful-fs'); const fs = require('graceful-fs');
const EventEmitter = require('events'); const Writable = require('stream');
const ModuleInfo = exports.moduleInfo = { const ModuleInfo = exports.moduleInfo = {
name : 'WebSocket', name : 'WebSocket',
@ -34,7 +34,7 @@ function WebSocketClient(ws, req, serverType) {
// This bridge makes accessible various calls that client sub classes // This bridge makes accessible various calls that client sub classes
// want to access on I/O socket // want to access on I/O socket
// //
this.socketBridge = new class SocketBridge extends EventEmitter { this.socketBridge = new class SocketBridge extends Writable {
constructor(ws) { constructor(ws) {
super(); super();
this.ws = ws; this.ws = ws;
@ -48,6 +48,15 @@ function WebSocketClient(ws, req, serverType) {
return this.ws.send(data, { binary : true }, cb); return this.ws.send(data, { binary : true }, cb);
} }
// we need to fake some streaming work
unpipe() {
Log.trace('WebSocket SocketBridge unpipe()');
}
resume() {
Log.trace('WebSocket SocketBridge resume()');
}
get remoteAddress() { get remoteAddress() {
// Support X-Forwarded-For and X-Real-IP headers for proxied connections // Support X-Forwarded-For and X-Real-IP headers for proxied connections
return (self.proxied && (req.headers['x-forwarded-for'] || req.headers['x-real-ip'])) || req.connection.remoteAddress; return (self.proxied && (req.headers['x-forwarded-for'] || req.headers['x-real-ip'])) || req.connection.remoteAddress;