Decouple

.eslintrc

@@ -1,8 +1,19 @@
 {
+  "extends": [
+    "eslint:recommended"
+  ],
+  "env": {
+        "node": true
+  },
+  "plugins": [
+    "mocha"
+  ],
   "parserOptions": {
     "ecmaVersion": 6
   },
   "rules": {
+    "eol-last": [2],
+    "no-trailing-spaces" : [2],
     "keyword-spacing": [
       2,
       {}
@@ -16,6 +27,23 @@
     "max-len": [
       2,
       100
+    ],
+    "comma-spacing": [
+      2,
+      { "before": false, "after": true }
+    ],
+    "space-infix-ops": [
+      2,
+     {"int32Hint": true}
+    ]
+  },
+  "overrides": [
+        {
+            "files": [ "test/**/*.js" ],
+            "env": { "mocha": true },
+            "rules": {
+                "max-nested-callbacks": [ "error", 8 ]
+            }
+        }
     ]
-  }
 }

.gitignore

@@ -2,3 +2,6 @@ node_modules
 datastore
 .env
 pidfile
+nocommit
+.nyc_output
+coverage

includes/buildURI.js

@@ -0,0 +1,31 @@
+/**
+ * Build URI from routeItem.endpointUrl and targetRequest.path
+ *
+ * @param String endpointUrl
+ * @param String endpointUrl
+ *
+ * @return String URI
+ */
+'use strict';
+
+module.exports = function(endpointUrl, path){
+  let URI = ''
+  if (endpointUrl && endpointUrl.length) {
+    URI += endpointUrl
+    if (endpointUrl[endpointUrl.length - 1] !== '/') {
+      URI += '/'
+    }
+  } else {
+    URI += '/'
+  }
+  if (path && path.length) {
+    for ( let i = 0; i < path.length; i++ ) {
+      if (path[i] !== '/') {
+        URI += path.substring(i)
+        break
+      }
+    }
+  }
+
+  return URI
+}

includes/checkConditions.js

@@ -0,0 +1,76 @@
+/**
+ * Check Conditions for request.
+ *
+ * @param Object conditions object with headers, payload and methods properties
+ * @param Object requestDetails http request details
+ * @param Object requestDetails http request json body.
+ *
+ * @return Boolean true if conditions are met
+ */
+'use strict';
+const debug = require('debug')('proxy:check-conditions');
+const getProperty = require('./getProperty.js')
+
+module.exports = function(conditions, requestDetails, jsonData) {
+  debug('checkConditions %O requestDetails: %O json: %O', conditions, requestDetails, jsonData)
+  if (conditions.headers && conditions.headers.length) {
+    for (let header of conditions.headers ) {
+      if (!requestDetails.headers[header.name]) {
+        return false
+      }
+      let receivedHeaderValue = requestDetails.headers[header.name]
+      if (header.isRegex) {
+        let pattern = new RegExp(header.value, "i")
+        if (!pattern.test(receivedHeaderValue)) {
+          return false
+        }
+      } else {
+        if (receivedHeaderValue !== header.value) {
+          return false
+        }
+      }
+    }
+  }
+  // check methods
+  if (conditions.methods && conditions.methods.length) {
+    if (conditions.methods.toUpperCase) {
+      if (requestDetails.method != conditions.methods.toUpperCase()) {
+        return false
+      }
+    } else {
+      for (let i in conditions.methods) {
+        conditions.methods[i] = conditions.methods[i].toUpperCase()
+      }
+      if (conditions.methods.indexOf(requestDetails.method) === -1) {
+        return false;
+      }
+    }
+
+  }
+  // check payload
+  if (conditions.payload && conditions.payload.length && jsonData) {
+    if (typeof jsonData != "object") {
+      return false
+    }
+    for (let payload of conditions.payload ) {
+      debug('Checking for payload conditions %O', payload)
+      let receivedPayloadValue = getProperty(payload.name, jsonData)
+      debug('receivedPayloadValue %O', receivedPayloadValue)
+      if (receivedPayloadValue instanceof Error) {
+        return false
+      }
+      if (payload.isRegex) {
+        let pattern = new RegExp(payload.value, "i")
+        debug('pattern.test %O', pattern.test(receivedPayloadValue))
+        if (!pattern.test(receivedPayloadValue)) {
+          return false
+        }
+      } else {
+        if (receivedPayloadValue !== payload.value) {
+          return false
+        }
+      }
+    }
+  }
+  return true
+}

includes/checkConditionsMingo.js

@@ -0,0 +1,49 @@
+/**
+ * Check Conditions for request.
+ *
+ * @param Object conditions object with headers, payload and methods properties
+ * @param Object requestDetails http request details
+ * @param Object requestDetails http request json body.
+ *
+ * @return Boolean true if conditions are met
+ */
+'use strict';
+const debug = require('debug')('proxy:check-conditions');
+const mingo = require('mingo')
+
+module.exports = function(conditions, requestDetails, jsonData) {
+  debug('checkConditions %O requestDetails: %O json: %O', conditions, requestDetails, jsonData)
+  if (conditions.headers ) {
+    let query = new mingo.Query(conditions.headers);
+    if (!query.test(requestDetails.headers)){
+      return false
+    }
+    //return mingo.find([requestDetails.headers], conditions.headers).count()
+
+  }
+  // check methods
+  if (conditions.methods && conditions.methods.length) {
+    if (conditions.methods instanceof Array) {
+      for (let i in conditions.methods) {
+        conditions.methods[i] = conditions.methods[i].toUpperCase()
+      }
+    } else if (conditions.methods.toUpperCase){
+      conditions.methods = conditions.methods.toUpperCase()
+    }
+    if (conditions.methods.indexOf(requestDetails.method) === -1) {
+      return false;
+    }
+  }
+  // check payload
+  if (conditions.payload) {
+    if (typeof jsonData != "object") {
+      return false
+    }
+    //return mingo.find([jsonData], conditions.payload).count()
+    let query = new mingo.Query(conditions.payload);
+    if (!query.test(jsonData)) {
+      return false
+    }
+  }
+  return true
+}

includes/checkConditionsMongo.js

@@ -0,0 +1,47 @@
+/**
+ * Check Conditions for request.
+ *
+ * @param Object conditions object with headers, payload and methods properties
+ * @param Object requestDetails http request details
+ * @param Object requestDetails http request json body.
+ *
+ * @return Boolean true if conditions are met
+ */
+'use strict';
+const debug = require('debug')('proxy:check-conditions');
+const sift = require('sift').default
+
+module.exports = function(conditions, requestDetails, jsonData) {
+  debug('checkConditions %O requestDetails: %O json: %O', conditions, requestDetails, jsonData)
+  if (conditions.headers ) {
+    let result = sift(conditions.headers, [requestDetails.headers])
+    if (!result.length){
+      return false
+    }
+
+  }
+  // check methods
+  if (conditions.methods && conditions.methods.length) {
+    if (conditions.methods instanceof Array) {
+      for (let i in conditions.methods) {
+        conditions.methods[i] = conditions.methods[i].toUpperCase()
+      }
+    } else if (conditions.methods.toUpperCase){
+      conditions.methods = conditions.methods.toUpperCase()
+    }
+    if (conditions.methods.indexOf(requestDetails.method) === -1) {
+      return false;
+    }
+  }
+  // check payload
+  if (conditions.payload) {
+    if (typeof jsonData != "object") {
+      return false
+    }
+    let result = sift(conditions.payload, [jsonData])
+    if (!result.length){
+      return false
+    }
+  }
+  return true
+}

includes/checkPath.js

@@ -0,0 +1,44 @@
+/**
+ * Check if path match route path.
+ *
+ * @param Object targetRequest  request details
+ * @param Object routeItem ob route table
+ *
+ * @return Boolean true if conditions are met
+ */
+'use strict';
+
+module.exports = function(targetRequest, routeItem) {
+  let targetRoutePathItems = targetRequest.route.split('/');
+
+  // routeItem is array of supporthed path (endpoints like /foo /bar/:test/foo)
+  for (let path of routeItem.path) {
+    // If route qual saved path
+    if (path == targetRequest.route) {
+      return true;
+    }
+
+    // If targetRoutePathItems.length == 1, and did not match
+    if (targetRoutePathItems.length == 1) {
+      continue;
+    }
+
+    let pathItems = path.split('/');
+    if (pathItems.length != targetRoutePathItems.length) {
+      continue;
+    }
+
+    routeItem.matchVariables = {}
+    for (var i = 0; i < targetRoutePathItems.length; i++) {
+      if (pathItems[i].charAt(0) == ':') {
+        routeItem.matchVariables[pathItems[i].substring(1)] = targetRoutePathItems[i];
+      } else {
+        if (targetRoutePathItems[i] != pathItems[i]) {
+          //if not matching items
+          return false
+        }
+      }
+    }
+    return true;
+  }
+}

includes/decodeData.js

@@ -0,0 +1,25 @@
+/**
+ * Decode buffer to specidied by content-type format.
+ *
+ * @param String phase(optional) hook phase: before, after, metric
+ * @param Buffer type(optional) hook type: adapter, notify, broadcast
+ *
+ * @return return buffer or object
+ */
+'use strict';
+
+module.exports = function(contentType, buffer){
+  let data = false
+  switch (contentType) {
+    case undefined: // version 1.x compatibility. If no content-type provided, assume json.
+    case 'application/json': {
+      data = JSON.parse(buffer);
+      break;
+    }
+    // Todo support more decoders here?
+    default: {
+      data = buffer
+    }
+  }
+  return data
+}

includes/findAllTargets.js

@@ -0,0 +1,50 @@
+/**
+ * Find all targets function
+ *
+ * @param Object targetRequest  request details
+ * @param String routeType(optional) of router: hook, handler, metric
+ * @param Object object all available routes
+ *
+ * @return array of objects with available routes
+ */
+'use strict';
+
+const debug = require('debug')('proxy:find-all-targets');
+const matchRoute = require('./matchRoute.js')
+
+module.exports = function(targetRequest, routeType, allRegisteredRoutes) {
+  debug('Find all routes %s', targetRequest.route);
+
+  var availableRoutes = [];
+  for (let i in allRegisteredRoutes) {
+    if (routeType) {
+      if (!allRegisteredRoutes[i].type) {
+        // Version 1.x compatibility
+        allRegisteredRoutes[i].type = "handler"
+      }
+      if (allRegisteredRoutes[i].type.toLowerCase() !== routeType) {
+        continue
+      }
+    }
+    // For easy deployment when service need to stop receiving new requests.
+    // Version 1.x compatibility
+    if (allRegisteredRoutes[i].online !== undefined) {
+      if (allRegisteredRoutes[i].online === false) {
+        continue
+      }
+    }
+    // Making copy of the router.
+    let routeItem = JSON.parse(JSON.stringify(allRegisteredRoutes[i]));
+    routeItem.matchVariables = {};
+    if (matchRoute(targetRequest, routeItem)) {
+      availableRoutes.push(routeItem);
+    }
+  }
+  debug('Available routes type: %s route: %s availableRoutes: %s', routeType,
+  targetRequest.route,  JSON.stringify(availableRoutes, null, 2));
+  if (availableRoutes.length == 0) {
+    debug('Not found for %s', targetRequest.route);
+    return new Error('Endpoint not found');
+  }
+  return availableRoutes;
+}