Fixes #20 and Fixes #21. Added an API to interact with the rule engine flow like .stop(), .restart() from the condition and consequence level. No more callbacks passed as parameter and user doesnt need to call cb(). User just needs to indicate the flow engine needs follow via the API.

Author: mithunsatheesh

lib/node-rules.js

@@ -69,64 +69,66 @@
         var _rules = this.activeRules;
 
 
-        (function doit(x) {
+        (function FnRuleLoop(x) {
 
 
-            var R = {};
-            
-            R.when = function(outcome) {
+            var API = {
+
+                "when" : function(outcome) {
 
-                if (outcome) {
+                    if (outcome) {
 
-                    var _consequence = _rules[x].consequence;     
-                    _consequence.call(session, R);
+                        var _consequence = _rules[x].consequence;     
+                        _consequence.call(session, API);
 
-                } else {
+                    } else {
 
-                    process.nextTick(function(){
-                        R.next();
-                    });
+                        process.nextTick(function(){
+                            R.next();
+                        });
 
-                } 
-            
-            }
+                    } 
+                
+                },
 
-            R.restart = function() {
+                "restart" : function() {
 
-                return doit(0);
+                    return FnRuleLoop(0);
 
-            };
+                },
 
-            R.stop = function() {
+                "stop" : function() {
 
-                complete = true;
-                return doit(0);
+                    complete = true;
+                    return FnRuleLoop(0);
 
-            };
+                },
 
-            R.next = function () {
+                "next" : function () {
 
-                if (!_.isEqual(lastSession,session)) {
+                    if (!_.isEqual(lastSession,session)) {
 
-                    lastSession = _.clone(session);
-                    process.nextTick(function(){
-                        R.restart();
-                    });
+                        lastSession = _.clone(session);
+                        process.nextTick(function(){
+                            R.restart();
+                        });
 
-                } else {
-                    
-                    process.nextTick(function(){
-                        return doit(x+1);
-                    });
-                    
-                }
+                    } else {
+                        
+                        process.nextTick(function(){
+                            return FnRuleLoop(x+1);
+                        });
+                        
+                    }
 
-            }
+                }
 
+            };
+            
             if (x < _rules.length && complete === false) {
 
                 var _rule = _rules[x].condition;
-                _rule.call(session, R); 
+                _rule.call(session, API); 
 
             } else {