/
tasks.js
48 lines (42 loc) · 1.61 KB
/
tasks.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
var should = require('should'),
path = require('path'),
gear = require(path.join(process.cwd(), './index')),
tasks = require('../lib/tasks/tasks').tasks,
fixtures = {
files: [{name: 'test/fixtures/test1.js'}],
missing_files: [{name: 'test/fixtures/missing_file.js'}],
parallel_files: [{name: 'test/fixtures/test2.js'}]
};
describe('Queue()', function() {
it('should wrap task correctly', function() {
new gear.Queue().tasks({
read_files: {task: ['read', fixtures.files]},
concat_files: {requires: 'read_files', task: 'concat'},
read_files2: {task: ['read', fixtures.parallel_files]},
done: {requires: ['read_files2', 'concat_files']}
}).run();
});
});
describe('tasks()', function() {
it('should handle err', function(done) {
var queue = new gear.Queue();
tasks.call(queue, {
read_files: {task: ['read', fixtures.missing_files]}
}, [], function(err, results) {
should.exist(err);
done();
});
});
it('should execute complex tasks', function(done) {
var queue = new gear.Queue();
tasks.call(queue, {
read_files: {task: ['read', fixtures.files]},
concat_files: {requires: 'read_files', task: 'concat'},
read_files2: {task: ['read', fixtures.parallel_files]},
inspect_1_and_2: {requires: ['concat_files', 'read_files2']}
}, [], function(err, results) {
done(err);
});
});
it('should accept existing data');
});