node-oauth testb.js

testb.js

var sys= require('sys');
var OAuth= require('oauth').OAuth;

oa= new OAuth("https://twitter.com/oauth/request_token",
                 "https://twitter.com/oauth/access_token", 
                 "consumer",  "secret", 
                 "1.0A", "http://localhost:3000/oauth/callback", "HMAC-SHA1");       

setInterval(function() {
  var request= oa.get("http://stream.twitter.com/1/statuses/sample.json", 'consumer-user', 'secret-user');
  request.addListener('response', function (response) {
    response.setEncoding('utf8');
    response.addListener('data', function (chunk) {
      console.log(chunk);
    });
    response.addListener('end', function () {
      console.log('--- END ---')
    });
  });

  request.end();

  oa.get("http://api.twitter.com/1/statuses/retweeted_by_me.json", 'consumer-user', 'secret-user', function(error, data) {
   // console.log(sys.inspect(data));
  });
}, 1000);