1 files changed, 130 insertions, 0 deletions
diff --git a/vnfmarket/src/main/webapp/vnfmarket/node_modules/karma/lib/middleware/proxy.js b/vnfmarket/src/main/webapp/vnfmarket/node_modules/karma/lib/middleware/proxy.js
new file mode 100644
index 00000000..a3e9f001
--- /dev/null
+++ b/vnfmarket/src/main/webapp/vnfmarket/node_modules/karma/lib/middleware/proxy.js
@@ -0,0 +1,130 @@
+var url = require('url')
+var httpProxy = require('http-proxy')
+
+var log = require('../logger').create('proxy')
+
+var parseProxyConfig = function (proxies, config) {
+  var proxyConfig = {}
+  var endsWithSlash = function (str) {
+    return str.substr(-1) === '/'
+  }
+
+  if (!proxies) {
+    return proxyConfig
+  }
+
+  Object.keys(proxies).forEach(function (proxyPath) {
+    var proxyUrl = proxies[proxyPath]
+    var proxyDetails = url.parse(proxyUrl)
+    var pathname = proxyDetails.pathname
+
+    // normalize the proxies config
+    // should we move this to lib/config.js ?
+    if (endsWithSlash(proxyPath) && !endsWithSlash(proxyUrl)) {
+      log.warn('proxy "%s" normalized to "%s"', proxyUrl, proxyUrl + '/')
+      proxyUrl += '/'
+      pathname += '/'
+    }
+
+    if (!endsWithSlash(proxyPath) && endsWithSlash(proxyUrl)) {
+      log.warn('proxy "%s" normalized to "%s"', proxyPath, proxyPath + '/')
+      proxyPath += '/'
+    }
+
+    if (pathname === '/' && !endsWithSlash(proxyUrl)) {
+      pathname = ''
+    }
+
+    proxyConfig[proxyPath] = {
+      host: proxyDetails.hostname,
+      port: proxyDetails.port,
+      baseProxyUrl: pathname,
+      https: proxyDetails.protocol === 'https:'
+    }
+
+    if (!proxyConfig[proxyPath].port) {
+      if (!proxyConfig[proxyPath].host) {
+        proxyConfig[proxyPath].host = config.hostname
+        proxyConfig[proxyPath].port = config.port
+      } else {
+        proxyConfig[proxyPath].port = proxyConfig[proxyPath].https ? '443' : '80'
+      }
+    }
+  })
+
+  return proxyConfig
+}
+
+/**
+ * Returns a handler which understands the proxies and its redirects, along with the proxy to use
+ * @param proxy A http-proxy.RoutingProxy object with the proxyRequest method
+ * @param proxies a map of routes to proxy url
+ * @return {Function} handler function
+ */
+var createProxyHandler = function (proxy, proxyConfig, proxyValidateSSL, urlRoot, config) {
+  var proxies = parseProxyConfig(proxyConfig, config)
+  var proxiesList = Object.keys(proxies).sort().reverse()
+
+  if (!proxiesList.length) {
+    var nullProxy = function createNullProxy (request, response, next) {
+      return next()
+    }
+    nullProxy.upgrade = function upgradeNullProxy () {}
+    return nullProxy
+  }
+
+  proxy.on('proxyError', function (err, req) {
+    if (err.code === 'ECONNRESET' && req.socket.destroyed) {
+      log.debug('failed to proxy %s (browser hung up the socket)', req.url)
+    } else {
+      log.warn('failed to proxy %s (%s)', req.url, err.message)
+    }
+  })
+
+  var middleware = function createProxy (request, response, next) {
+    for (var i = 0; i < proxiesList.length; i++) {
+      if (request.url.indexOf(proxiesList[i]) === 0) {
+        var proxiedUrl = proxies[proxiesList[i]]
+
+        log.debug('proxying request - %s to %s:%s', request.url, proxiedUrl.host, proxiedUrl.port)
+        request.url = request.url.replace(proxiesList[i], proxiedUrl.baseProxyUrl)
+        proxy.proxyRequest(request, response, {
+          host: proxiedUrl.host,
+          port: proxiedUrl.port,
+          target: {https: proxiedUrl.https, rejectUnauthorized: proxyValidateSSL}
+        })
+        return
+      }
+    }
+
+    return next()
+  }
+
+  middleware.upgrade = function upgradeProxy (request, socket, head) {
+    // special-case karma's route to avoid upgrading it
+    if (request.url.indexOf(urlRoot) === 0) {
+      log.debug('NOT upgrading proxyWebSocketRequest %s', request.url)
+      return
+    }
+    for (var i = 0; i < proxiesList.length; i++) {
+      if (request.url.indexOf(proxiesList[i]) === 0) {
+        var proxiedUrl = proxies[proxiesList[i]]
+        log.debug('upgrade proxyWebSocketRequest %s to %s:%s',
+          request.url, proxiedUrl.host, proxiedUrl.port)
+        proxy.proxyWebSocketRequest(request, socket, head,
+          {host: proxiedUrl.host, port: proxiedUrl.port})
+      }
+    }
+  }
+
+  return middleware
+}
+
+var createProxyHandlerFactory = function (/* config */ config, /* config.proxies */ proxies,
+  /* config.proxyValidateSSL */ validateSSL) {
+  return createProxyHandler(new httpProxy.RoutingProxy({changeOrigin: true}),
+    proxies, validateSSL, config.urlRoot, config)
+}
+createProxyHandlerFactory.$inject = ['config', 'config.proxies', 'config.proxyValidateSSL']
+
+exports.create = createProxyHandlerFactory