bitinflow/server
1
0
Fork 0
mirror of https://github.com/bitinflow/server.git synced 2026-03-13 13:35:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

wip

Browse Source
This commit is contained in:
Roman Shtylman
2016-01-13 22:12:46 -08:00
parent f12f1c81b3
commit 60813d6c04
1 changed files with 23 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
server.js
View File

@@ -62,7 +62,13 @@ function maybe_bounce(req, res, sock, head) {
var finished = false; var finished = false;
if (sock) { if (sock) {
sock.once('end', function() { sock.once('error', function(err) {
console.log('sock error', err);
finished = true;
});
sock.once('close', function() {
console.log('finished');
finished = true; finished = true;
}); });
} }
@@ -99,10 +105,15 @@ function maybe_bounce(req, res, sock, head) {
return; return;
} }
socket.once('error', function(err) {
console.log('socket error', err);
});
// websocket requests are special in that we simply re-create the header info // websocket requests are special in that we simply re-create the header info
// and directly pipe the socket data // and directly pipe the socket data
// avoids having to rebuild the request and handle upgrades via the http client // avoids having to rebuild the request and handle upgrades via the http client
if (res === null) { if (res === null) {
console.log('websocket');
var arr = [req.method + ' ' + req.url + ' HTTP/' + req.httpVersion]; var arr = [req.method + ' ' + req.url + ' HTTP/' + req.httpVersion];
for (var i=0 ; i < (req.rawHeaders.length-1) ; i+=2) { for (var i=0 ; i < (req.rawHeaders.length-1) ; i+=2) {
arr.push(req.rawHeaders[i] + ': ' + req.rawHeaders[i+1]); arr.push(req.rawHeaders[i] + ': ' + req.rawHeaders[i+1]);
@@ -113,7 +124,8 @@ function maybe_bounce(req, res, sock, head) {
socket.pipe(sock).pipe(socket); socket.pipe(sock).pipe(socket);
socket.write(arr.join('\r\n')); socket.write(arr.join('\r\n'));
socket.once('end', function() { socket.once('close', function() {
console.log('release websocket');
done(); done();
}); });
@@ -131,17 +143,23 @@ function maybe_bounce(req, res, sock, head) {
headers: req.headers headers: req.headers
}; };
console.log('req', req.url);
var client_req = http.request(opt, function(client_res) { var client_req = http.request(opt, function(client_res) {
// write response code and headers res.writeHead(client_res.statusCode, client_res.statusMessage, client_res.headers);
res.writeHead(client_res.statusCode, client_res.headers);
client_res.pipe(res); client_res.pipe(res);
on_finished(client_res, function(err) { on_finished(client_res, function(err) {
console.log('release client_req', req.url);
done(); done();
}); });
}); });
req.pipe(client_req); req.pipe(client_req);
client_req.on('error', function(err) { // ??
console.log('client request erorr', err);
done();
});
}); });
return true; return true;