primus jwt

primus_jwt.js

'use strict';
var Primus = require('primus.io'),
    authParser = require('parse-bearer-token'),
    config = require('../../../config'),
    debug = require('debug')('myprimus'),
    jwt = require('jsonwebtoken');

function authCheck(token, req, done){
    jwt.verify(token, config.jwt_secret, function(err, decoded) {
        if (err) {
            debug('authCheck failed');
            done(err);
        } else {
            debug('authCheck passed');
            req.decoded_token = decoded;
            done();
        }

    });
}

function setup(server){
    var primus = new Primus(server, { transformer: 'websockets', parser: 'JSON' , timeout: 630000});

    primus.authorize(function (req, done) {
        var token;

        try { token = authParser(req) }
        catch (ex) { return done(ex) }
        authCheck(token, req, done);
    });

    primus.on('connection', function (spark) {
        debug('primus client connected');
    });
}

module.exports.setup = setup;