114 lines
3.9 KiB
JavaScript
114 lines
3.9 KiB
JavaScript
|
"use strict";
|
||
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
||
|
|
// An alternative fs for the browser and testing
|
||
|
|
const memfs_1 = require("memfs");
|
||
|
|
const volume_1 = require("memfs/lib/volume");
|
||
|
|
const path_1 = require("path");
|
||
|
|
require("./node_sync_emit");
|
||
|
|
const assert = (cond, message) => {
|
||
|
|
if (!cond) {
|
||
|
|
throw new Error(message);
|
||
|
|
}
|
||
|
|
};
|
||
|
|
class WasmFsDefault {
|
||
|
|
constructor() {
|
||
|
|
this.volume = new volume_1.Volume();
|
||
|
|
this.fs = memfs_1.createFsFromVolume(this.volume);
|
||
|
|
this.fromJSON({
|
||
|
|
"/dev/stdin": "",
|
||
|
|
"/dev/stdout": "",
|
||
|
|
"/dev/stderr": ""
|
||
|
|
});
|
||
|
|
}
|
||
|
|
_toJSON(link, json = {}, path) {
|
||
|
|
let isEmpty = true;
|
||
|
|
for (const name in link.children) {
|
||
|
|
isEmpty = false;
|
||
|
|
const child = link.getChild(name);
|
||
|
|
if (child) {
|
||
|
|
const node = child.getNode();
|
||
|
|
if (node && node.isFile()) {
|
||
|
|
let filename = child.getPath();
|
||
|
|
if (path)
|
||
|
|
filename = path_1.relative(path, filename);
|
||
|
|
json[filename] = node.getBuffer();
|
||
|
|
}
|
||
|
|
else if (node && node.isDirectory()) {
|
||
|
|
this._toJSON(child, json, path);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
let dirPath = link.getPath();
|
||
|
|
if (path)
|
||
|
|
dirPath = path_1.relative(path, dirPath);
|
||
|
|
if (dirPath && isEmpty) {
|
||
|
|
json[dirPath] = null;
|
||
|
|
}
|
||
|
|
return json;
|
||
|
|
}
|
||
|
|
toJSON(paths, json = {}, isRelative = false) {
|
||
|
|
const links = [];
|
||
|
|
if (paths) {
|
||
|
|
if (!(paths instanceof Array))
|
||
|
|
paths = [paths];
|
||
|
|
for (const path of paths) {
|
||
|
|
const filename = volume_1.pathToFilename(path);
|
||
|
|
const link = this.volume.getResolvedLink(filename);
|
||
|
|
if (!link)
|
||
|
|
continue;
|
||
|
|
links.push(link);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
links.push(this.volume.root);
|
||
|
|
}
|
||
|
|
if (!links.length)
|
||
|
|
return json;
|
||
|
|
for (const link of links)
|
||
|
|
this._toJSON(link, json, isRelative ? link.getPath() : "");
|
||
|
|
return json;
|
||
|
|
}
|
||
|
|
fromJSONFixed(vol, json) {
|
||
|
|
const sep = "/";
|
||
|
|
for (let filename in json) {
|
||
|
|
const data = json[filename];
|
||
|
|
const isDir = data ? Object.getPrototypeOf(data) === null : data === null;
|
||
|
|
// const isDir = typeof data === "string" || ((data as any) instanceof Buffer && data !== null);
|
||
|
|
if (!isDir) {
|
||
|
|
const steps = volume_1.filenameToSteps(filename);
|
||
|
|
if (steps.length > 1) {
|
||
|
|
const dirname = sep + steps.slice(0, steps.length - 1).join(sep);
|
||
|
|
// @ts-ignore
|
||
|
|
vol.mkdirpBase(dirname, 0o777);
|
||
|
|
}
|
||
|
|
vol.writeFileSync(filename, data || "");
|
||
|
|
}
|
||
|
|
else {
|
||
|
|
// @ts-ignore
|
||
|
|
vol.mkdirpBase(filename, 0o777);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
fromJSON(fsJson) {
|
||
|
|
this.volume = new volume_1.Volume();
|
||
|
|
this.fromJSONFixed(this.volume, fsJson);
|
||
|
|
// @ts-ignore
|
||
|
|
this.fs = memfs_1.createFsFromVolume(this.volume);
|
||
|
|
this.volume.releasedFds = [0, 1, 2];
|
||
|
|
const fdErr = this.volume.openSync("/dev/stderr", "w");
|
||
|
|
const fdOut = this.volume.openSync("/dev/stdout", "w");
|
||
|
|
const fdIn = this.volume.openSync("/dev/stdin", "r");
|
||
|
|
assert(fdErr === 2, `invalid handle for stderr: ${fdErr}`);
|
||
|
|
assert(fdOut === 1, `invalid handle for stdout: ${fdOut}`);
|
||
|
|
assert(fdIn === 0, `invalid handle for stdin: ${fdIn}`);
|
||
|
|
}
|
||
|
|
async getStdOut() {
|
||
|
|
let promise = new Promise(resolve => {
|
||
|
|
resolve(this.fs.readFileSync("/dev/stdout", "utf8"));
|
||
|
|
});
|
||
|
|
return promise;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
exports.default = WasmFsDefault;
|
||
|
|
exports.WasmFs = WasmFsDefault;
|