twitter websocket sample

gistfile1.txt

$ npm install twitter ws
$ node twitter-websocket

twitter-websocket.js

var Twitter = require('twitter');
var client  = new Twitter({
	consumer_key        : 'XXXXXXXXXXXXXXXXXXXXXXXXX',
	consumer_secret     : 'XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX',
	access_token_key    : 'XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX',
	access_token_secret : 'XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX'
});

var WebSocketServer = require('ws').Server;
var wss             = new WebSocketServer({ port: 3000 });

client.stream('statuses/filter', {track: 'oculus rift'}, function(stream) {
	wss.on('connection', function connection(ws) {
		stream.on('data', function(tweet) {
			ws.send(tweet);
		});
	});
});