taskRunner.js
4.78 KB
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
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
"use strict";
var __extends = (this && this.__extends) || function (d, b) {
for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p];
function __() { this.constructor = d; }
d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
};
var child_process = require("child_process");
var events_1 = require("events");
var q = require("q");
var configParser_1 = require("./configParser");
var runner_1 = require("./runner");
var taskLogger_1 = require("./taskLogger");
/**
* A runner for running a specified task (capabilities + specs).
* The TaskRunner can either run the task from the current process (via
* './runner.js') or from a new process (via './runnerCli.js').
*
* @constructor
* @param {string} configFile Path of test configuration.
* @param {object} additionalConfig Additional configuration.
* @param {object} task Task to run.
* @param {boolean} runInFork Whether to run test in a forked process.
* @constructor
*/
var TaskRunner = (function (_super) {
__extends(TaskRunner, _super);
function TaskRunner(configFile, additionalConfig, task, runInFork) {
var _this = _super.call(this) || this;
_this.configFile = configFile;
_this.additionalConfig = additionalConfig;
_this.task = task;
_this.runInFork = runInFork;
return _this;
}
/**
* Sends the run command.
* @return {q.Promise} A promise that will resolve when the task finishes
* running. The promise contains the following parameters representing the
* result of the run:
* taskId, specs, capabilities, failedCount, exitCode, specResults
*/
TaskRunner.prototype.run = function () {
var runResults = {
taskId: this.task.taskId,
specs: this.task.specs,
capabilities: this.task.capabilities,
// The following are populated while running the test:
failedCount: 0,
exitCode: -1,
specResults: []
};
var configParser = new configParser_1.ConfigParser();
if (this.configFile) {
configParser.addFileConfig(this.configFile);
}
if (this.additionalConfig) {
configParser.addConfig(this.additionalConfig);
}
var config = configParser.getConfig();
config.capabilities = this.task.capabilities;
config.specs = this.task.specs;
if (this.runInFork) {
var deferred_1 = q.defer();
var childProcess = child_process.fork(__dirname + '/runnerCli.js', process.argv.slice(2), { cwd: process.cwd(), silent: true });
var taskLogger_2 = new taskLogger_1.TaskLogger(this.task, childProcess.pid);
// stdout pipe
childProcess.stdout.on('data', function (data) {
taskLogger_2.log(data);
});
// stderr pipe
childProcess.stderr.on('data', function (data) {
taskLogger_2.log(data);
});
childProcess
.on('message', function (m) {
if (config.verboseMultiSessions) {
taskLogger_2.peek();
}
switch (m.event) {
case 'testPass':
process.stdout.write('.');
break;
case 'testFail':
process.stdout.write('F');
break;
case 'testsDone':
runResults.failedCount = m.results.failedCount;
runResults.specResults = m.results.specResults;
break;
}
})
.on('error', function (err) {
taskLogger_2.flush();
deferred_1.reject(err);
})
.on('exit', function (code) {
taskLogger_2.flush();
runResults.exitCode = code;
deferred_1.resolve(runResults);
});
childProcess.send({
command: 'run',
configFile: this.configFile,
additionalConfig: this.additionalConfig,
capabilities: this.task.capabilities,
specs: this.task.specs
});
return deferred_1.promise;
}
else {
var runner = new runner_1.Runner(config);
runner.on('testsDone', function (results) {
runResults.failedCount = results.failedCount;
runResults.specResults = results.specResults;
});
return runner.run().then(function (exitCode) {
runResults.exitCode = exitCode;
return runResults;
});
}
};
return TaskRunner;
}(events_1.EventEmitter));
exports.TaskRunner = TaskRunner;