add twitter stream

Author: e-jigsaw

README.md

@@ -30,6 +30,17 @@ You are GIF JOCKEY!!!!
 % foreman start
 ```
 
+## Configuation
+
+```
+REDISTOGO_URL=...
+CONSUMER_KEY=...
+CONSUMER_SECRET=...
+ACCESS_TOKEN=...
+ACCESS_TOKEN_SECRET=...
+HASH_TAG=#kosendj
+```
+
 ## Usage
 
 * for Users -> http://gjbu.herokuapp.com/usage ([Source](https://github.com/kosendj/gj/blob/master/views/usage.jade))

index.coffee

@@ -40,6 +40,7 @@ app.get '/bpm', require('./lib/bpm').get
 app.get '/usage', (req, res)-> res.render 'usage'
 
 io.on 'connection', require './lib/socket'
+require './lib/twitter'
 
 port = if process.env.PORT
          parseInt(process.env.PORT, 10)

lib/twitter.coffee

@@ -0,0 +1,17 @@
+Twit = require 'twit'
+io = process.globals.io
+
+twitter = new Twit
+  consumer_key: process.env.CONSUMER_KEY
+  consumer_secret: process.env.CONSUMER_SECRET
+  access_token: process.env.ACCESS_TOKEN
+  access_token_secret: process.env.ACCESS_TOKEN_SECRET
+
+replaceHashtag = new RegExp process.env.HASH_TAG, 'g'
+
+stream = twitter.stream 'statuses/filter',
+  track: process.env.HASH_TAG
+
+stream.on 'tweet', (tweet)->
+  io.emit 'tweet',
+    text: tweet.text.replace replaceHashtag, ''

package.json

@@ -19,6 +19,7 @@
     "redis": "^0.12.1",
     "request": "^2.40.0",
     "socket.io": "^1.0.6",
-    "stylus": "^0.49.3"
+    "stylus": "^0.49.3",
+    "twit": "^1.1.18"
   }
 }

public/js/screen.coffee

@@ -74,10 +74,10 @@ interrupt = (url)->
     main.update()
   , duration
 
-commentAdd = (body)->
+tweetAdd = (tweet)->
   top = $('.comment').length * 40
   top -= $('.commentContainer').height() while top > $('.commentContainer').height()
-  $("<p>").text(body)
+  $("<p>").text(tweet.text)
     .addClass('comment')
     .appendTo $('.commentContainer')
     .css
@@ -115,5 +115,5 @@ socket.on 'added',  -> if !main.$get('lock') then main.update()
 socket.on 'choose', -> if !main.$get('lock') then main.update()
 socket.on 'bpm', (bpm)-> main.$data.bpm = bpm
 socket.on 'djadded', interrupt
-socket.on 'comment', commentAdd
+socket.on 'tweet', tweetAdd
 socket.on 'name', (name)-> main.$data.name = name