keepalive sockets

.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:https://localhost:9000'
+});
+
+var srv = proxy.listen(3000);
+
+var socket = new Socket('http:https://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);
+});