A simple example to create a websocket server and stream tweets of a specific hashtag to your browser.
$ sudo npm install socket.io
$ sudo npm install twitter
Get your Standard Twitter API credentials from https://apps.twitter.com/ .
Make sure to include any valid URL (eg. https://www.google.com) as the Callback URL, so that the keys can work as a browser app.
$ node ./app.js
Then open http://localhost:1337/ in your browser.
| var app = require('http').createServer(handler), | |
| io = require('socket.io').listen(app), | |
| fs = require('fs'), | |
| sys = require('sys'), | |
| twitter = require('twitter'); | |
| app.listen(1337); | |
| var twit = new twitter({ | |
| consumer_key: 'CONSUMER_KEY', | |
| consumer_secret: 'CONSUMER_SECRET', | |
| access_token_key: 'ACCESS_TOKEN_KEY', | |
| access_token_secret: 'ACCESS_TOKEN_SECRET' | |
| }); | |
| function handler (req, res) { | |
| fs.readFile(full_project_directory_ + '/index.html', | |
| function (err, data) { | |
| if (err) { | |
| res.writeHead(500); | |
| return res.end('Error loading index.html'); | |
| } | |
| res.writeHead(200); | |
| res.end(data); | |
| }); | |
| } | |
| var twee = io.of('tweet'); | |
| twit.stream('statuses/filter', { track: '#survivorgr' }, function(stream) { | |
| stream.on('data', function (data) { | |
| io.sockets.emit('tweet', data.text); | |
| console.log('.'); | |
| }); | |
| }); |
| <!doctype html> | |
| <title>Twitter Stream</title> | |
| <div id="tweets"></div> | |
| <script src="/socket.io/socket.io.js"></script> | |
| <script> | |
| var socket = io.connect('/'), | |
| tweets = document.getElementById('tweets'); | |
| socket.on('tweet', function (data) { | |
| tweets.innerHTML = tweets.innerHTML + '<br>' + data; | |
| }); | |
| </script> |