socksub.io

SockSub + Socket.IO + Promises = great websocket interface

On the server

var http = require('http');
var SockSubIO = require('socksub.io');

var socksub = SockSubIO();

socksub.auth(function(credentials, next){
    if(credentials.username === 'me' && credentials.password === 'p4sSw0rD'){
        var user = {
            id: 1
        };
        return next(null, user);
    }
    throw new Error("Invalid credentials");
});

socksub.expose('add', function(nb1, nb2){
    return nb1 + nb2;
});

socksub.subscription('/myEvent/:user', function(req){
    if(req.params.user !== req.user.id){
        throw new Error("Subscription not authorized");
    }
});

var counter = 1;
setInterval(function(){
    socksub.dispatch('/myEvent/1', counter++);
    socksub.dispatch('/myEvent/2', counter++);
    socksub.dispatch('/myEvent/3', counter++);
}, 1000);

var server = http.createServer();
socksub.attach(server);

server.listen(3000);

On the client

var SockSubIO = require('socksub.io');

var socksub = SockSubIO();

socksub.login({
    username: 'me',
    password: 'p4sSw0rD'
}).done();

socksub.request('add', 3, 4).done(function(result){
    console.log("3 + 4 = %d", result);
});

socksub.on('/myEvent/1', function(counter){
    console.log('/myEvent/1', counter);
});
socksub.on('/myEvent/2', function(counter){
    console.log('/myEvent/2', counter);
});

socksub.subscribe('/myEvent/1').done();
socksub.subscribe('/myEvent/2').done();