cockrel/test/do.js

const assert = require('assert');
const co = require('../cockrel');



describe("Plugin: do", function() {


  it("can execute a synchronous function", function(done) {

    co.do((data) => { data.test = 2; return data; }, '@')
      .do(check)
      .begin({test: 1});

    function check(data) {
      assert.equal(data.test, 2);
      done();
    }

  });

  it("can execute a synchronous function with picked args", function(done) {

    co
      .do(check, '@arg1', '@arg2', '@', 'cnst', 'hi {arg1}', {foo : '@arg1'})
      .begin({arg1: 1, arg2 : 2});

    function check(arg1, arg2, all, cnst, interp, some) {
      assert.equal(arg1, 1);
      assert.equal(arg2, 2);
      assert.equal(all.arg2, 2);
      assert.equal(cnst, 'cnst');
      assert.equal(interp, 'hi 1');
      assert.equal(some.foo, 1);
      done();
    }

  });

  it("can handle a synchronous function that throws", function(done) {

    co.do((data) => { throw new Error('uh oh'); })
      .begin({test:1})
      .catch(check);

    function check(err) {
      assert.equal(err, 'uh oh');
      done();
    }

  });

  it("can execute a promise function", function(done) {

    co.do(testPromise)
      .do(check)
      .begin({test: 1});

    function testPromise(data) {
      return new Promise((res, rej) => {
        data.foo = 'bar';
        return res(data);
      });
    }

    function check(data) {
      assert.equal(data.foo, 'bar');
      done();
    }

  });

  it("can handle a promise function that rejects", function(done) {

    co.do(testPromise).begin({test:1}).catch(check);

    function testPromise(data) {
      return new Promise((res, rej) => {
        return rej('uh oh');
      });
    }

    function check(err) {
      assert.equal(err, 'uh oh');
      done();
    }

  });

  it("can execute a sub-chain", function(done) {

    co.do(co.do(testPromise))
      .do(check)
      .begin({test: 1});

    function testPromise(data) {
      return new Promise((res, rej) => {
        data.foo = 'bar';
        return res(data);
      });
    }

    function check(data) {
      assert.equal(data.foo, 'bar');
      done();
    }

  });


});