import fs from "node:fs/promises";

import os from "node:os";

import path from "node:path";

import { pathToFileURL } from "node:url";

import { resolvePnpmRunner } from "./pnpm-runner.mjs";

type RunResult = {

code: number | null;

stderr: string;

};

type PnpmCommand = {

args: string[];

command: string;

env?: NodeJS.ProcessEnv;

shell: boolean;

windowsVerbatimArguments?: boolean;

};

type ResolvePnpmCommandOptions = {

comSpec?: string;

env?: NodeJS.ProcessEnv;

execPath?: string;

npmExecPath?: string;

platform?: NodeJS.Platform;

};

function resolveEnvValue(env: NodeJS.ProcessEnv, name: string): string | undefined {

const key = Object.keys(env).find((candidate) => candidate.toLowerCase() === name.toLowerCase());

return key === undefined ? undefined : env[key];

}

export function resolveZaiFallbackPnpmCommand(

args: string[],

options: ResolvePnpmCommandOptions = {},

): PnpmCommand {

const env = options.env ?? process.env;

const command = resolvePnpmRunner({

comSpec: options.comSpec ?? resolveEnvValue(env, "ComSpec"),

npmExecPath: options.npmExecPath ?? env.npm_execpath,

nodeExecPath: options.execPath ?? process.execPath,

platform: options.platform,

pnpmArgs: args,

});

if (command.env === undefined) {

const invocation = { ...command };

delete invocation.env;

return invocation;

}

return command;

}

function pickAnthropicEnv(): { type: "oauth" | "api"; value: string } | null {

const oauth = process.env.ANTHROPIC_OAUTH_TOKEN?.trim();

if (oauth) {

env: NodeJS.ProcessEnv,

): Promise<RunResult> {

return await new Promise((resolve, reject) => {

const child = spawn("pnpm", args, {

env,

const command = resolveZaiFallbackPnpmCommand(args, { env });

const child = spawn(command.command, command.args, {

env: command.env ?? env,

shell: command.shell,

stdio: ["ignore", "pipe", "pipe"],

windowsVerbatimArguments: command.windowsVerbatimArguments,

});

let stdout = "";

let stderr = "";

process.exit(run2.code ?? 1);

}

main().catch((err) => {

console.error(err);

process.exit(1);

});

function isCliEntrypoint() {

const entrypoint = process.argv[1];

return Boolean(entrypoint && import.meta.url === pathToFileURL(path.resolve(entrypoint)).href);

}

if (isCliEntrypoint()) {

await main().catch((err) => {

console.error(err);

process.exit(1);

});

}