1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
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;
|
