var express = require('express'); var http = require('http'); var socketIo = require('socket.io'); var socketio_jwt = require('../../lib'); var jwt = require('jsonwebtoken'); var xtend = require('xtend'); var server; exports.start = function (options, callback) { if(typeof options == 'function'){ callback = options; options = {}; } options = xtend({ secret: 'aaafoo super sercret', timeout: 1000, handshake: true }, options); var app = express(); app.configure(function(){ this.use(express.json()); this.use(express.urlencoded()); }); app.post('/login', function (req, res) { var profile = { first_name: 'John', last_name: 'Doe', email: 'john@doe.com', id: 123 }; // We are sending the profile inside the token var token = jwt.sign(profile, options.secret, { expiresInMinutes: 60*5 }); res.json({token: token}); }); server = http.createServer(app); var sio = socketIo.listen(server); if (options.handshake) { // this.set('authorization', socketio_jwt.authorize(options)); sio.use(socketio_jwt.authorize(options)); } sio.set('log level', 0); if (options.handshake) { sio.sockets.on('echo', function (m) { sio.sockets.emit('echo-response', m); }); } else { sio.sockets .on('connection', socketio_jwt.authorize(options)) .on('authenticated', function (socket) { socket.on('echo', function (m) { socket.emit('echo-response', m); }); }); } server.listen(9000, callback); }; exports.stop = function (callback) { server.close(); callback(); };