1 | "use strict";
|
2 |
|
3 |
|
4 |
|
5 |
|
6 |
|
7 |
|
8 |
|
9 | Object.defineProperty(exports, "__esModule", { value: true });
|
10 | exports.isJobHandler = exports.JobState = exports.JobOutboundMessageKind = exports.JobInboundMessageKind = void 0;
|
11 |
|
12 |
|
13 |
|
14 | var JobInboundMessageKind;
|
15 | (function (JobInboundMessageKind) {
|
16 | JobInboundMessageKind["Ping"] = "ip";
|
17 | JobInboundMessageKind["Stop"] = "is";
|
18 |
|
19 | JobInboundMessageKind["Input"] = "in";
|
20 |
|
21 |
|
22 | })(JobInboundMessageKind = exports.JobInboundMessageKind || (exports.JobInboundMessageKind = {}));
|
23 |
|
24 |
|
25 |
|
26 | var JobOutboundMessageKind;
|
27 | (function (JobOutboundMessageKind) {
|
28 |
|
29 | JobOutboundMessageKind["OnReady"] = "c";
|
30 | JobOutboundMessageKind["Start"] = "s";
|
31 | JobOutboundMessageKind["End"] = "e";
|
32 | JobOutboundMessageKind["Pong"] = "p";
|
33 |
|
34 | JobOutboundMessageKind["Output"] = "o";
|
35 |
|
36 | JobOutboundMessageKind["ChannelCreate"] = "cn";
|
37 | JobOutboundMessageKind["ChannelMessage"] = "cm";
|
38 | JobOutboundMessageKind["ChannelError"] = "ce";
|
39 | JobOutboundMessageKind["ChannelComplete"] = "cc";
|
40 | })(JobOutboundMessageKind = exports.JobOutboundMessageKind || (exports.JobOutboundMessageKind = {}));
|
41 |
|
42 |
|
43 |
|
44 | var JobState;
|
45 | (function (JobState) {
|
46 | |
47 |
|
48 |
|
49 | JobState["Queued"] = "queued";
|
50 | |
51 |
|
52 |
|
53 |
|
54 | JobState["Ready"] = "ready";
|
55 | |
56 |
|
57 |
|
58 |
|
59 | JobState["Started"] = "started";
|
60 | |
61 |
|
62 |
|
63 | JobState["Ended"] = "ended";
|
64 | |
65 |
|
66 |
|
67 | JobState["Errored"] = "errored";
|
68 | })(JobState = exports.JobState || (exports.JobState = {}));
|
69 | function isJobHandler(value) {
|
70 | const job = value;
|
71 | return (typeof job == 'function' && typeof job.jobDescription == 'object' && job.jobDescription !== null);
|
72 | }
|
73 | exports.isJobHandler = isJobHandler;
|