1 | "use strict";
|
2 |
|
3 |
|
4 |
|
5 |
|
6 |
|
7 |
|
8 |
|
9 | Object.defineProperty(exports, "__esModule", { value: true });
|
10 | exports.scheduleTargetAndForget = exports.targetFromTargetString = exports.targetStringFromTarget = exports.fromAsyncIterable = exports.isBuilderOutput = exports.BuilderProgressState = void 0;
|
11 | const rxjs_1 = require("rxjs");
|
12 | const operators_1 = require("rxjs/operators");
|
13 | const progress_schema_1 = require("./progress-schema");
|
14 | Object.defineProperty(exports, "BuilderProgressState", { enumerable: true, get: function () { return progress_schema_1.State; } });
|
15 |
|
16 | function isBuilderOutput(obj) {
|
17 | if (!obj || typeof obj.then === 'function' || typeof obj.subscribe === 'function') {
|
18 | return false;
|
19 | }
|
20 | if (typeof obj[Symbol.asyncIterator] === 'function') {
|
21 | return false;
|
22 | }
|
23 | return typeof obj.success === 'boolean';
|
24 | }
|
25 | exports.isBuilderOutput = isBuilderOutput;
|
26 | function fromAsyncIterable(iterable) {
|
27 | return new rxjs_1.Observable((subscriber) => {
|
28 | handleAsyncIterator(subscriber, iterable[Symbol.asyncIterator]()).then(() => subscriber.complete(), (error) => subscriber.error(error));
|
29 | });
|
30 | }
|
31 | exports.fromAsyncIterable = fromAsyncIterable;
|
32 | async function handleAsyncIterator(subscriber, iterator) {
|
33 | var _a;
|
34 | const teardown = new Promise((resolve) => subscriber.add(() => resolve()));
|
35 | try {
|
36 | while (!subscriber.closed) {
|
37 | const result = await Promise.race([teardown, iterator.next()]);
|
38 | if (!result || result.done) {
|
39 | break;
|
40 | }
|
41 | subscriber.next(result.value);
|
42 | }
|
43 | }
|
44 | finally {
|
45 | await ((_a = iterator.return) === null || _a === void 0 ? void 0 : _a.call(iterator));
|
46 | }
|
47 | }
|
48 |
|
49 |
|
50 |
|
51 | function targetStringFromTarget({ project, target, configuration }) {
|
52 | return `${project}:${target}${configuration !== undefined ? ':' + configuration : ''}`;
|
53 | }
|
54 | exports.targetStringFromTarget = targetStringFromTarget;
|
55 |
|
56 |
|
57 |
|
58 | function targetFromTargetString(str) {
|
59 | const tuple = str.split(/:/, 3);
|
60 | if (tuple.length < 2) {
|
61 | throw new Error('Invalid target string: ' + JSON.stringify(str));
|
62 | }
|
63 | return {
|
64 | project: tuple[0],
|
65 | target: tuple[1],
|
66 | ...(tuple[2] !== undefined && { configuration: tuple[2] }),
|
67 | };
|
68 | }
|
69 | exports.targetFromTargetString = targetFromTargetString;
|
70 |
|
71 |
|
72 |
|
73 |
|
74 |
|
75 |
|
76 |
|
77 |
|
78 |
|
79 |
|
80 |
|
81 |
|
82 |
|
83 | function scheduleTargetAndForget(context, target, overrides, scheduleOptions) {
|
84 | let resolve = null;
|
85 | const promise = new Promise((r) => (resolve = r));
|
86 | context.addTeardown(() => promise);
|
87 | return rxjs_1.from(context.scheduleTarget(target, overrides, scheduleOptions)).pipe(operators_1.switchMap((run) => new rxjs_1.Observable((observer) => {
|
88 | const subscription = run.output.subscribe(observer);
|
89 | return () => {
|
90 | subscription.unsubscribe();
|
91 |
|
92 |
|
93 |
|
94 | run.stop().then(resolve);
|
95 | };
|
96 | })));
|
97 | }
|
98 | exports.scheduleTargetAndForget = scheduleTargetAndForget;
|