grabtweets.js

var myArgs = process.argv.slice(2);
console.log("Streaming for " + myArgs[0]);

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

oa = new OAuth("credentials_here");

var access_token = "";
var access_token_secret = "";

var request = oa.get("https://stream.twitter.com/1.1/statuses/filter.json?track=" + myArgs[0], access_token, access_token_secret);

var tweetsProcessed = 0;
MongoClient.connect("mongodb://localhost:27017/tweetograph", function(error, database) {
  request.addListener('response', function(response) {
	
		response.setEncoding('utf8');
		
		response.addListener('data', function(chunk) {
		
			var theTweets = JSON.parse(chunk);
			
			//console.log(theTweets);
			
			
				var collection = database.collection('biebertweetTest');
				collection.insert(theTweets, function(err, result) {});
				tweetsProcessed++;
				console.log("Tweets processed and saved: " + tweetsProcessed);
			
			
		});
		
		response.addListener('end', function() {
			console.log('--- END ---');
		});
		
	});
});

request.end();