add tests

test/bootstrap/index.js

@@ -9,7 +9,7 @@ global.should = global.chai.should();
  * Chai Plugins
  */
 
-//global.chai.use(require('chai-spies'));
+global.chai.use(require('chai-spies'));
 //global.chai.use(require('chai-http'));
 
 /*!

test/browser/index.html

@@ -6,6 +6,7 @@
     <link rel="stylesheet" href="../../node_modules/mocha/mocha.css" />
     <script src="../../node_modules/mocha/mocha.js"></script>
     <script src="../../node_modules/chai/chai.js"></script>
+    <script src="../../node_modules/chai-spies/chai-spies.js"></script>
     <script>
       mocha.setup('bdd')
       var should = chai.should();
@@ -14,7 +15,7 @@
     <script>
       dag = require('breeze-dag');
     </script>
-    <!-- <script src="../test.js"></script> -->
+    <script src="../dag.js"></script>
     <script>onload = function () {
       if (window.mochaPhantomJS) mochaPhantomJS.run()
       else mocha.run();

test/dag.js

@@ -0,0 +1,61 @@
+describe('dag', function () {
+  it('should run a set of edges in threads', function (done) {
+    var deps = [
+        [ null, 'a' ]
+      , [ 'a', 'b' ]
+      , [ 'a', 'c' ]
+      , [ 'a', 'f' ]
+      , [ 'd', 'e' ]
+      , [ 'b', 'd' ]
+    ];
+
+    var spy = chai.spy(function (e, next) {
+      setTimeout(next, 100);
+    });
+
+    dag(deps, 2, spy, function (err) {
+      should.not.exist(err);
+      spy.should.have.been.called.exactly(6);
+      done();
+    });
+  });
+
+  it('should bail on error', function (done) {
+    var deps = [
+        [ 'a', 'b' ]
+      , [ 'a', 'c' ]
+      , [ 'd', 'e' ]
+      , [ 'b', 'd' ]
+    ];
+
+    var spy = chai.spy(function (e, next) {
+      if (e === 'c') return next('err');
+      setTimeout(next, 100);
+    });
+
+    dag(deps, 2, spy, function (err) {
+      err.should.equal('err');
+      spy.should.have.been.called.exactly(3);
+      done();
+    });
+  });
+
+  it('should detect cyclical error', function (done) {
+    var deps = [
+        [ 'a', 'b' ]
+      , [ 'b', 'a' ]
+    ];
+
+    var spy = chai.spy(function (e, next) {
+      setTimeout(next, 10);
+    });
+
+    dag(deps, 2, spy, function (err) {
+      should.exist(err);
+      err.should.be.instanceof(Error)
+        .with.property('message', 'b can not come before a');
+      spy.should.have.not.been.called();
+      done();
+    });
+  });
+});