Function Connector$turnOn has a Cognitive Complexity of 64 (exceeds 5 allowed). Consider refactoring.

Open

function Connector$turnOn() {
    if (this.isOn)
        return logger.warn('data sources are already connected');

    var subscriptionPath = this._subscriptionPath =

• Read up
  Read up

Function Connector$turnOn has 118 lines of code (exceeds 25 allowed). Consider refactoring.

Open

function Connector$turnOn() {
    if (this.isOn)
        return logger.warn('data sources are already connected');

    var subscriptionPath = this._subscriptionPath =

Function linkDataSource has 104 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    function linkDataSource(reverseLink, fromDS, toDS, changesQueue, pathTranslation, patternTranslation, dataTranslation, dataValidation) {
        fromDS.onSync('datachanges', onData);
        return onData;

        function onData(message, batch) {

Function onData has 100 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        function onData(message, batch) {
            var sendData = {
                changes: [],
                transaction: batch.transaction
            }

Function prepareTransaction has a Cognitive Complexity of 26 (exceeds 5 allowed). Consider refactoring.

Open

function prepareTransaction(transaction) {
    var todo = []
        , pathsToSplice = []
        , pathsToChange = []
        , hadSplice

• Read up
  Read up

Function _synthesize has a Cognitive Complexity of 25 (exceeds 5 allowed). Consider refactoring.

Open

function _synthesize(synthesizer, path, parsedPath) {
    var methodCode = synthesizer({
            parsedPath: parsedPath,
            getPathNodeKey: pathUtils.getPathNodeKey
        });

• Read up
  Read up

Function _synthesize has 88 lines of code (exceeds 25 allowed). Consider refactoring.

Open

function _synthesize(synthesizer, path, parsedPath) {
    var methodCode = synthesizer({
            parsedPath: parsedPath,
            getPathNodeKey: pathUtils.getPathNodeKey
        });

File index.js has 293 lines of code (exceeds 250 allowed). Consider refactoring.

Open

'use strict';

var Mixin = require('ml-mixin')
    , MessageSource = require('./m_source')
    , _ = require('protojs')

File connector.js has 271 lines of code (exceeds 250 allowed). Consider refactoring.

Open

'use strict';

var Messenger = require('../messenger')
    , pathUtils = require('./path_utils')
    , _ = require('protojs')

Function prepareTransaction has 45 lines of code (exceeds 25 allowed). Consider refactoring.

Open

function prepareTransaction(transaction) {
    var todo = []
        , pathsToSplice = []
        , pathsToChange = []
        , hadSplice

Function Connector has 40 lines of code (exceeds 25 allowed). Consider refactoring.

Open

function Connector(ds1, mode, ds2, options) {
    setupMode.call(this, mode);

    _.extend(this, {
        ds1: ds1,

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

Open

    function addMessages(messages, messagesHash, rootPath, obj, msgType, valueProp) {
        _addMessages(rootPath, obj);


        function _addMessages(rootPath, obj) {

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

Open

function Connector(ds1, mode, ds2, options) {
    setupMode.call(this, mode);

    _.extend(this, {
        ds1: ds1,

• Read up
  Read up

Function linkDataSource has 8 arguments (exceeds 4 allowed). Consider refactoring.

Open

    function linkDataSource(reverseLink, fromDS, toDS, changesQueue, pathTranslation, patternTranslation, dataTranslation, dataValidation) {

Function addMessages has 6 arguments (exceeds 4 allowed). Consider refactoring.

Open

    function addMessages(messages, messagesHash, rootPath, obj, msgType, valueProp) {

Function _registerSubscriber has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

function _registerSubscriber(subscribersHash, message, subscriber) {
    if (! (subscribersHash[message] && subscribersHash[message].length)) {
        subscribersHash[message] = [];
        if (message instanceof RegExp)
            subscribersHash[message].pattern = message;

• Read up
  Read up

Function _removeSubscriber has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

function _removeSubscriber(subscribersHash, message, subscriber) {
    var msgSubscribers = subscribersHash[message];
    if (! msgSubscribers || ! msgSubscribers.length)
        return false; // nothing removed

• Read up
  Read up

Function _callSubscriber has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

function _callSubscriber(subscriber, message, data, callback, _synchronous) {
    var syncSubscriber = subscriber.options && subscriber.options.sync
        , synchro = (_synchronous && syncSubscriber !== false)
                  || syncSubscriber;

• Read up
  Read up

Function removeInternalMessage has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

function removeInternalMessage(message) {
    var sourceMessage = this.translateToSourceMessage(message);

    if (typeof sourceMessage == 'undefined') return;

• Read up
  Read up

Function _callPatternSubscribers has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

function _callPatternSubscribers(message, data, callback, calledMsgSubscribers, _synchronous) {