const PACKAGE_URL_DOWNLOAD_TIMEOUT_MS = 60_000;

const PACKAGE_URL_MAX_BYTES = 250 * 1024 * 1024;

const PACKAGE_URL_MAX_REDIRECTS = 5;

export const ARTIFACT_TARBALL_SCAN_MAX_ENTRIES = 10_000;

const COMMAND_STDOUT_CAPTURE_MAX_CHARS = 8 * 1024 * 1024;

const COMMAND_STDERR_CAPTURE_MAX_CHARS = 128 * 1024;

const COMMAND_TIMEOUT_KILL_AFTER_MS = 5_000;

export const runCommandForTest = run;

async function walkFiles(dir) {

const entries = await fs.readdir(dir, { withFileTypes: true });

const files = [];

for (const entry of entries) {

const absolute = path.join(dir, entry.name);

if (entry.isDirectory()) {

files.push(...(await walkFiles(absolute)));

} else if (entry.isFile()) {

files.push(absolute);

}

}

return files;

}

async function sha256(file) {

const hash = createHash("sha256");

const handle = await fs.open(file, "r");

}

async function findSingleTarball(dir) {

const files = (await walkFiles(path.resolve(ROOT_DIR, dir)))

.filter((file) => /\.t(?:ar\.)?gz$/u.test(path.basename(file)))

.toSorted((a, b) => a.localeCompare(b));

if (files.length !== 1) {

const root = path.resolve(ROOT_DIR, dir);

const pending = [root];

const tarballs = [];

let scannedEntries = 0;

while (pending.length > 0) {

const currentDir = pending.pop();

if (!currentDir) {

continue;

}

const handle = await fs.opendir(currentDir);

for await (const entry of handle) {

scannedEntries += 1;

if (scannedEntries > ARTIFACT_TARBALL_SCAN_MAX_ENTRIES) {

throw new Error(

`source=artifact scan exceeded ${ARTIFACT_TARBALL_SCAN_MAX_ENTRIES} filesystem entries under ${dir}; provide a smaller artifact directory containing exactly one .tgz.`,

);

}

const absolute = path.join(currentDir, entry.name);

if (entry.isDirectory()) {

pending.push(absolute);

continue;

}

if (entry.isFile() && /\.t(?:ar\.)?gz$/u.test(entry.name)) {

tarballs.push(absolute);

if (tarballs.length > 1) {

throw new Error(

`source=artifact requires exactly one .tgz under ${dir}; found at least 2: ${tarballs.toSorted((a, b) => a.localeCompare(b)).join(", ")}`,

);

}

}

}

}

if (tarballs.length !== 1) {

throw new Error(

`source=artifact requires exactly one .tgz under ${dir}; found ${files.length}: ${files.join(", ")}`,

`source=artifact requires exactly one .tgz under ${dir}; found ${tarballs.length}: ${tarballs.join(", ")}`,

);

}

return files[0];

return tarballs[0];

}

export const findSingleTarballForTest = findSingleTarball;

export async function readArtifactPackageCandidateMetadata(dir) {

const metadataPath = path.join(path.resolve(ROOT_DIR, dir), "package-candidate.json");

let raw;