Urađena test aplikacija. Povezan front i back.

1 files changed, 200 insertions, 0 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
new file mode 100644
index 00000000..bcff4656
--- /dev/null
+++ b/sandbox/testAppNevena/Front/node_modules/@angular-devkit/architect/src/create-builder.js
@@ -0,0 +1,200 @@
+"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';
+}