Added loggin and several fixes.

packages/splitio-cache/es6/index.js

@@ -2,10 +2,11 @@
 
 var segmentChangesDataSource = require('./ds/segmentChanges');
 var splitChangesDataSource = require('./ds/splitChanges');
-
 var storage = require('./storage');
+var log = require('debug')('splitio-cache');
 
 function writer(authorizationKey) {
+  log(`Running updater using key: ${authorizationKey}`);
 
   return splitChangesDataSource({authorizationKey})
     .then(splitsMutator => {
@@ -21,4 +22,4 @@ function writer(authorizationKey) {
 
 }
 
-exports.writer = writer;
+module.exports = writer;

packages/splitio-cache/es6/storage/index.js

@@ -18,8 +18,8 @@ module.exports = {
     segments = segments.set(name, segmentSet);
   },
 
-  updateSplit(featureName, splitDTO) {
-    splits = splits.set(featureName, splitDTO);
+  updateSplit(featureName, split) {
+    splits = splits.set(featureName, split);
   },
 
   getSplit(featureName) {

packages/splitio-engine/es6/engine/index.js

@@ -2,6 +2,7 @@
 
 var partitionTypes = require('../partitions/types');
 var murmur = require('murmurhash-js');
+var log = require('debug')('splitio-engine');
 
 var engine = {
   /**
@@ -19,7 +20,12 @@ var engine = {
    * @return {boolean}
    */
   isOn(key /*: string */, seed /*: number */, partitions /*: Map */) {
-    return partitions.get(partitionTypes.enum.ON) >= (murmur(key, seed) % 100);
+    let percentageOn = partitions.get(partitionTypes.enum.ON);
+    let keyPercentageValue = (murmur(key, seed) % 100);
+
+    log(`[engine] percentage on ${percentageOn} and key ${keyPercentageValue}`);
+
+    return percentageOn >= keyPercentageValue;
   }
 };
 

packages/splitio-engine/es6/index.js

@@ -28,14 +28,14 @@ class Split {
   }
 
   isOn(key) {
-    this.evalutor(key, this.baseInfo.seed);
+    return this.evaluator(key, this.baseInfo.seed);
   }
 
   static parse(splitFlatStructure) {
     let {conditions, ...baseInfo} = splitFlatStructure;
     let {evaluator, segments} = parser(conditions);
 
-    return new SplitDTO(baseInfo, evaluator, segments);
+    return new Split(baseInfo, evaluator, segments);
   }
 
 }

packages/splitio-engine/es6/matchers/identity.js

@@ -1,5 +1,9 @@
 'use strict';
 
-module.exports = function () {
+var log = require('debug')('splitio-engine:matcher');
+
+module.exports = function identityMatcher() {
+  log('[identityMatcher] always true');
+
   return true;
 };

packages/splitio-engine/es6/matchers/segment.js

@@ -1,10 +1,15 @@
 'use strict';
 
 var storage = require('splitio-cache/src/storage');
+var log = require('debug')('splitio-engine:matcher');
 
 function matcherSegmentContext(segmentName /*: string */) {
   return function segmentMatcher(key /*: string */) {
-    return storage.getSegment(segmentName).has(key);
+    let isInSegment = storage.getSegment(segmentName).has(key);
+
+    log(`[segmentMatcher] evaluated ${segmentName} / ${key} => ${isInSegment}`);
+
+    return isInSegment;
   };
 }
 

packages/splitio-engine/es6/matchers/whitelist.js

@@ -1,6 +1,7 @@
-
 'use strict';
 
+var log = require('debug')('splitio-engine:matcher');
+
 /**
  * Check if a key is inside a whitelist.
  *
@@ -10,7 +11,11 @@
  */
 function whitelistMatcherContext(whitelist /*: Set */) {
   return function whitelistMatcher(key /*: string */) {
-    return whitelist.has(key);
+    let isInWhitelist = whitelist.has(key);
+
+    log(`[whitelistMatcher] evaluated ${whitelist} / ${key} => ${isInWhitelist}`);
+
+    return isInWhitelist;
   };
 }
 

packages/splitio/es6/core/browser.js

@@ -4,7 +4,10 @@ var updater = require('splitio-cache');
 
 var core = {
   schedule(fn /*: function */, delay /*: number */, ...params /*:? Array<any> */) {
-    setTimeout(fn, delay, ...params);
+    setTimeout(() => {
+      fn(...params);
+      this.schedule(fn, delay, ...params);
+    }, delay);
   },
 
   start(authorizationKey /*: string */) {
@@ -14,7 +17,7 @@ var core = {
       }
 
       // fire cache updater each 5 seconds
-      this.schedule(writer, 5000, authorizationKey);
+      this.schedule(updater, 5000, authorizationKey);
 
       return storage;
     });

packages/splitio/es6/index.js

@@ -1,6 +1,7 @@
 'use strict';
 
 var core = require('./core');
+var log = require('debug')('splitio');
 
 function splitter(authorizationKey /*: string */) {
   return core.start(authorizationKey).then(storage => {
@@ -9,7 +10,18 @@ function splitter(authorizationKey /*: string */) {
        * Evaluates is a given userId is enabled for a given feature.
        */
       isOn(userId /*: string */, featureName /*: string */) {
-        return storage.getSplit(featureName).evaluate(userId);
+        let split = storage.getSplit(featureName);
+
+        if (split) {
+          let splitEvaluation = split.isOn(userId);
+
+          log(`[splitio] feature ${featureName} key ${userId} evaluated as ${splitEvaluation}`);
+
+          return splitEvaluation;
+        } else {
+          console.log('Feature is not present yet');
+          return false;
+        }
       }
     };
   });

scripts/development.sh

@@ -1,13 +1,10 @@
 #!/usr/bin/env bash
 
-npm link packages/splitio-engine
-npm link packages/splitio-cache
-npm link packages/splitio
-
 cd packages/splitio-cache
 rm -rf src/
 rm -rf node_modules/
 npm install
+npm link
 npm run watch &
 npm run watch-test &
 cd -
@@ -16,6 +13,7 @@ cd packages/splitio-engine
 rm -rf src/
 rm -rf node_modules/
 npm install
+npm link
 npm run watch &
 npm run watch-test &
 cd -
@@ -24,6 +22,7 @@ cd packages/splitio
 rm -rf src/
 rm -rf node_modules/
 npm install
+npm link
 npm run watch &
 npm run watch-test &
 cd -