Store a realtime stream of Twitter search in Redis DB

gistfile1.coffee

redis = require('redis').createClient process.env['REDIS_PORT_6379_TCP_PORT'], process.env['REDIS_PORT_6379_TCP_ADDR']
redis.select 1
Twitter = require 'twitter'
credentials =
	consumer_key: process.env.TWITTER_CONSUMER_KEY
	consumer_secret: process.env.TWITTER_CONSUMER_SECRET
	access_token_key: process.env.TWITTER_ACCESS_TOKEN_KEY
	access_token_secret: process.env.TWITTER_ACCESS_TOKEN_SECRET
twitter = new Twitter credentials

keywords = 'Whatever'

twitter.stream 'statuses/filter', {track: keywords}, (stream) ->
	stream.on 'data', (data) ->
		unless data.retweeted_status
			console.log "#{data.user.screen_name} (#{data.user.followers_count}): #{data.text}"
			redis.lpush 'to_test', "User: #{data.user.screen_name} (#{data.user.followers_count}): #{data.text}"