keepalive sockets

Author: yawnt

.gitignore

@@ -3,3 +3,4 @@ node_modules
 cov
 atest.js
 notes
+prismus-proxy.js

lib/caronte/common.js

@@ -33,3 +33,12 @@ common.setupOutgoing = function(outgoing, options, req, forward) {
 
   return outgoing;
 };
+
+common.setupSocket = function(socket) {
+  socket.setTimeout(0);
+  socket.setNoDelay(true);
+
+  socket.setKeepAlive(true, 0);
+
+  return socket;
+};

lib/caronte/passes/ws.js

@@ -72,11 +72,15 @@ function XHeaders(req, socket, options) {
  *
  */
 function stream(req, socket, options, head) {
+  common.setupSocket(socket);
+
   var proxyReq = http.request(
     common.setupOutgoing(options.ssl || {}, options, req)
   );
 
   proxyReq.on('upgrade', function(proxyRes, proxySocket, proxyHead) {
+    common.setupSocket(proxySocket);
+
     if (proxyHead && proxyHead.length) proxySocket.unshift(proxyHead);
 
     socket.write('HTTP/1.1 101 Switching Protocols\r\n');

primus-proxy.js

@@ -0,0 +1,50 @@
+var http = require('http');
+var caronte = require('./');
+var Primus = require('primus');
+
+var server = http.createServer(function (req, res) {
+  res.writeHead(500);
+  res.end('Not Implemented\n');
+});
+
+var primus = new Primus(server, { transformer: 'engine.io' });
+var Socket = primus.Socket;
+
+primus.on('error', function (err) {
+  console.log('Primus ' + err);
+});
+
+primus.on('connection', function (spark) {
+  spark.write({ from: 'server', to: 'client' });
+
+  spark.on('data', function (data) {
+    console.dir(data);
+  });
+});
+
+primus.on('disconnection', function (spark) {
+  console.log('disconnected');
+});
+
+server.listen(9000);
+
+var proxy = caronte.createProxyServer({
+  ws: true,
+  target: 'http://localhost:9000'
+});
+
+var srv = proxy.listen(3000);
+
+var socket = new Socket('http://localhost:3000');
+
+socket.on('reconnecting', function () {
+  console.log('reconnecting');
+});
+
+socket.on('open', function () {
+  socket.write({ from: 'client', to: 'server' })
+});
+
+socket.on('data', function (data) {
+  console.dir(data);
+});