// @ts-check
const { exec, execSync } = require('node:child_process');
const {
  LARGE_BUFFER,
} = require('nx/src/executors/run-commands/run-commands.impl');

async function populateLocalRegistryStorage() {
  const listenAddress = 'localhost';
  const port = process.env.NX_LOCAL_REGISTRY_PORT ?? '4873';
  const registry = `http://${listenAddress}:${port}`;
  const authToken = 'secretVerdaccioToken';

  while (true) {
    await new Promise((resolve) => setTimeout(resolve, 250));
    try {
      await assertLocalRegistryIsRunning(registry);
      break;
    } catch {
      console.log(`Waiting for Local registry to start on ${registry}...`);
    }
  }

  process.env.npm_config_registry = registry;

  // bun
  process.env.BUN_CONFIG_REGISTRY = registry;
  process.env.BUN_CONFIG_TOKEN = authToken;
  // yarnv1
  process.env.YARN_REGISTRY = registry;
  // yarnv2
  process.env.YARN_NPM_REGISTRY_SERVER = registry;
  process.env.YARN_UNSAFE_HTTP_WHITELIST = listenAddress;

  try {
    const publishVersion = process.env.PUBLISHED_VERSION ?? 'major';
    const isVerbose = process.env.NX_VERBOSE_LOGGING === 'true';

    console.log('Publishing packages to local registry to populate storage');
    await runLocalRelease(publishVersion, isVerbose);
  } catch (err) {
    console.error('Error:', err);
    process.exit(1);
  }
}
exports.populateLocalRegistryStorage = populateLocalRegistryStorage;

function runLocalRelease(publishVersion, isVerbose) {
  return new Promise((res, rej) => {
    const publishProcess = exec(`pnpm nx-release --local ${publishVersion}`, {
      env: process.env,
      maxBuffer: LARGE_BUFFER,
    });
    let logs = Buffer.from('');
    if (isVerbose) {
      publishProcess?.stdout?.pipe(process.stdout);
      publishProcess?.stderr?.pipe(process.stderr);
    } else {
      publishProcess?.stdout?.on('data', (data) => (logs += data));
      publishProcess?.stderr?.on('data', (data) => (logs += data));
    }
    publishProcess.on('exit', (code) => {
      if (code && code > 0) {
        if (!isVerbose) {
          console.log(logs.toString());
        }
        rej(code);
      }
      res(undefined);
    });
  });
}
exports.runLocalRelease = runLocalRelease;

async function assertLocalRegistryIsRunning(url) {
  const response = await fetch(url);
  if (!response.ok) {
    throw new Error(`HTTP error! status: ${response.status}`);
  }
}