Implemented timeout() and req.clearTimeout()

lib/middleware/timeout.js

@@ -1,5 +1,43 @@
+/*!
+ * Connect - timeout
+ * Copyright(c) 2012 Hunter Loftis
+ * MIT Licensed
+ */
+
+/**
+ * Timeout:
+ *
+ * Invokes `socket.setTimeout` to timeout idle requests
+ * Adds req.clearTimeout() for long-running requests
+ *
+ *   - `throwError`: throw an error instead of writing a status code
+ *   - `time`: timeout length in ms (default: 10000)
+ *
+ * @param {Object} options
+ * @return {Function}
+ * @api public
+ */
+
 module.exports = function timeout(options) {
   return function(req, res, next) {
+
+    req.socket.removeAllListeners('timeout');   // http socket auto-destroys on timeout
+    req.socket.setTimeout(options.time || 10000, timed_out);
+
+    function timed_out() {
+      if (options.throwError) {
+        return next(new Error('Timeout ' + at));
+      }
+      else {
+        res.writeHead(options.code || 500);
+        res.end();
+      }
+    }
+
+    req.clearTimeout = function() {
+      req.socket.setTimeout(0);
+    };
+
     return next();
   };
 }

test/timeout.js

@@ -4,6 +4,7 @@ var connect = require('../');
 var app = connect();
 
 app.use(connect.timeout({
+  code: 503,
   time: 500
 }));
 
@@ -31,7 +32,7 @@ describe('connect.timeout()', function() {
     app.request()
     .get('/should/timeout')
     .end(function(res) {
-      res.statusCode.should.equal(500);
+      res.statusCode.should.equal(503);
       done();
     });
   });