Function constructor has 48 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  constructor (xyz, port) {
    super()
    http.globalAgent.maxSockets = Infinity
    this.port = port || CONFIG.getSelfConf().transport[0].port
    this.xyz = xyz

Function setSelfConf has 46 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    setSelfConf: function (aConf, cmdLineArgs) {
        Logger_1.logger.info('CONFIG :: Setting default selfConf');
        selfConf = Constants_1.CONSTANTS.defaultConfig.selfConf;
        Logger_1.logger.info('CONFIG :: Reading selfConf from user');
        selfConf = MergeRecursive(selfConf, aConf);

Function _ping has 44 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  function _ping () {
    let nodes = CONFIG.getSystemConf().nodes
    for (let node of nodes) {
      SR.transport.send({
        route: 'PING',

Function NodeXYZ has a Cognitive Complexity of 14 (exceeds 5 allowed). Consider refactoring.

Open

var NodeXYZ = (function () {
    /**
     * create a new xyz object
     * @param {Object} configuration configuration should have two main keys:
     *   - selfConf

• Read up
  Read up

Function roundRobinSendStrategy has 43 lines of code (exceeds 25 allowed). Consider refactoring.

Open

let roundRobinSendStrategy = function (params, next, done, xyz) {
  let servicePath = params[0].servicePath
  // let userPayload = params[0].payload
  let responseCallback = params[1]
  let route = params[0].route

Function _genericTransportInvoke has 43 lines of code (exceeds 25 allowed). Consider refactoring.

Open

export function _genericTransportInvoke (params: IServDiscMwParam, next, end, xyz: XYZ) {
  const targets = params.targets
  const transport = xyz.serviceRepository.transport
  const responseCallback = params.responseCallback
  const logger = xyz.logger

Function match has 39 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    match: function (path, serializedTree) {
        var matches = [];
        var pathToken = path.split('/');
        var pathIndex = 0;
        var pathTree = serializedTree;

Function send has 37 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    Transport.prototype.send = function (opt, responseCallback) {
        opt.route = opt.route || 'CALL';
        if (!this.routes[opt.route]) {
            Logger_1.logger.error("attempting to send message in route " + opt.route + ". DOES NOT EXIST");
            responseCallback('outgoing message route not found', null);

Function send has 37 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  send (opt: ITransportSendMessageParams, responseCallback?) {
    opt.route = opt.route || 'CALL'

    if (!this.routes[opt.route]) {
      logger.error(`attempting to send message in route ${opt.route}. DOES NOT EXIST`)

Function setSelfConf has 37 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  setSelfConf: (aConf, cmdLineArgs) => {
    logger.info('CONFIG :: Setting default selfConf')
    selfConf = CONSTANTS.defaultConfig.selfConf
    logger.info('CONFIG :: Reading selfConf from user')
    selfConf = MergeRecursive(selfConf, aConf)

Function xyzGeneric has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

function xyzGeneric(prefix) {
    if (prefix === void 0) { prefix = '--xyz-'; }
    var args = process.argv;
    var _args = {};
    for (var idx = 2; idx < args.length; idx++) {

• Read up
  Read up

Function HTTPServer has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

var HTTPServer = (function (_super) {
    __extends(HTTPServer, _super);
    /**
     * Creates a new HTTP server
     * @param xyz {Object} a reference to the curretn xyz object. will be filled automatically.

• Read up
  Read up

Function match has 35 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  match (path, serializedTree) {
    let matches = []
    let pathToken = path.split('/')
    let pathIndex = 0
    let pathTree = serializedTree

Function _loop_1 has 32 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        var _loop_1 = function (node) {
            SR.transport.send({
                route: 'PING',
                node: node
            }, function (err, body, res) {

Function _basicPingBootstrap has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

export default function _basicPingBootstrap (xyz: INodeXYZ, event, port) {
  let Util = xyz.Util
  let wrapper = Util.wrapper
  let logger = xyz.logger
  let CONFIG = xyz.CONFIG

• Read up
  Read up

Function roundRobinSendStrategy has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

let roundRobinSendStrategy = function (params, next, done, xyz) {
  let servicePath = params[0].servicePath
  // let userPayload = params[0].payload
  let responseCallback = params[1]
  let route = params[0].route

• Read up
  Read up

Function xyzGeneric has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

export function xyzGeneric (prefix = '--xyz-') {
  let args = process.argv
  let _args = {}
  for (let idx = 2; idx < args.length; idx++) {
    let arg = args[idx]

• Read up
  Read up

Function _basicPingBootstrap has a Cognitive Complexity of 11 (exceeds 5 allowed). Consider refactoring.

Open

function _basicPingBootstrap(xyz, event, port) {
    var Util = xyz.Util;
    var wrapper = Util.wrapper;
    var logger = xyz.logger;
    var CONFIG = xyz.CONFIG;

• Read up
  Read up

Function UDPServer has 31 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    function UDPServer(xyz, port) {
        var _this = _super.call(this) || this;
        _this.port = port;
        _this.xyz = xyz;
        /**

Function _httpExport has 30 lines of code (exceeds 25 allowed). Consider refactoring.

Open

var _httpExport = function (xMessageParam, next, end, xyz) {
    var requestConfig = xMessageParam.requestConfig;
    var responseCallback = xMessageParam.responseCallback;
    var postData = requestConfig.json;
    delete requestConfig.json;