primus.js

var http = require('http');
var Primus = require('primus');

var server = http.createServer(function (req, res) {
  res.writeHead(500);
  res.end('Not implemented\n');
});

var primus = new Primus(server, {transform: 'websockets', parser: 'JSON'});
var Socket = primus.Socket;

server.on('upgrade', function (req, socket, head) {
  console.log('test headers', req.headers);
});

primus.on('connection', function (spark) {
  console.log('spark headers', spark.headers);
  spark.end();
});


server.listen(3000, function() {
  var socket = new Socket('http://test:testpass@localhost:3000');

});