new error propagation

lib/caronte.js

@@ -48,8 +48,9 @@ proxy.createProxyServer = function createProxyServer(options) {
     options[key].agent = new (options.ssl ? https.Agent : http.Agent)(options[key].maxSockets || 100);
   });
 
+  options.ee = new events.EventEmitter2({ wildcard: true, delimiter: ':' }); 
+
   return {
-    __proto__: new events.EventEmitter2({ wildcard: true, delimiter: ':' }), 
     web      : caronte.createWebProxy(options),
     ws       : caronte.createWsProxy(options),
     listen   : function listen(port) {
@@ -62,6 +63,9 @@ proxy.createProxyServer = function createProxyServer(options) {
       server.listen(port);
 
       return server;
+    },
+    emitter  : function() {
+      return options.ee;
     }
   };
 };

lib/caronte/index.js

@@ -33,19 +33,20 @@ function createRightProxy(type) {
     return function(req, res) {
       var self = this,
           ev   = 'caronte:' + type + ':';
-      //self.emit(ev + 'begin', req, res); 
+      options.ee.emit(ev + 'begin', req, res); 
 
 
       passes.some(function(pass) {
         var evnt = ev + pass.name.toLowerCase();
 
-        //self.emit(evnt + 'begin', req, res);
-        var val = pass(req, res, options, self); 
-        //self.emit(evnt + 'end');
+        options.ee.emit(evnt + 'begin', req, res); 
+        var val = pass(req, res, options); 
+        options.ee.emit(evnt + 'end');
+
         return val;
       });
 
-      //self.emit(ev + 'end');
+      options.ee.emit(ev + 'end');
     };   
   };
 }

lib/caronte/passes/web.js

@@ -79,18 +79,17 @@ function XHeaders(req, res, options) {
  * @param {ClientRequest} Req Request object
  * @param {IncomingMessage} Res Response object  
  * @param {Object} Options Config object passed to the proxy
- * @param {Object} Instance Proxy object that emits events
  *
  * @api private
  */
 
-function stream(req, res, options, instance) {
+function stream(req, res, options) {
   if(options.forward) {
-    req.pipe(new ForwardStream(options, instance));
+    req.pipe(new ForwardStream(options));
   }
 
   if(options.target) {
-    return req.pipe(new ProxyStream(options, res, instance)).pipe(res);
+    return req.pipe(new ProxyStream(options, res)).pipe(res);
   }
 
   res.end();
@@ -99,4 +98,4 @@ function stream(req, res, options, instance) {
 ] // <--
   .forEach(function(func) {
     passes[func.name] = func;   
-  });
+  });

lib/caronte/streams/proxy.js

@@ -3,12 +3,11 @@ var Duplex   = require('stream').Duplex,
     http     = require('http'),
     https    = require('https');
 
-function ProxyStream(options, res, instance) {
+function ProxyStream(options, res) {
   Duplex.call(this);
 
   this.options  = options;
   this.res      = res;
-  this.instance = instance;
 
   var self = this;
 
@@ -86,7 +85,7 @@ ProxyStream.prototype.onResponse = function(proxyRes) {
 };
 
 ProxyStream.prototype.onError = function(e) {
-  if(this.instance.emit('proxyError', this.req, this.res, e)) return;
+  if(this.options.ee.emit('proxyError', this.req, this.res, e)) return;
 
   this.res.writeHead(500, { 'Content-Type': 'text/plain' });
   this.res.end('Internal Server Error');
@@ -102,4 +101,4 @@ ProxyStream.prototype._read = function(size) {
   this.push(chunk);
 };
 
-module.exports = ProxyStream;
+module.exports = ProxyStream;

lib/caronte/streams/websocket.js

@@ -36,10 +36,12 @@ WebsocketStream.prototype.onPipe = function(req) {
 };
 
 WebsocketStream.prototye.onFinish = function() {
-
+  this.proxyReq.end();
 };
 
 WebsocketStream.prototype.onResponse = function(proxyRes) {
+  this.proxyRes = proxyRes;
+
 
 };