Skip to content

Instantly share code, notes, and snippets.

@tomkersten
Created November 9, 2011 07:52
Show Gist options
  • Star 1 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save tomkersten/1350771 to your computer and use it in GitHub Desktop.
Save tomkersten/1350771 to your computer and use it in GitHub Desktop.
/**
* Module dependencies.
*/
var express = require('express'),
routes = require('./routes'),
redis = require('redis'),
publisherClient = redis.createClient();
var app = module.exports = express.createServer();
// Configuration
app.configure(function(){
app.set('views', __dirname + '/views');
app.set('view engine', 'jade');
app.use(express.bodyParser());
app.use(express.methodOverride());
app.use(app.router);
app.use(express.static(__dirname + '/public'));
});
app.configure('development', function(){
app.use(express.errorHandler({ dumpExceptions: true, showStack: true }));
});
app.configure('production', function(){
app.use(express.errorHandler());
});
// Routes
app.get('/', function(req, res){
res.render('index');
});
app.get('/update-stream', function(req, res) {
// let request last as long as possible
req.socket.setTimeout(Infinity);
var messageCount = 0;
var subscriber = redis.createClient();
subscriber.subscribe("updates");
// In case we encounter an error...print it out to the console
subscriber.on("error", function(err) {
console.log("Redis Error: " + err);
});
// When we receive a message from the redis connection
subscriber.on("message", function(channel, message) {
messageCount++; // Increment our message count
res.write('id: ' + messageCount + '\n');
res.write("data: " + message + '\n\n'); // Note the extra newline
});
//send headers for event-stream connection
res.writeHead(200, {
'Content-Type': 'text/event-stream',
'Cache-Control': 'no-cache',
'Connection': 'keep-alive'
});
res.write('\n');
// The 'close' event is fired when a user closes their browser window.
// In that situation we want to make sure our redis channel subscription
// is properly shut down to prevent memory leaks...and incorrect subscriber
// counts to the channel.
req.on("close", function() {
subscriber.unsubscribe();
subscriber.quit();
});
});
app.get('/fire-event/:event_name', function(req, res) {
publisherClient.publish( 'updates', ('"' + req.params.event_name + '" page visited') );
res.writeHead(200, {'Content-Type': 'text/html'});
res.write('All clients have received "' + req.params.event_name + '"');
res.end();
});
app.listen(8000);
console.log("Express server listening on port %d in %s mode", app.address().port, app.settings.env);
@hagemann
Copy link

Infinity in line #40 should be Number.MAX_SAFE_INTEGER or else you will get "RangeError: "msecs" argument must be a non-negative finite number":

req.socket.setTimeout(Number.MAX_SAFE_INTEGER)

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment