-
Notifications
You must be signed in to change notification settings - Fork 2
/
Task.ts
90 lines (78 loc) · 2.06 KB
/
Task.ts
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
import { Deferred } from "./Deferred"
import { logger } from "./Logger"
import { Parser } from "./Parser"
/**
* Tasks embody individual jobs given to the underlying child processes. Each
* instance has a promise that will be resolved or rejected based on the
* result of the task.
*/
export class Task<T> {
private readonly d = new Deferred<T>()
private _stdout = ""
private _stderr = ""
/**
* @param {string} command is the value written to stdin to perform the given
* task.
* @param {Parser<T>} parser is used to parse resulting data from the
* underlying process to a typed object.
*/
constructor(readonly command: string, readonly parser: Parser<T>) {}
/**
* @return the resolution or rejection of this task.
*/
get promise(): Promise<T> {
return this.d.promise
}
get pending(): boolean {
return this.d.pending
}
get state(): string {
return this.d.pending
? "pending"
: this.d.fulfilled
? "resolved"
: "rejected"
}
toString() {
return this.constructor.name + "(" + this.command + ")"
}
onStdout(buf: string | Buffer) {
this._stdout += buf.toString()
}
onStderr(buf: string | Buffer) {
this._stderr += buf.toString()
}
get stdout() {
return this._stdout
}
get stderr() {
return this._stderr
}
/**
* This is for use by `BatchProcess` only, and will only be called when the
* process is complete for this task's command
*/
resolve(result: string, stderr: string): void {
try {
const parseResult = this.parser(result, stderr)
logger().trace("Task.onData(): resolved", {
command: this.command,
parseResult
})
this.d.resolve(parseResult)
} catch (error) {
this.reject(error, "Task.onData(): rejected")
}
}
/**
* This is for use by `BatchProcess` only, and will only be called when the
* process has errored after N retries
*/
reject(error: Error, source = "Task.reject()"): void {
logger().warn(source, {
cmd: this.command,
error
})
this.d.reject(error)
}
}