import { $ } from "execa";
import { dirAsync, existsAsync } from "fs-jetpack";
import { deploy } from "utils/deploy";
import { startDevWatcher } from "utils/dev-watcher";
import { dir } from "utils/dir";
import { ensureNotRunning } from "utils/ensure";
import { preparePrisma } from "utils/prisma";
import { generateAPIFrm } from "./server/api-frm";
import { createServer } from "./server/create";
import { prepareAPITypes } from "./server/prep-api-ts";
import { config } from "./utils/config";
import { g } from "./utils/global";
import { createLogger } from "./utils/logger";
import { genEnv, parseEnv } from "utils/parse-env";

g.mode = process.argv.includes("dev") ? "dev" : "prod";
g.datadir = g.mode === "prod" ? "../data" : ".data";

if (!(await existsAsync(dir("app")))) {
  await dirAsync(dir("app"));
}

if (!(await existsAsync(dir("app/db")))) {
  await $`unzip -o pkgs/zip/dbzip -d app`;
}

if (!(await existsAsync(dir("app/srv")))) {
  await $`unzip -o pkgs/zip/srvzip -d app`;
}

if (!process.env.PORT) {
  g.port = 3000;
  const env = genEnv({
    ...parseEnv(".env"),
    ...parseEnv(dir("app/db/.env")),
    PORT: g.port,
  });
  await Bun.write(".env", env);
} else {
  g.port = parseInt(process.env.PORT);
}

await preparePrisma();
await createLogger();
await ensureNotRunning();

if (g.db) {
  await g.db.$connect();
}

await config.init();

g.log.info(g.mode === "dev" ? "DEVELOPMENT" : "PRODUCTION");

await deploy.init();
if (g.mode === "dev") {
  await startDevWatcher();
}

await createServer();

await generateAPIFrm();
await prepareAPITypes();