Enable session.halt()

lib/flow.js

@@ -27,7 +27,8 @@ module.exports = declare(EventEmitter, {
             this.agenda.on("fire", bind(this, "emit", "fire"));
             this.agenda.on("focused", bind(this, "emit", "focused"));
             this.rootNode = new nodes.RootNode(this.workingMemory, this.agenda);
-            extd.bindAll(this, "halt", "assert", "retract", "modify", "focus", "emit", "getFacts");
+            extd.bindAll(this, "halt", "assert", "retract", "modify", "focus",
+              "emit", "getFacts", "getFact");
         },
 
         getFacts: function (Type) {
@@ -40,16 +41,29 @@ module.exports = declare(EventEmitter, {
             return ret;
         },
 
+        getFact: function (Type) {
+            var ret;
+            if (Type) {
+                ret = this.workingMemory.getFactsByType(Type);
+            } else {
+                ret = this.workingMemory.getFacts();
+            }
+            return ret && ret[0];
+        },
+
         focus: function (focused) {
             this.agenda.setFocus(focused);
             return this;
         },
 
         halt: function () {
             var strategy = this.executionStrategy;
+            /*
             if (strategy.matchUntilHalt) {
                 strategy.halt();
             }
+            */
+            strategy.halt();
             return this;
         },
 

package.json

@@ -59,7 +59,7 @@
     "author": "Doug Martin (http://c2fo.com)",
     "main": "index.js",
     "scripts": {
-        "test": "it -r dot",
+        "test": "it -r spec",
         "create-doc": "rm -rf docs/* && coddoc -d ./lib -f multi-html"
     },
     "directories": {

test/flow.test.js

@@ -0,0 +1,2 @@
+"use strict";
+require('./flow/index');

test/flow/index.js

@@ -5,6 +5,7 @@ require("./events.test");
 require("./exists.test");
 require("./from.test");
 require("./matchUntil.halt");
+require("./match.halt");
 require("./not.test");
 require("./or.test");
 require("./rule.test");

test/flow/match.halt.js

@@ -0,0 +1,36 @@
+"use strict";
+var it = require("it"),
+    nools = require("../../"),
+    assert = require("assert");
+
+it.describe("#matchHalt", function (it) {
+
+    function Count(c) {
+        this.count = c;
+    }
+
+    var session, flow = nools.flow("Match with halt Flow", function (flow) {
+
+        flow.rule("Stop", [Count, "c", "c.count == 6"], function () {
+            this.halt();
+        });
+
+        flow.rule("Inc", [Count, "c"], function (facts) {
+            facts.c.count++;
+            this.modify(facts.c);
+        });
+
+    });
+
+    it.beforeEach(function () {
+        session = flow.getSession(new Count(0));
+    });
+
+    it.should("stop match with halt", function () {
+        return session.match().then(function (err) {
+            assert.isUndefinedOrNull(err);
+            assert.equal(session.getFacts(Count)[0].count, 6);
+        });
+
+    });
+});