import cp from "child_process";
import fs from "fs";
import path from "path";
import { fileURLToPath } from "url";
import { promisify } from "util";

const PACKAGE_JSON = "package.json";
// hack to get __dirname
const DIR = path.dirname(fileURLToPath(import.meta.url));

const exec = promisify(cp.exec);
const readFile = promisify(fs.readFile);

run()
  .then(() => {
    console.info("Successfully published packages.");
  })
  .catch((err) => {
    console.error("Failed at publishing packages with ", err.message);
  });

async function run() {
  const rootPackage = await readJSON(path.resolve(DIR, "../", PACKAGE_JSON));
  const workspacePaths = rootPackage.workspaces;

  const workspaces = await Promise.all(
    workspacePaths.map(async (workspacePath) => {
      const workspaceInfo = await readWorkspace(workspacePath);
      const allowPublishing = await shouldBePublished(workspaceInfo);

      if (allowPublishing) {
        return workspaceInfo;
      }

      return;
    })
  );

  await Promise.all(
    workspaces
      .filter((v) => !!v)
      .map(async (info) => {
        try {
          await exec(
            `npm publish --workspace ${info.workspace} --tag latest --access public`
          );
          console.info(
            `Successfully published ${info.workspace} with version ${info.version}.`
          );
        } catch (err) {
          console.error(
            `Cannot publish ${info.workspace} with version ${info.version}. Error: ${err.message}`
          );
        }
      })
  );
}

async function readJSON(path) {
  const rawJSON = await readFile(path, "utf-8");
  return JSON.parse(rawJSON);
}

async function readWorkspace(packagePath) {
  const json = await readJSON(
    path.resolve(DIR, "../", packagePath, PACKAGE_JSON)
  );

  return {
    name: json.name,
    private: !!json.private,
    version: json.version,
    workspace: packagePath,
  };
}

async function shouldBePublished(info) {
  if (info.private) {
    console.info(`Skipping ${info.path} because it is private.`);
    return false;
  }

  try {
    const npmTag = `${info.name}@${info.version}`;
    const { stdout } = await exec(`npm view ${npmTag} version`);

    if (stdout.trim() !== info.version.trim()) {
      return true;
    }

    console.info(`Workspace ${info.path} is already published.`);
  } catch (err) {
    if (err.message.includes("code E404")) {
      return true;
    }

    console.error(
      `Cannot check published version of ${info.path}. Received error: ${err.message}`
    );
  }
}