diff options
author | Nevena Bojovic <nenabojov@gmail.com> | 2022-03-01 20:05:50 +0100 |
---|---|---|
committer | Nevena Bojovic <nenabojov@gmail.com> | 2022-03-01 20:05:50 +0100 |
commit | 291803c31f829fe0d32bb3207bc11def95a7408c (patch) | |
tree | c7d43107d79291b19d8c9eceefbe91c9f9a52acf /sandbox/testAppNevena/Front/node_modules/@angular-devkit/schematics/src/sink/host.js | |
parent | 1fa69862057db4db53cfda5be9c24b4228ef63f7 (diff) |
Urađena test aplikacija. Povezan front i back.
Diffstat (limited to 'sandbox/testAppNevena/Front/node_modules/@angular-devkit/schematics/src/sink/host.js')
-rw-r--r-- | sandbox/testAppNevena/Front/node_modules/@angular-devkit/schematics/src/sink/host.js | 76 |
1 files changed, 76 insertions, 0 deletions
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 new file mode 100644 index 00000000..a5bb10b3 --- /dev/null +++ b/sandbox/testAppNevena/Front/node_modules/@angular-devkit/schematics/src/sink/host.js @@ -0,0 +1,76 @@ +"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; |