adding internal functions into core

Author: mithunsatheesh

lib/node-rules.js

@@ -26,28 +26,13 @@
 
     RuleEngine.prototype.register = function(rules) {
 
-        if(typeof(rules) == "string") {
-
-            rules = JSON.parse(rules);
-
-        }
-
-
+        
         if(rules instanceof Array) {
 
-            rules = rules.map(function(rule){
-
-                rule.condition = eval("("+rule.condition+")");
-                return rule;
-
-            });
-
             this.rules = this.rules.concat(rules);
 
         } else if(rules !== null && typeof(rules) == "object") {
 
-            rules.condition = eval("("+rules.condition+")");
-
             this.rules.push(rules);
 
         }
@@ -76,61 +61,79 @@
 
         //these new attributes have to be in both last session and current session to support
         // the compare function
-        fact.complete = false;
+        var complete = false;
         fact.result = true;
 
         var session = _.clone(fact);
         var lastSession = _.clone(fact);
         var _rules = this.activeRules;
 
 
-
         (function doit(x) {
 
-            if (x < _rules.length && session.complete === false) {
 
-                var _rule = _rules[x].condition;
+            var R = {};
+            
+            R.when = function(outcome) {
+                
+                if (outcome) {
 
-                _rule.call(session, function(outcome) {
-                    
-                    if (outcome) {
+                    var _consequence = _rules[x].consequence;     
+                    _consequence.call(session, R);
 
-                        var _consequence = _rules[x].consequence;     
-                        
-                        _consequence.call(session, function() {
+                } else {
 
-                            if (!_.isEqual(lastSession,session)) {
+                    process.nextTick(function(){
+                        R.next();
+                    });
 
-                                lastSession = _.clone(session);
-                                process.nextTick(function(){
-                                    return doit(0);
-                                });
+                } 
+            
+            }
 
-                            } else {
-                                
-                                process.nextTick(function(){
-                                    return doit(x+1);
-                                });
-                                
-                            }
+            R.restart = function() {
 
-                        });
+                return doit(0);
 
-                    } else {
+            };
 
-                        process.nextTick(function(){
-                            return doit(x+1);
-                        });
+            R.stop = function() {
 
-                    } 
+                complete = true;
+                return doit(0);
 
-                
-                }); 
+            };
+
+            R.next = function () {
+
+                if (!_.isEqual(lastSession,session)) {
+
+                    lastSession = _.clone(session);
+                    process.nextTick(function(){
+                        R.restart();
+                    });
+
+                } else {
+                    
+                    process.nextTick(function(){
+                        return doit(x+1);
+                    });
+                    
+                }
+
+            }
+
+            if (x < _rules.length && complete === false) {
+
+                var _rule = _rules[x].condition;
+                _rule.call(session, R); 
 
             } else {
+
                 process.nextTick(function(){
                     return callback(session);
                 });
+
             }
 
         })(0);
@@ -202,10 +205,33 @@
 
         this.init();
 
+        if(typeof(rules) == "string") {
+
+            rules = JSON.parse(rules);
+
+        }
+
+        if(rules instanceof Array) {
+
+            rules = rules.map(function(rule){
+
+                rule.condition = eval("("+rule.condition+")");
+                return rule;
+
+            });
+
+        } else if(rules !== null && typeof(rules) == "object") {
+
+            rules.condition = eval("("+rules.condition+")");
+
+        }
+
         this.register(rules);
 
     };
 
+
+
     module.exports = RuleEngine;
 
 }(module.exports));