conducto

conducto

WebSocket and HTTP framework. WIP

Server

var conducto = require('conducto');

var server = new conducto.Server();

server.use({
  //name of the method to handle
  method: 'sum',
  /* this is a json schema to validate the payload,
  if it fails an error will be sent to the client */
  payload: {
    required: true,
    type: 'array',
    items: {
      type: 'number'
    }
  },
  //res is the callback to be called to send the error or the result to the client
  handler: function(payload, res) {
    var sum = 0;
    for (var i = 0; i < payload.length; i++) {
      sum += payload[i];
    }
    //first argument is the error, second is the result
    res(null, sum);
  }
});
server.listen(3000);

Client

var client = new conducto.Client();
//open client socket to server address
client.open('ws://localhost:3000');
//wait for socket to open
client.on('open', function() {
 /*
  * first argument is the method name,
  * second the payload, optional
  * third a callback optional, (if absent will trigger a notifications, no id)
  */
  client.emit('sum', ['foo', 'bar'], function(err, res) {
    /* an err will be received as the payload doesn't
     * validate against the previously defined json schema
     */
  });

  client.emit('sum', [0, 1, 2, 3], function(err, res) {
    console.log(res);
    //6
  });
});