File size: 4,728 Bytes
b4143a2 | 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 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 | "use strict";
var __createBinding = (this && this.__createBinding) || (Object.create ? (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
var desc = Object.getOwnPropertyDescriptor(m, k);
if (!desc || ("get" in desc ? !m.__esModule : desc.writable || desc.configurable)) {
desc = { enumerable: true, get: function() { return m[k]; } };
}
Object.defineProperty(o, k2, desc);
}) : (function(o, m, k, k2) {
if (k2 === undefined) k2 = k;
o[k2] = m[k];
}));
var __setModuleDefault = (this && this.__setModuleDefault) || (Object.create ? (function(o, v) {
Object.defineProperty(o, "default", { enumerable: true, value: v });
}) : function(o, v) {
o["default"] = v;
});
var __importStar = (this && this.__importStar) || (function () {
var ownKeys = function(o) {
ownKeys = Object.getOwnPropertyNames || function (o) {
var ar = [];
for (var k in o) if (Object.prototype.hasOwnProperty.call(o, k)) ar[ar.length] = k;
return ar;
};
return ownKeys(o);
};
return function (mod) {
if (mod && mod.__esModule) return mod;
var result = {};
if (mod != null) for (var k = ownKeys(mod), i = 0; i < k.length; i++) if (k[i] !== "default") __createBinding(result, mod, k[i]);
__setModuleDefault(result, mod);
return result;
};
})();
Object.defineProperty(exports, "__esModule", { value: true });
/**
* Runs in a worker thread (never blocks the Electron main process).
* Keep walk caps in sync with audit.ts.
*/
const node_worker_threads_1 = require("node:worker_threads");
const fssync = __importStar(require("node:fs"));
const path = __importStar(require("node:path"));
const FOLDER_WALK_MAX_FILES = 200_000;
function resolveSafePath(input) {
return path.resolve(path.normalize(input));
}
function measureFolderTree(rootDir, maxFiles = FOLDER_WALK_MAX_FILES) {
const root = resolveSafePath(rootDir);
let bytes = 0;
let files = 0;
const walk = (d) => {
let list;
try {
list = fssync.readdirSync(d, { withFileTypes: true });
}
catch {
return false;
}
for (const ent of list) {
if (files >= maxFiles)
return true;
const p = path.join(d, ent.name);
try {
if (ent.isDirectory()) {
if (walk(p))
return true;
}
else {
bytes += fssync.statSync(p).size;
files++;
}
}
catch {
/* skip */
}
}
return false;
};
const truncated = walk(root);
return { bytes, files, truncated };
}
function findLargeFilesSync(rootPath, minBytes, maxResults) {
const root = resolveSafePath(rootPath);
const results = [];
const cap = Math.min(maxResults, 500);
const walk = (d) => {
if (results.length >= cap)
return;
let list;
try {
list = fssync.readdirSync(d, { withFileTypes: true });
}
catch {
return;
}
for (const ent of list) {
if (results.length >= cap)
return;
const p = path.join(d, ent.name);
try {
if (ent.isDirectory()) {
walk(p);
}
else {
const st = fssync.statSync(p);
if (st.size >= minBytes) {
results.push({ path: p, sizeBytes: st.size });
}
}
}
catch {
/* skip */
}
}
};
walk(root);
results.sort((a, b) => b.sizeBytes - a.sizeBytes);
return results.slice(0, cap);
}
if (!node_worker_threads_1.isMainThread && node_worker_threads_1.parentPort) {
node_worker_threads_1.parentPort.on('message', (msg) => {
try {
if (msg.kind === 'large') {
const largeResults = findLargeFilesSync(msg.root, msg.minBytes, msg.maxResults);
node_worker_threads_1.parentPort.postMessage({ id: msg.id, ok: true, largeResults });
}
else {
const { bytes, files, truncated } = measureFolderTree(msg.root);
node_worker_threads_1.parentPort.postMessage({ id: msg.id, ok: true, bytes, files, truncated });
}
}
catch (e) {
node_worker_threads_1.parentPort.postMessage({
id: msg.id,
ok: false,
error: String(e.message),
});
}
});
}
|