Middleware

middleware.js

var HttpStream = require("http-stream")
    , chain = require("chain-stream")

var server = chain(HttpStream().listen(3000))

var serverWithMiddleware = server
    .map(function (duplex, callback) {
        getSession(duplex, function (err, session) {
            if (err) {
                return callback(err)
            }

            callback(null, {
                duplex: duplex
                , session: session
            })
        })
    })

serverWithMiddleware
    .filter(function (duplex) {
        return duplex.url === "/home"
    })
    .forEach(function (duplex) {
        duplex.end(homePageTemplate)
    })