1 | "use strict";
|
---|
2 | /**
|
---|
3 | * @license
|
---|
4 | * Copyright Google LLC All Rights Reserved.
|
---|
5 | *
|
---|
6 | * Use of this source code is governed by an MIT-style license that can be
|
---|
7 | * found in the LICENSE file at https://angular.io/license
|
---|
8 | */
|
---|
9 | Object.defineProperty(exports, "__esModule", { value: true });
|
---|
10 | exports.HostSink = void 0;
|
---|
11 | const rxjs_1 = require("rxjs");
|
---|
12 | const operators_1 = require("rxjs/operators");
|
---|
13 | const update_buffer_1 = require("../utility/update-buffer");
|
---|
14 | const sink_1 = require("./sink");
|
---|
15 | class HostSink extends sink_1.SimpleSinkBase {
|
---|
16 | constructor(_host, _force = false) {
|
---|
17 | super();
|
---|
18 | this._host = _host;
|
---|
19 | this._force = _force;
|
---|
20 | this._filesToDelete = new Set();
|
---|
21 | this._filesToRename = new Set();
|
---|
22 | this._filesToCreate = new Map();
|
---|
23 | this._filesToUpdate = new Map();
|
---|
24 | }
|
---|
25 | _validateCreateAction(action) {
|
---|
26 | return this._force ? rxjs_1.EMPTY : super._validateCreateAction(action);
|
---|
27 | }
|
---|
28 | _validateFileExists(p) {
|
---|
29 | if (this._filesToCreate.has(p) || this._filesToUpdate.has(p)) {
|
---|
30 | return rxjs_1.of(true);
|
---|
31 | }
|
---|
32 | if (this._filesToDelete.has(p)) {
|
---|
33 | return rxjs_1.of(false);
|
---|
34 | }
|
---|
35 | for (const [from, to] of this._filesToRename.values()) {
|
---|
36 | switch (p) {
|
---|
37 | case from:
|
---|
38 | return rxjs_1.of(false);
|
---|
39 | case to:
|
---|
40 | return rxjs_1.of(true);
|
---|
41 | }
|
---|
42 | }
|
---|
43 | return this._host.exists(p);
|
---|
44 | }
|
---|
45 | _overwriteFile(path, content) {
|
---|
46 | this._filesToUpdate.set(path, new update_buffer_1.UpdateBuffer(content));
|
---|
47 | return rxjs_1.EMPTY;
|
---|
48 | }
|
---|
49 | _createFile(path, content) {
|
---|
50 | this._filesToCreate.set(path, new update_buffer_1.UpdateBuffer(content));
|
---|
51 | return rxjs_1.EMPTY;
|
---|
52 | }
|
---|
53 | _renameFile(from, to) {
|
---|
54 | this._filesToRename.add([from, to]);
|
---|
55 | return rxjs_1.EMPTY;
|
---|
56 | }
|
---|
57 | _deleteFile(path) {
|
---|
58 | if (this._filesToCreate.has(path)) {
|
---|
59 | this._filesToCreate.delete(path);
|
---|
60 | this._filesToUpdate.delete(path);
|
---|
61 | }
|
---|
62 | else {
|
---|
63 | this._filesToDelete.add(path);
|
---|
64 | }
|
---|
65 | return rxjs_1.EMPTY;
|
---|
66 | }
|
---|
67 | _done() {
|
---|
68 | // Really commit everything to the actual filesystem.
|
---|
69 | return rxjs_1.concat(rxjs_1.from([...this._filesToDelete.values()]).pipe(operators_1.concatMap((path) => this._host.delete(path))), rxjs_1.from([...this._filesToRename.entries()]).pipe(operators_1.concatMap(([_, [path, to]]) => this._host.rename(path, to))), rxjs_1.from([...this._filesToCreate.entries()]).pipe(operators_1.concatMap(([path, buffer]) => {
|
---|
70 | return this._host.write(path, buffer.generate());
|
---|
71 | })), rxjs_1.from([...this._filesToUpdate.entries()]).pipe(operators_1.concatMap(([path, buffer]) => {
|
---|
72 | return this._host.write(path, buffer.generate());
|
---|
73 | }))).pipe(operators_1.reduce(() => { }));
|
---|
74 | }
|
---|
75 | }
|
---|
76 | exports.HostSink = HostSink;
|
---|