test.js

var Swarm = require('bugswarm-prt').Swarm;

var options = {
    apikey: '4d9b162a7f1b5122e551b427a3fb26d49df85f37',
    resource: 'aaeee512fda0a6dbb20d0baa5a05d85f35968777',
    swarms: ['9e4a8e85f12da09a3ed1cd0f3942f570ee12baa3']
};

var prosumer = new Swarm(options);

prosumer.on('message', function(message) {
    console.log('message: ' + JSON.stringify(message));
});

prosumer.on('error', function(err) {
    console.log(err);
});

prosumer.on('connect', function(err) {
    console.log('Connected!');

    //Let's start sending random temperatures
    //from Central Park!
    setInterval(function() {
        prosumer.send(JSON.stringify({
            'temperature': Math.floor((Math.random() * 100) + 1)
        }));
    }, 2000);
});

prosumer.on('presence', function(presence) {
    console.log('presence: ' + JSON.stringify(presence));
});

prosumer.on('disconnect', function() {
    console.log('disconnected');
});

//here is where the execution flow starts
prosumer.connect();