import { createHash } from "node:crypto";

import { lookup as dnsLookupCb } from "node:dns";

import { lookup as dnsLookup } from "node:dns/promises";

import { once } from "node:events";

import { createWriteStream } from "node:fs";

import fs from "node:fs/promises";

import { request as httpsRequest } from "node:https";

const size = typeof value === "string" ? Buffer.byteLength(value) : value.byteLength;

downloaded += size;

if (downloaded > maxBytes) {

await reader.cancel().catch(() => {});

throw new Error(`package_url exceeds maximum download size of ${maxBytes} bytes`);

}

yield value;

options,

);

const tempTarget = `${target}.tmp`;

let output;

try {

if (!responseOk(response) || !response.body) {

throw new Error(`failed to download package_url: HTTP ${responseStatus(response)}`);

throw new Error(`package_url exceeds maximum download size of ${maxBytes} bytes`);

}

await fs.rm(tempTarget, { force: true });

await pipeline(

limitResponseBody(response.body, maxBytes, timeoutPromise),

createWriteStream(tempTarget),

);

output = createWriteStream(tempTarget);

await pipeline(limitResponseBody(response.body, maxBytes, timeoutPromise), output);

await fs.rename(tempTarget, target);

} catch (error) {

if (error?.code === "ETIMEDOUT") {

} finally {

clearTimeout(timeout);

await close();

if (output && !output.closed) {

await once(output, "close").catch(() => {});

}

await fs.rm(tempTarget, { force: true });

}

}