Function setupCliTarget

e2e/setup/cli.globalsetup.ts:50–97

(os: VmOs)

};

export async function setupCliTarget(os: VmOs): Promise<(() => Promise<void>) | void> {
  process.env.E2E_VM_OS = os; // so the worker-side target resolves the same OS

  const arch: VmArch = os === "windows" ? "x64" : "arm64";
  const binDir = await buildGuestBinary(os, arch);
  const vm: VmHandle =
    os === "windows" ? await ec2Vm(os, arch).provision() : await tartVm(os, arch).provision();
  const plan = guestPlan(os);

  let tunnelClose: (() => void) | undefined;
  try {
    await vm.ssh(plan.prep);
    await vm.push(`${binDir}/.`, os === "windows" ? plan.dir : `${plan.dir}/`);
    await vm.ssh(plan.postPush);

    const install = await vm.ssh(plan.install);
    if (install.code !== 0) {
      throw new Error(`service install failed: ${install.stderr.trim() || install.stdout.trim()}`);
    }

    // The supervised daemon mints/loads its bearer into auth.json on first boot.
    const tokenRaw = (await vm.ssh(plan.readToken)).stdout.trim();
    const token = (JSON.parse(tokenRaw) as { token: string }).token;

    const tunnel = await vm.tunnel(PORT);
    tunnelClose = tunnel.close;
    const baseUrl = `http://127.0.0.1:${tunnel.localPort}`;
    await waitForHttp(`${baseUrl}/`, { timeoutMs: 60_000 });

    process.env.E2E_CLI_BASE_URL = baseUrl;
    process.env.E2E_CLI_AUTH_TOKEN = token;
    process.env.E2E_CLI_VM_HOST = vm.host;
    if (vm.sshKeyPath) process.env.E2E_CLI_SSH_KEY = vm.sshKeyPath;
    process.env.E2E_CLI_TUNNEL_PORT = String(tunnel.localPort);
    process.env.E2E_CLI_BIN_DIR = plan.dir;
  } catch (error) {
    tunnelClose?.();
    await vm.ssh(plan.uninstall).catch(() => undefined);
    await vm.discard();
    throw error;
  }

  return async () => {
    tunnelClose?.();
    await vm.ssh(plan.uninstall).catch(() => undefined);
    await vm.discard();
  };
}