diff options
author | Nevena Bojovic <nenabojov@gmail.com> | 2022-03-01 22:05:25 +0100 |
---|---|---|
committer | Nevena Bojovic <nenabojov@gmail.com> | 2022-03-01 22:05:25 +0100 |
commit | 6555fb80fdd8f6a5d201efadec3189d1244830a0 (patch) | |
tree | c1aa1c5aedc634ad1ea7fad4847884d559b51290 /sandbox/testAppNevena/Front/node_modules/@angular-devkit/architect/src/create-builder.js | |
parent | 7d3640f824f46490b47bd95f1c5a16644f712068 (diff) |
Izbrisala bin, obj i node-modules.
Diffstat (limited to 'sandbox/testAppNevena/Front/node_modules/@angular-devkit/architect/src/create-builder.js')
-rw-r--r-- | sandbox/testAppNevena/Front/node_modules/@angular-devkit/architect/src/create-builder.js | 200 |
1 files changed, 0 insertions, 200 deletions
diff --git a/sandbox/testAppNevena/Front/node_modules/@angular-devkit/architect/src/create-builder.js b/sandbox/testAppNevena/Front/node_modules/@angular-devkit/architect/src/create-builder.js deleted file mode 100644 index bcff4656..00000000 --- a/sandbox/testAppNevena/Front/node_modules/@angular-devkit/architect/src/create-builder.js +++ /dev/null @@ -1,200 +0,0 @@ -"use strict"; -/** - * @license - * Copyright Google LLC All Rights Reserved. - * - * Use of this source code is governed by an MIT-style license that can be - * found in the LICENSE file at https://angular.io/license - */ -Object.defineProperty(exports, "__esModule", { value: true }); -exports.createBuilder = void 0; -const core_1 = require("@angular-devkit/core"); -const rxjs_1 = require("rxjs"); -const operators_1 = require("rxjs/operators"); -const api_1 = require("./api"); -const internal_1 = require("./internal"); -const schedule_by_name_1 = require("./schedule-by-name"); -// eslint-disable-next-line max-lines-per-function -function createBuilder(fn) { - const cjh = core_1.experimental.jobs.createJobHandler; - // eslint-disable-next-line max-lines-per-function - const handler = cjh((options, context) => { - const scheduler = context.scheduler; - const progressChannel = context.createChannel('progress'); - const logChannel = context.createChannel('log'); - const analyticsChannel = context.createChannel('analytics'); - let currentState = api_1.BuilderProgressState.Stopped; - const teardownLogics = []; - let tearingDown = false; - let current = 0; - let status = ''; - let total = 1; - function log(entry) { - logChannel.next(entry); - } - function progress(progress, context) { - currentState = progress.state; - if (progress.state === api_1.BuilderProgressState.Running) { - current = progress.current; - total = progress.total !== undefined ? progress.total : total; - if (progress.status === undefined) { - progress.status = status; - } - else { - status = progress.status; - } - } - progressChannel.next({ - ...progress, - ...(context.target && { target: context.target }), - ...(context.builder && { builder: context.builder }), - id: context.id, - }); - } - return new rxjs_1.Observable((observer) => { - const subscriptions = []; - const inputSubscription = context.inboundBus.subscribe((i) => { - switch (i.kind) { - case core_1.experimental.jobs.JobInboundMessageKind.Stop: - // Run teardown logic then complete. - tearingDown = true; - Promise.all(teardownLogics.map((fn) => fn() || Promise.resolve())).then(() => observer.complete(), (err) => observer.error(err)); - break; - case core_1.experimental.jobs.JobInboundMessageKind.Input: - if (!tearingDown) { - onInput(i.value); - } - break; - } - }); - function onInput(i) { - const builder = i.info; - const loggerName = i.target - ? (0, api_1.targetStringFromTarget)(i.target) - : builder.builderName; - const logger = new core_1.logging.Logger(loggerName); - subscriptions.push(logger.subscribe((entry) => log(entry))); - const context = { - builder, - workspaceRoot: i.workspaceRoot, - currentDirectory: i.currentDirectory, - target: i.target, - logger: logger, - id: i.id, - async scheduleTarget(target, overrides = {}, scheduleOptions = {}) { - const run = await (0, schedule_by_name_1.scheduleByTarget)(target, overrides, { - scheduler, - logger: scheduleOptions.logger || logger.createChild(''), - workspaceRoot: i.workspaceRoot, - currentDirectory: i.currentDirectory, - }); - // We don't want to subscribe errors and complete. - subscriptions.push(run.progress.subscribe((event) => progressChannel.next(event))); - return run; - }, - async scheduleBuilder(builderName, options = {}, scheduleOptions = {}) { - const run = await (0, schedule_by_name_1.scheduleByName)(builderName, options, { - scheduler, - target: scheduleOptions.target, - logger: scheduleOptions.logger || logger.createChild(''), - workspaceRoot: i.workspaceRoot, - currentDirectory: i.currentDirectory, - }); - // We don't want to subscribe errors and complete. - subscriptions.push(run.progress.subscribe((event) => progressChannel.next(event))); - return run; - }, - async getTargetOptions(target) { - return scheduler - .schedule('..getTargetOptions', target) - .output.toPromise(); - }, - async getProjectMetadata(target) { - return scheduler - .schedule('..getProjectMetadata', target) - .output.toPromise(); - }, - async getBuilderNameForTarget(target) { - return scheduler - .schedule('..getBuilderNameForTarget', target) - .output.toPromise(); - }, - async validateOptions(options, builderName) { - return scheduler - .schedule('..validateOptions', [ - builderName, - options, - ]) - .output.toPromise(); - }, - reportRunning() { - switch (currentState) { - case api_1.BuilderProgressState.Waiting: - case api_1.BuilderProgressState.Stopped: - progress({ state: api_1.BuilderProgressState.Running, current: 0, total }, context); - break; - } - }, - reportStatus(status) { - switch (currentState) { - case api_1.BuilderProgressState.Running: - progress({ state: currentState, status, current, total }, context); - break; - case api_1.BuilderProgressState.Waiting: - progress({ state: currentState, status }, context); - break; - } - }, - reportProgress(current, total, status) { - switch (currentState) { - case api_1.BuilderProgressState.Running: - progress({ state: currentState, current, total, status }, context); - } - }, - analytics: new core_1.analytics.ForwardingAnalytics((report) => analyticsChannel.next(report)), - addTeardown(teardown) { - teardownLogics.push(teardown); - }, - }; - context.reportRunning(); - let result; - try { - result = fn(i.options, context); - if ((0, api_1.isBuilderOutput)(result)) { - result = (0, rxjs_1.of)(result); - } - else if (!(0, rxjs_1.isObservable)(result) && isAsyncIterable(result)) { - result = (0, api_1.fromAsyncIterable)(result); - } - else { - result = (0, rxjs_1.from)(result); - } - } - catch (e) { - result = (0, rxjs_1.throwError)(e); - } - // Manage some state automatically. - progress({ state: api_1.BuilderProgressState.Running, current: 0, total: 1 }, context); - subscriptions.push(result - .pipe((0, operators_1.tap)(() => { - progress({ state: api_1.BuilderProgressState.Running, current: total }, context); - progress({ state: api_1.BuilderProgressState.Stopped }, context); - })) - .subscribe((message) => observer.next(message), (error) => observer.error(error), () => observer.complete())); - } - return () => { - subscriptions.forEach((x) => x.unsubscribe()); - inputSubscription.unsubscribe(); - }; - }); - }); - return { - handler, - [internal_1.BuilderSymbol]: true, - [internal_1.BuilderVersionSymbol]: require('../package.json').version, - }; -} -exports.createBuilder = createBuilder; -function isAsyncIterable(obj) { - return !!obj && typeof obj[Symbol.asyncIterator] === 'function'; -} |