gjohnson · September 18, 2011 15:09
diff --git a/index.html b/index.html
 <!DOCTYPE html>
 <html>
 <head>
    <script src="http://ajax.googleapis.com/ajax/libs/jquery/1.6.4/jquery.min.js"></script>
 </head>
 <body>
 <div id="tweets"></div>
 <!-- 
    Since we bound the socket.io library to our web server, it will know about this file.
 -->
 <script src="http://localhost:8000/socket.io/socket.io.js"></script>
 <script>
 
  // connect to our websocket server, need to tell it which port
  var socket = io.connect('http://localhost', { port: 8000 });
  
  // wait for tweet events
  socket.on('tweet', function (data) {
    $('<p></p>').text(data.message).appendTo('#tweets');
  });
 </script>    
 </body>
 </html>
diff --git a/server.js b/server.js

 /**
 * Net module is needed to create a tcp server.
 */
 var net = require('net');

 /**
 * Http module for creating web servers.
 */
 var http = require('http');

 /**
 * System module for misc. things
 */
 var sys = require('sys');

 /**
 * Fs module for reading the file system.
 */
 var fs = require('fs');

 /**
 * Twitter module for accessing twitter api.
 * install it via `npm install twitter`
 */
 var twitter = require('twitter');

 /**
 * Websocket module for realtime goodness.
 * install via `npm install socket.io`
 */
 var io = require('socket.io');

 /**
 * The port to bind our server to. It can be set via
 * the environment variable, or defaulted.
 */
 var SOCKET_PORT = process.env.SOCKET_PORT || 8124;

 /**
 * The port we want our web server on. Same deal as above.
 */
 var WEB_PORT = process.env.WEB_PORT || 8000;

 /**
 * Create connection to twitter. Put your api keys here.
 */
 var tweets = new twitter({
    consumer_key: '',
    consumer_secret: '',
    access_token_key: '',
    access_token_secret: ''
 });

 /**
 * Holds our connected clients
 */
 var sockets = [];

 /**
 * Create a simple tcp server
 */
 var server = net.createServer(function(conn) {
 	// keeps track of our connected clients
 	sockets.push(conn);
 	
 	// when the client disconnected, we need to remove it
 	// other wise there will be a dead socket and when we
 	// attempt to write to it, our server will crash
 	conn.on('end', function() {
 		delete sockets[conn];
 	});
 });

 /**
 * Bind to our port
 */
 server.listen(SOCKET_PORT);

 /**
 * Create a simple http server to host our page and websockets.
 */
 var web = http.createServer(function(req, res) {
 	fs.readFile(__dirname + '/index.html', 'utf8', function(err, contents) {
 		res.writeHead(200, { 'Content-type': 'text/html' });
 		res.end(contents);
 	});	
 });

 /**
 * Bind to our port.
 */
 web.listen(WEB_PORT);

 /**
 * Tell the web socket module to listen with our web server.
 */
 io = io.listen(web);

 /**
 * Tweet stream. This probably is not the right way to do this... any suggestions?
 */
 tweets.stream('statuses/filter', { track: 'ncdevcon' }, function(stream) {
 	// data is streamed in and will emit the `data` event whenever new data arrives.
 	stream.on('data', function(data) {	
 		
 		// the stuff we want from the message
 		var message = data.user.screen_name + ': ' + data.text;
 		sys.puts(message + '\n');
 		
 		// push it out to all of your connected net clients
 		sockets.forEach(function(sock) {
 			sock.write(message + '\n');
 		});
 		
 		// now push it out to your web clients too under the "tweet" event
 		io.sockets.emit('tweet', {
 			message: message
 		});
 	});
 });
	<!DOCTYPE html>
	<html>
	<head>
	<script src="http://ajax.googleapis.com/ajax/libs/jquery/1.6.4/jquery.min.js"></script>
	</head>
	<body>
	<div id="tweets"></div>
	<!--
	Since we bound the socket.io library to our web server, it will know about this file.
	-->
	<script src="http://localhost:8000/socket.io/socket.io.js"></script>
	<script>

	// connect to our websocket server, need to tell it which port
	var socket = io.connect('http://localhost', { port: 8000 });

	// wait for tweet events
	socket.on('tweet', function (data) {
	$('<p></p>').text(data.message).appendTo('#tweets');
	});
	</script>
	</body>
	</html>

	/**
	* Net module is needed to create a tcp server.
	*/
	var net = require('net');

	/**
	* Http module for creating web servers.
	*/
	var http = require('http');

	/**
	* System module for misc. things
	*/
	var sys = require('sys');

	/**
	* Fs module for reading the file system.
	*/
	var fs = require('fs');

	/**
	* Twitter module for accessing twitter api.
	* install it via `npm install twitter`
	*/
	var twitter = require('twitter');

	/**
	* Websocket module for realtime goodness.
	* install via `npm install socket.io`
	*/
	var io = require('socket.io');

	/**
	* The port to bind our server to. It can be set via
	* the environment variable, or defaulted.
	*/
	var SOCKET_PORT = process.env.SOCKET_PORT \|\| 8124;

	/**
	* The port we want our web server on. Same deal as above.
	*/
	var WEB_PORT = process.env.WEB_PORT \|\| 8000;

	/**
	* Create connection to twitter. Put your api keys here.
	*/
	var tweets = new twitter({
	consumer_key: '',
	consumer_secret: '',
	access_token_key: '',
	access_token_secret: ''
	});

	/**
	* Holds our connected clients
	*/
	var sockets = [];

	/**
	* Create a simple tcp server
	*/
	var server = net.createServer(function(conn) {
	// keeps track of our connected clients
	sockets.push(conn);

	// when the client disconnected, we need to remove it
	// other wise there will be a dead socket and when we
	// attempt to write to it, our server will crash
	conn.on('end', function() {
	delete sockets[conn];
	});
	});

	/**
	* Bind to our port
	*/
	server.listen(SOCKET_PORT);

	/**
	* Create a simple http server to host our page and websockets.
	*/
	var web = http.createServer(function(req, res) {
	fs.readFile(__dirname + '/index.html', 'utf8', function(err, contents) {
	res.writeHead(200, { 'Content-type': 'text/html' });
	res.end(contents);
	});
	});

	/**
	* Bind to our port.
	*/
	web.listen(WEB_PORT);

	/**
	* Tell the web socket module to listen with our web server.
	*/
	io = io.listen(web);

	/**
	* Tweet stream. This probably is not the right way to do this... any suggestions?
	*/
	tweets.stream('statuses/filter', { track: 'ncdevcon' }, function(stream) {
	// data is streamed in and will emit the `data` event whenever new data arrives.
	stream.on('data', function(data) {

	// the stuff we want from the message
	var message = data.user.screen_name + ': ' + data.text;
	sys.puts(message + '\n');

	// push it out to all of your connected net clients
	sockets.forEach(function(sock) {
	sock.write(message + '\n');
	});

	// now push it out to your web clients too under the "tweet" event
	io.sockets.emit('tweet', {
	message: message
	});
	});
	});