stream.js

var TwitterNode = require('./lib').TwitterNode;
var sys = require('sys');


var twit = new TwitterNode({
      user: 'tuitersbolivia'
    , password: 'asdf'
});


//twit.track("bolivia");
twit.params['count'] = 1000;
twit.headers['User-Agent'] = 'node.js';
twit.action = 'filter';

twit.track("nowplaying");
twit.track("Ray J");
twit.track("retweetthisif");
twit.track("someonetell");

function getTime() {
    return new Date().getTime();
}

var counter = 0;
var startTime = getTime();
var endTime = getTime();

twit.addListener('tweet', function(tweet) {
        ++counter;
        sys.puts("@" + tweet.user.screen_name + ": " + tweet.text);
    }).addListener('limit', function(limit) {
        sys.puts("LIMIT: " + sys.inspect(limit));
    }).addListener('delete', function(del) {
        sys.puts("DELETE: " + sys.inspect(del));
    }).addListener('close', function(response) {
        sys.puts("wave goodbye..." + response.statusCode);
    }).stream();

var echo_stats = function() {
    // update end time
    try {
        endTime = getTime();
        rate = (counter / (endTime - startTime) * 1000).toFixed(1);
    } catch (e) {
        rate = 0;
    }

    // display memory & tweet stats
    mem = (process.memoryUsage().rss / 1024 / 1024).toFixed(2);

    sys.debug("Tweet Rate: " + rate + " tweet/sec");
    sys.debug("Memory Usage: " +  mem + "M");
    sys.debug("Chunks Lenght: " + twit.chunks.length.toFixed(1));
    //sys.debug(sys.inspect(twit));

    // reset counter and timer  
    counter = 0;
    startTime = getTime();
};

// display initial stats
echo_stats();

// stats every 5 seconds
setInterval(echo_stats, 5000);