Add support for sending event requests via proxy

Author: ndmanvar

lib/transports.js

@@ -6,6 +6,7 @@ var timeoutReq = require('timed-out');
 
 var http = require('http');
 var https = require('https');
+var Tls = require('tls');
 
 function Transport() {}
 util.inherits(Transport, events.EventEmitter);
@@ -17,6 +18,7 @@ function HTTPTransport(options) {
 }
 util.inherits(HTTPTransport, Transport);
 HTTPTransport.prototype.send = function(client, message, headers, eventId, cb) {
+
   var options = {
     hostname: client.dsn.host,
     path: client.dsn.path + 'api/' + client.dsn.project_id + '/store/',
@@ -25,6 +27,17 @@ HTTPTransport.prototype.send = function(client, message, headers, eventId, cb) {
     port: client.dsn.port || this.defaultPort,
     ca: client.ca
   };
+
+  // set path apprpriately when using proxy
+  if (this.options.hasOwnProperty('host')) {
+      if (client.dsn.protocol === 'http') {
+        options.path = 'http://' + client.dsn.host + ':' + client.dsn.port + client.dsn.path + 'api/' + client.dsn.project_id + '/store/'
+      } else {
+        options.path = client.dsn.host + ':' + client.dsn.port;
+      }
+      delete options.hostname; // only 'host' should be set when using proxy
+  }
+
   for (var key in this.options) {
     if (this.options.hasOwnProperty(key)) {
       options[key] = this.options[key];
@@ -64,6 +77,22 @@ HTTPTransport.prototype.send = function(client, message, headers, eventId, cb) {
       cbFired = true;
     }
   });
+
+  // TLS connection for proxying to HTTPS endpoint
+  /* req.on('connect', function (res, socket, head) {
+      var cts = Tls.connect({
+      host: client.dsn.host,
+      socket: socket
+      }, function () {
+          cts.write('GET /welcome HTTP/1.1rnHost: sentry.iornrn');
+      });
+
+      cts.on('data', function (data) {
+          // console.log(data.toString());
+      });
+  });
+  req.end(); */
+  
   req.end(message);
 };
 
@@ -72,10 +101,37 @@ function HTTPSTransport(options) {
   this.transport = https;
   this.options = options || {};
 }
+
+function HTTPProxyTransport(options) {
+    // this.defaultPort = 80;
+    this.transport = http;
+    this.options = options || {};
+
+    // set host and port for proxy
+    this.options.host = options.proxyHost;
+    this.options.port = options.proxyPort;
+}
+
+function HTTPSProxyTransport(options) {
+    // Not working yet ):
+    this.defaultPort = 443;
+    this.transport = http;
+    this.options = options || {};
+    
+    this.options.host = options.proxyHost;
+    this.options.port = options.proxyPort;
+    this.options.method = 'CONNECT';
+}
+
 util.inherits(HTTPSTransport, HTTPTransport);
+util.inherits(HTTPProxyTransport, HTTPTransport);
+util.inherits(HTTPSProxyTransport, HTTPTransport);
 
 module.exports.http = new HTTPTransport();
 module.exports.https = new HTTPSTransport();
 module.exports.Transport = Transport;
 module.exports.HTTPTransport = HTTPTransport;
 module.exports.HTTPSTransport = HTTPSTransport;
+
+module.exports.HTTPProxyTransport = HTTPProxyTransport;
+module.exports.HTTPSProxyTransport = HTTPSProxyTransport;