archive-gh-me/node-http-proxy
1
0
Fork 0
mirror of https://github.com/http-party/node-http-proxy.git synced 2025-12-08 20:59:18 +00:00
Code Issues Projects Releases Wiki Activity

[fix] naming

Browse Source
This commit is contained in:
yawnt 2013-09-14 13:02:28 +02:00
parent 893100972c
commit 2a593664a5
2 changed files with 3 additions and 131 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
lib/caronte/passes/ws.js
View File

@ -1,5 +1,4 @@
var WebsocketStream = require('../streams/websocket'), var http = require('http'),
http = require('http'),
common = require('../common'), common = require('../common'),
passes = exports; passes = exports;

127
lib/caronte/streams/websocket.js
View File

@ -1,127 +0,0 @@
var Duplex = require('stream').Duplex,
common = require('../common'),
http = require('http'),
https = require('https');
module.exports = WebsocketStream;
function WebsocketStream(options, res) {
Duplex.call(this);
this.options = options;
this.res = res;
this.handshakeDone = false;
var self = this;
this.once('pipe', function(pipe) { self.onPipe(pipe); });
this.once('finish', function() { self.onFinish(); });
}
require('util').inherits(WebsocketStream, Duplex);
WebsocketStream.prototype.onPipe = function(req) {
this.req = req;
var self = this;
this.proxyReq = (self.options.ssl ? https : http).request(
common.setupOutgoing(self.options.ssl || {}, self.options, req)
);
this.proxyReq.once('socket', function(proxySocket) {
self.onSocket(proxySocket);
});
this.proxyReq.on('upgrade', function(proxyRes, proxySocket, proxyHead) {
self.onUpgrade(proxyRes, proxySocket, proxyHead);
});
this.proxyReq.on('error', function(e) {
self.onError(e);
});
};
WebsocketStream.prototype.onFinish = function() {
this.proxyReq.end();
};
WebsocketStream.prototype.onSocket = function(proxySocket) {
};
WebsocketStream.prototype.onUpgrade = function(proxyRes, proxySocket, proxyHead) {
var self = this;
this.handshake = {
headers : proxyRes.headers,
statusCode : proxyRes.statusCode
};
this.proxyRes = proxyRes;
this.proxySocket = proxySocket;
this.proxyHead = proxyHead;
proxySocket.setTimeout(0);
proxySocket.setNoDelay(true);
proxySocket.setKeepAlive(true, 0);
proxySocket.on('readable', function() {
self.read(0);
});
proxySocket.on('end', function() {
self.push(null);
});
self.emit('readable');
};
WebsocketStream.prototype.onError = function(e) {
};
WebsocketStream.prototype._write = function(chunk, encoding, callback) {
this.proxySocket.write(chunk, encoding, callback);
};
WebsocketStream.prototype._read = function(size) {
var chunk = (this.proxySocket ? this.proxySocket.read(size) : '') || '';
if(chunk && !this.handshakeDone) {
var headers = '';
if (this.handshake.statusCode && this.handshake.statusCode == 101) {
headers = [
'HTTP/1.1 101 Switching Protocols',
'Upgrade: websocket',
'Connection: Upgrade',
'Sec-WebSocket-Accept: ' + this.handshake.headers['sec-websocket-accept']
];
headers = headers.concat('', '').join('\r\n');
}
/*
* Socket.IO specific code
*/
/*var sdata = chunk.toString();
sdata = sdata.substr(0, sdata.search('\r\n\r\n'));
chunk = data.slice(Buffer.byteLength(sdata), data.length);
if (self.source.https && !self.target.https) { sdata = sdata.replace('ws:', 'wss:'); }
this.push(headers + sdata);
this.push(data);
this.handshakeDone = true;
return;
*/
this.push(headers);
this.push(chunk);
}
this.push(chunk);
};