diff --git a/lib/caronte/passes/web.js b/lib/caronte/passes/web.js index 33da585..6f82da2 100644 --- a/lib/caronte/passes/web.js +++ b/lib/caronte/passes/web.js @@ -1,9 +1,7 @@ -var ForwardStream = require('../streams/forward'), - ProxyStream = require('../streams/proxy'), - http = require('http'), - https = require('https'), - common = require('../common'), - passes = exports; +var http = require('http'), + https = require('https'), + common = require('../common'), + passes = exports; /*! * Array of passes. @@ -87,6 +85,14 @@ function XHeaders(req, res, options) { */ function stream(req, res, options) { + if(options.forward) { + var forwardReq = (options.ssl ? https : http).request( + common.setupOutgoing(options.ssl || {}, options, req, 'forward') + ); + req.pipe(forwardReq); + return res.end(); + } + var proxyReq = (options.ssl ? https : http).request( common.setupOutgoing(options.ssl || {}, options, req) ); diff --git a/ttest.js b/ttest.js index 2101db6..3f945e4 100644 --- a/ttest.js +++ b/ttest.js @@ -32,13 +32,14 @@ client.on('open', function() { caronte.createProxyServer({ ws : true, - target: 'http://127.0.0.1:9090' + forward: 'http://127.0.0.1:9090' }).listen(8080); var srv = http.createServer(function(req, res) { res.end('ciao proxy'); + console.log('suca'); }).listen(9090); /* srv.on('upgrade', function(req, sock, head) {