HTTPiped

turn http.Server instances into readable streams

HTTPiped allows you to wrap an instance of http.Server into a Readable Stream in objectMode, opening up the opportunity to create stream-based middleware or micro-frameworks with ease.

Installation

npm install httpiped

Example

server.js

var HTTPiped = require("httpiped");
var http = require("http");
 
// middleware
var logger = require("./logger");
var handler = require("./handler");
 
var server = http.createServer();
var stream = new HTTPiped(server);
 
stream.pipe(logger())
      .pipe(handler());
 
server.listen(8080);

logger.js

var stream = require("stream");
 
var createLogger = function() {
    var logger = new stream.Transform({objectMode: true});
 
    logger._transform = function(client, encoding, done) {
        var conn = client.req.connection;
        console.log("Request from " + conn.remoteAddress);
        this.push(client);
        done();
    }
 
    return logger;
}
 
module.exports = createLogger;

handler.js

var stream = require("stream");
 
var createHandler = function() {
    var handler = new stream.Transform({objectMode: true});
 
    handler._transform = function(client, encoding, done) {
        var path = client.req.url;
        var split = path.split("/");
 
        client.res.end(JSON.stringify(split) + "\n");
 
        this.push(client);
        done();
    }
 
    return handler;
}
 
module.exports = createHandler;