121 lines
3.5 KiB
TypeScript
121 lines
3.5 KiB
TypeScript
import { type FetchOptions } from "make-fetch-happen";
|
|
import * as child_process from "child_process";
|
|
import * as fs from "fs";
|
|
|
|
export type ProxyFetchOptions = Pick<
|
|
FetchOptions,
|
|
"proxy" | "noProxy" | "strictSSL" | "cert" | "ca"
|
|
>;
|
|
|
|
export function getProxyFetchOptions(params: {
|
|
npmConfigGetCwd: string;
|
|
}): ProxyFetchOptions {
|
|
const { npmConfigGetCwd } = params;
|
|
|
|
const cfg = (() => {
|
|
const output = child_process
|
|
.execSync("npm config get", {
|
|
cwd: npmConfigGetCwd
|
|
})
|
|
.toString("utf8");
|
|
|
|
console.log("Output of `npm config get`:");
|
|
console.log(output);
|
|
|
|
return output
|
|
.split("\n")
|
|
.filter(line => !line.startsWith(";"))
|
|
.map(line => line.trim())
|
|
.map(line => line.split("=", 2) as [string, string])
|
|
.reduce(
|
|
(
|
|
cfg: Record<string, string | string[]>,
|
|
[key, value]: [string, string]
|
|
) =>
|
|
key in cfg
|
|
? { ...cfg, [key]: [...ensureArray(cfg[key]), value] }
|
|
: { ...cfg, [key]: value },
|
|
{}
|
|
);
|
|
})();
|
|
|
|
console.log("npm config get object");
|
|
console.log(cfg);
|
|
|
|
const proxy = ensureSingleOrNone(cfg["https-proxy"] ?? cfg["proxy"]);
|
|
|
|
console.log("proxy", proxy);
|
|
|
|
const noProxy = cfg["noproxy"] ?? cfg["no-proxy"];
|
|
|
|
console.log("noProxy", noProxy);
|
|
|
|
function maybeBoolean(arg0: string | undefined) {
|
|
return typeof arg0 === "undefined" ? undefined : Boolean(arg0);
|
|
}
|
|
|
|
const strictSSL = maybeBoolean(ensureSingleOrNone(cfg["strict-ssl"]));
|
|
|
|
console.log("strictSSL", strictSSL);
|
|
|
|
const cert = cfg["cert"];
|
|
|
|
console.log("cert", cert);
|
|
const ca = ensureArray(cfg["ca"] ?? cfg["ca[]"]);
|
|
|
|
console.log("ca", ca);
|
|
const cafile = ensureSingleOrNone(cfg["cafile"]);
|
|
|
|
console.log("cafile", cafile);
|
|
|
|
if (typeof cafile !== "undefined" && cafile !== "null") {
|
|
ca.push(
|
|
...(() => {
|
|
const cafileContent = fs.readFileSync(cafile).toString("utf8");
|
|
|
|
const newLinePlaceholder = "NEW_LINE_PLACEHOLDER_xIsPsK23svt";
|
|
|
|
const chunks = <T>(arr: T[], size: number = 2) =>
|
|
arr
|
|
.map((_, i) => i % size == 0 && arr.slice(i, i + size))
|
|
.filter(Boolean) as T[][];
|
|
|
|
return chunks(cafileContent.split(/(-----END CERTIFICATE-----)/), 2).map(
|
|
ca =>
|
|
ca
|
|
.join("")
|
|
.replace(/\r?\n/g, newLinePlaceholder)
|
|
.replace(new RegExp(`^${newLinePlaceholder}`), "")
|
|
.replace(new RegExp(newLinePlaceholder, "g"), "\\n")
|
|
);
|
|
})()
|
|
);
|
|
}
|
|
|
|
const out = {
|
|
proxy,
|
|
noProxy,
|
|
strictSSL,
|
|
cert,
|
|
ca: ca.length === 0 ? undefined : ca
|
|
};
|
|
|
|
console.log("Final proxy options", out);
|
|
|
|
return out;
|
|
}
|
|
|
|
function ensureArray<T>(arg0: T | T[]) {
|
|
return Array.isArray(arg0) ? arg0 : typeof arg0 === "undefined" ? [] : [arg0];
|
|
}
|
|
|
|
function ensureSingleOrNone<T>(arg0: T | T[]) {
|
|
if (!Array.isArray(arg0)) return arg0;
|
|
if (arg0.length === 0) return undefined;
|
|
if (arg0.length === 1) return arg0[0];
|
|
throw new Error(
|
|
"Illegal configuration, expected a single value but found multiple: " +
|
|
arg0.map(String).join(", ")
|
|
);
|
|
}
|