76 lines
1.8 KiB
JavaScript
76 lines
1.8 KiB
JavaScript
import { existsSync, promises as fsp } from "node:fs";
|
|
import { resolve, join } from "node:path";
|
|
import { createError, createRequiredError, defineDriver } from "./utils/index.mjs";
|
|
import {
|
|
readFile,
|
|
writeFile,
|
|
readdirRecursive,
|
|
rmRecursive,
|
|
unlink
|
|
} from "./utils/node-fs.mjs";
|
|
const PATH_TRAVERSE_RE = /\.\.:|\.\.$/;
|
|
const DRIVER_NAME = "fs-lite";
|
|
export default defineDriver((opts = {}) => {
|
|
if (!opts.base) {
|
|
throw createRequiredError(DRIVER_NAME, "base");
|
|
}
|
|
opts.base = resolve(opts.base);
|
|
const r = (key) => {
|
|
if (PATH_TRAVERSE_RE.test(key)) {
|
|
throw createError(
|
|
DRIVER_NAME,
|
|
`Invalid key: ${JSON.stringify(key)}. It should not contain .. segments`
|
|
);
|
|
}
|
|
const resolved = join(opts.base, key.replace(/:/g, "/"));
|
|
return resolved;
|
|
};
|
|
return {
|
|
name: DRIVER_NAME,
|
|
options: opts,
|
|
flags: {
|
|
maxDepth: true
|
|
},
|
|
hasItem(key) {
|
|
return existsSync(r(key));
|
|
},
|
|
getItem(key) {
|
|
return readFile(r(key), "utf8");
|
|
},
|
|
getItemRaw(key) {
|
|
return readFile(r(key));
|
|
},
|
|
async getMeta(key) {
|
|
const { atime, mtime, size, birthtime, ctime } = await fsp.stat(r(key)).catch(() => ({}));
|
|
return { atime, mtime, size, birthtime, ctime };
|
|
},
|
|
setItem(key, value) {
|
|
if (opts.readOnly) {
|
|
return;
|
|
}
|
|
return writeFile(r(key), value, "utf8");
|
|
},
|
|
setItemRaw(key, value) {
|
|
if (opts.readOnly) {
|
|
return;
|
|
}
|
|
return writeFile(r(key), value);
|
|
},
|
|
removeItem(key) {
|
|
if (opts.readOnly) {
|
|
return;
|
|
}
|
|
return unlink(r(key));
|
|
},
|
|
getKeys(_base, topts) {
|
|
return readdirRecursive(r("."), opts.ignore, topts?.maxDepth);
|
|
},
|
|
async clear() {
|
|
if (opts.readOnly || opts.noClear) {
|
|
return;
|
|
}
|
|
await rmRecursive(r("."));
|
|
}
|
|
};
|
|
});
|