index.js

var http = require('http'),
    express = require('express'),
    httpProxy = require('http-proxy'),
    url = require('url');


var selects = [];
  var simpleselect = {};

    simpleselect.query = 'body';
    simpleselect.func = function (node) {
      var s = '';
      var stream = node.createStream();
      stream.on('data', function(chunk) { s += chunk.toString(); });
      stream.on('end', function() {
        stream.end(s + '<script>alert1</script>');
      });
    }
    selects.push(simpleselect);

express()
  .use(require('harmon')([], selects))
  .use(function (req, res) {
    httpProxy
      .createProxyServer({ target: url.parse(req.url).protocol + "//" + url.parse(req.url).hostname })
      .web(req, res)
  })

  .use(function(req, res) {
    res.send();
  })
  .listen(8000)
;