diff options
Diffstat (limited to 'sandbox/testAppNevena/Front/node_modules/@angular-devkit/schematics/src/sink')
6 files changed, 0 insertions, 386 deletions
diff --git a/sandbox/testAppNevena/Front/node_modules/@angular-devkit/schematics/src/sink/dryrun.d.ts b/sandbox/testAppNevena/Front/node_modules/@angular-devkit/schematics/src/sink/dryrun.d.ts deleted file mode 100644 index bb7ab7d1..00000000 --- a/sandbox/testAppNevena/Front/node_modules/@angular-devkit/schematics/src/sink/dryrun.d.ts +++ /dev/null @@ -1,50 +0,0 @@ -/** - * @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 - */ -/// <reference types="node" /> -import { virtualFs } from '@angular-devkit/core'; -import { Observable, Subject } from 'rxjs'; -import { HostSink } from './host'; -export interface DryRunErrorEvent { - kind: 'error'; - description: 'alreadyExist' | 'doesNotExist'; - path: string; -} -export interface DryRunDeleteEvent { - kind: 'delete'; - path: string; -} -export interface DryRunCreateEvent { - kind: 'create'; - path: string; - content: Buffer; -} -export interface DryRunUpdateEvent { - kind: 'update'; - path: string; - content: Buffer; -} -export interface DryRunRenameEvent { - kind: 'rename'; - path: string; - to: string; -} -export declare type DryRunEvent = DryRunErrorEvent | DryRunDeleteEvent | DryRunCreateEvent | DryRunUpdateEvent | DryRunRenameEvent; -export declare class DryRunSink extends HostSink { - protected _subject: Subject<DryRunEvent>; - protected _fileDoesNotExistExceptionSet: Set<string>; - protected _fileAlreadyExistExceptionSet: Set<string>; - readonly reporter: Observable<DryRunEvent>; - /** - * @param {host} dir The host to use to output. This should be scoped. - * @param {boolean} force Whether to force overwriting files that already exist. - */ - constructor(host: virtualFs.Host, force?: boolean); - protected _fileAlreadyExistException(path: string): void; - protected _fileDoesNotExistException(path: string): void; - _done(): Observable<void>; -} diff --git a/sandbox/testAppNevena/Front/node_modules/@angular-devkit/schematics/src/sink/dryrun.js b/sandbox/testAppNevena/Front/node_modules/@angular-devkit/schematics/src/sink/dryrun.js deleted file mode 100644 index 7ff91540..00000000 --- a/sandbox/testAppNevena/Front/node_modules/@angular-devkit/schematics/src/sink/dryrun.js +++ /dev/null @@ -1,80 +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.DryRunSink = void 0; -const core_1 = require("@angular-devkit/core"); -const node_1 = require("@angular-devkit/core/node"); -const rxjs_1 = require("rxjs"); -const host_1 = require("./host"); -class DryRunSink extends host_1.HostSink { - constructor(host, force = false) { - super(typeof host == 'string' - ? new core_1.virtualFs.ScopedHost(new node_1.NodeJsSyncHost(), (0, core_1.normalize)(host)) - : host, force); - this._subject = new rxjs_1.Subject(); - this._fileDoesNotExistExceptionSet = new Set(); - this._fileAlreadyExistExceptionSet = new Set(); - this.reporter = this._subject.asObservable(); - } - _fileAlreadyExistException(path) { - this._fileAlreadyExistExceptionSet.add(path); - } - _fileDoesNotExistException(path) { - this._fileDoesNotExistExceptionSet.add(path); - } - _done() { - this._fileAlreadyExistExceptionSet.forEach((path) => { - this._subject.next({ - kind: 'error', - description: 'alreadyExist', - path, - }); - }); - this._fileDoesNotExistExceptionSet.forEach((path) => { - this._subject.next({ - kind: 'error', - description: 'doesNotExist', - path, - }); - }); - this._filesToDelete.forEach((path) => { - // Check if this is a renaming. - for (const [from] of this._filesToRename) { - if (from == path) { - // The event is sent later on. - return; - } - } - this._subject.next({ kind: 'delete', path }); - }); - this._filesToRename.forEach(([path, to]) => { - this._subject.next({ kind: 'rename', path, to }); - }); - this._filesToCreate.forEach((content, path) => { - // Check if this is a renaming. - for (const [, to] of this._filesToRename) { - if (to == path) { - // The event is sent later on. - return; - } - } - if (this._fileAlreadyExistExceptionSet.has(path) || - this._fileDoesNotExistExceptionSet.has(path)) { - return; - } - this._subject.next({ kind: 'create', path, content: content.generate() }); - }); - this._filesToUpdate.forEach((content, path) => { - this._subject.next({ kind: 'update', path, content: content.generate() }); - }); - this._subject.complete(); - return (0, rxjs_1.of)(undefined); - } -} -exports.DryRunSink = DryRunSink; diff --git a/sandbox/testAppNevena/Front/node_modules/@angular-devkit/schematics/src/sink/host.d.ts b/sandbox/testAppNevena/Front/node_modules/@angular-devkit/schematics/src/sink/host.d.ts deleted file mode 100644 index 3f2934c4..00000000 --- a/sandbox/testAppNevena/Front/node_modules/@angular-devkit/schematics/src/sink/host.d.ts +++ /dev/null @@ -1,29 +0,0 @@ -/** - * @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 - */ -/// <reference types="node" /> -import { Path, virtualFs } from '@angular-devkit/core'; -import { Observable } from 'rxjs'; -import { CreateFileAction } from '../tree/action'; -import { UpdateBufferBase } from '../utility/update-buffer'; -import { SimpleSinkBase } from './sink'; -export declare class HostSink extends SimpleSinkBase { - protected _host: virtualFs.Host; - protected _force: boolean; - protected _filesToDelete: Set<Path>; - protected _filesToRename: Set<[Path, Path]>; - protected _filesToCreate: Map<Path, UpdateBufferBase>; - protected _filesToUpdate: Map<Path, UpdateBufferBase>; - constructor(_host: virtualFs.Host, _force?: boolean); - protected _validateCreateAction(action: CreateFileAction): Observable<void>; - protected _validateFileExists(p: Path): Observable<boolean>; - protected _overwriteFile(path: Path, content: Buffer): Observable<void>; - protected _createFile(path: Path, content: Buffer): Observable<void>; - protected _renameFile(from: Path, to: Path): Observable<void>; - protected _deleteFile(path: Path): Observable<void>; - _done(): Observable<void>; -} diff --git a/sandbox/testAppNevena/Front/node_modules/@angular-devkit/schematics/src/sink/host.js b/sandbox/testAppNevena/Front/node_modules/@angular-devkit/schematics/src/sink/host.js deleted file mode 100644 index a5bb10b3..00000000 --- a/sandbox/testAppNevena/Front/node_modules/@angular-devkit/schematics/src/sink/host.js +++ /dev/null @@ -1,76 +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.HostSink = void 0; -const rxjs_1 = require("rxjs"); -const operators_1 = require("rxjs/operators"); -const update_buffer_1 = require("../utility/update-buffer"); -const sink_1 = require("./sink"); -class HostSink extends sink_1.SimpleSinkBase { - constructor(_host, _force = false) { - super(); - this._host = _host; - this._force = _force; - this._filesToDelete = new Set(); - this._filesToRename = new Set(); - this._filesToCreate = new Map(); - this._filesToUpdate = new Map(); - } - _validateCreateAction(action) { - return this._force ? rxjs_1.EMPTY : super._validateCreateAction(action); - } - _validateFileExists(p) { - if (this._filesToCreate.has(p) || this._filesToUpdate.has(p)) { - return (0, rxjs_1.of)(true); - } - if (this._filesToDelete.has(p)) { - return (0, rxjs_1.of)(false); - } - for (const [from, to] of this._filesToRename.values()) { - switch (p) { - case from: - return (0, rxjs_1.of)(false); - case to: - return (0, rxjs_1.of)(true); - } - } - return this._host.exists(p); - } - _overwriteFile(path, content) { - this._filesToUpdate.set(path, update_buffer_1.UpdateBufferBase.create(content)); - return rxjs_1.EMPTY; - } - _createFile(path, content) { - this._filesToCreate.set(path, update_buffer_1.UpdateBufferBase.create(content)); - return rxjs_1.EMPTY; - } - _renameFile(from, to) { - this._filesToRename.add([from, to]); - return rxjs_1.EMPTY; - } - _deleteFile(path) { - if (this._filesToCreate.has(path)) { - this._filesToCreate.delete(path); - this._filesToUpdate.delete(path); - } - else { - this._filesToDelete.add(path); - } - return rxjs_1.EMPTY; - } - _done() { - // Really commit everything to the actual filesystem. - return (0, rxjs_1.concat)((0, rxjs_1.from)([...this._filesToDelete.values()]).pipe((0, operators_1.concatMap)((path) => this._host.delete(path))), (0, rxjs_1.from)([...this._filesToRename.entries()]).pipe((0, operators_1.concatMap)(([_, [path, to]]) => this._host.rename(path, to))), (0, rxjs_1.from)([...this._filesToCreate.entries()]).pipe((0, operators_1.concatMap)(([path, buffer]) => { - return this._host.write(path, buffer.generate()); - })), (0, rxjs_1.from)([...this._filesToUpdate.entries()]).pipe((0, operators_1.concatMap)(([path, buffer]) => { - return this._host.write(path, buffer.generate()); - }))).pipe((0, operators_1.reduce)(() => { })); - } -} -exports.HostSink = HostSink; diff --git a/sandbox/testAppNevena/Front/node_modules/@angular-devkit/schematics/src/sink/sink.d.ts b/sandbox/testAppNevena/Front/node_modules/@angular-devkit/schematics/src/sink/sink.d.ts deleted file mode 100644 index 9e441f2a..00000000 --- a/sandbox/testAppNevena/Front/node_modules/@angular-devkit/schematics/src/sink/sink.d.ts +++ /dev/null @@ -1,35 +0,0 @@ -/** - * @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 - */ -/// <reference types="node" /> -import { Observable } from 'rxjs'; -import { Action, CreateFileAction, DeleteFileAction, OverwriteFileAction, RenameFileAction } from '../tree/action'; -import { Tree } from '../tree/interface'; -export interface Sink { - commit(tree: Tree): Observable<void>; -} -export declare abstract class SimpleSinkBase implements Sink { - preCommitAction: (action: Action) => void | Action | PromiseLike<Action> | Observable<Action>; - postCommitAction: (action: Action) => void | Observable<void>; - preCommit: () => void | Observable<void>; - postCommit: () => void | Observable<void>; - protected abstract _validateFileExists(p: string): Observable<boolean>; - protected abstract _overwriteFile(path: string, content: Buffer): Observable<void>; - protected abstract _createFile(path: string, content: Buffer): Observable<void>; - protected abstract _renameFile(path: string, to: string): Observable<void>; - protected abstract _deleteFile(path: string): Observable<void>; - protected abstract _done(): Observable<void>; - protected _fileAlreadyExistException(path: string): void; - protected _fileDoesNotExistException(path: string): void; - protected _validateOverwriteAction(action: OverwriteFileAction): Observable<void>; - protected _validateCreateAction(action: CreateFileAction): Observable<void>; - protected _validateRenameAction(action: RenameFileAction): Observable<void>; - protected _validateDeleteAction(action: DeleteFileAction): Observable<void>; - validateSingleAction(action: Action): Observable<void>; - commitSingleAction(action: Action): Observable<void>; - commit(tree: Tree): Observable<void>; -} diff --git a/sandbox/testAppNevena/Front/node_modules/@angular-devkit/schematics/src/sink/sink.js b/sandbox/testAppNevena/Front/node_modules/@angular-devkit/schematics/src/sink/sink.js deleted file mode 100644 index 80b42052..00000000 --- a/sandbox/testAppNevena/Front/node_modules/@angular-devkit/schematics/src/sink/sink.js +++ /dev/null @@ -1,116 +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.SimpleSinkBase = void 0; -const rxjs_1 = require("rxjs"); -const operators_1 = require("rxjs/operators"); -const exception_1 = require("../exception/exception"); -const action_1 = require("../tree/action"); -const Noop = function () { }; -class SimpleSinkBase { - constructor() { - this.preCommitAction = Noop; - this.postCommitAction = Noop; - this.preCommit = Noop; - this.postCommit = Noop; - } - _fileAlreadyExistException(path) { - throw new exception_1.FileAlreadyExistException(path); - } - _fileDoesNotExistException(path) { - throw new exception_1.FileDoesNotExistException(path); - } - _validateOverwriteAction(action) { - return this._validateFileExists(action.path).pipe((0, operators_1.map)((b) => { - if (!b) { - this._fileDoesNotExistException(action.path); - } - })); - } - _validateCreateAction(action) { - return this._validateFileExists(action.path).pipe((0, operators_1.map)((b) => { - if (b) { - this._fileAlreadyExistException(action.path); - } - })); - } - _validateRenameAction(action) { - return this._validateFileExists(action.path).pipe((0, operators_1.map)((b) => { - if (!b) { - this._fileDoesNotExistException(action.path); - } - }), (0, operators_1.mergeMap)(() => this._validateFileExists(action.to)), (0, operators_1.map)((b) => { - if (b) { - this._fileAlreadyExistException(action.to); - } - })); - } - _validateDeleteAction(action) { - return this._validateFileExists(action.path).pipe((0, operators_1.map)((b) => { - if (!b) { - this._fileDoesNotExistException(action.path); - } - })); - } - validateSingleAction(action) { - switch (action.kind) { - case 'o': - return this._validateOverwriteAction(action); - case 'c': - return this._validateCreateAction(action); - case 'r': - return this._validateRenameAction(action); - case 'd': - return this._validateDeleteAction(action); - default: - throw new action_1.UnknownActionException(action); - } - } - commitSingleAction(action) { - return (0, rxjs_1.concat)(this.validateSingleAction(action), new rxjs_1.Observable((observer) => { - let committed = null; - switch (action.kind) { - case 'o': - committed = this._overwriteFile(action.path, action.content); - break; - case 'c': - committed = this._createFile(action.path, action.content); - break; - case 'r': - committed = this._renameFile(action.path, action.to); - break; - case 'd': - committed = this._deleteFile(action.path); - break; - } - if (committed) { - committed.subscribe(observer); - } - else { - observer.complete(); - } - })).pipe((0, operators_1.ignoreElements)()); - } - commit(tree) { - const actions = (0, rxjs_1.from)(tree.actions); - return (0, rxjs_1.concat)(this.preCommit() || (0, rxjs_1.of)(null), (0, rxjs_1.defer)(() => actions).pipe((0, operators_1.concatMap)((action) => { - const maybeAction = this.preCommitAction(action); - if ((0, rxjs_1.isObservable)(maybeAction) || isPromiseLike(maybeAction)) { - return maybeAction; - } - return (0, rxjs_1.of)(maybeAction || action); - }), (0, operators_1.concatMap)((action) => { - return (0, rxjs_1.concat)(this.commitSingleAction(action).pipe((0, operators_1.ignoreElements)()), (0, rxjs_1.of)(action)); - }), (0, operators_1.concatMap)((action) => this.postCommitAction(action) || (0, rxjs_1.of)(null))), (0, rxjs_1.defer)(() => this._done()), (0, rxjs_1.defer)(() => this.postCommit() || (0, rxjs_1.of)(null))).pipe((0, operators_1.ignoreElements)()); - } -} -exports.SimpleSinkBase = SimpleSinkBase; -function isPromiseLike(value) { - return !!value && typeof value.then === 'function'; -} |