"use strict";
const {
  PDS,
  Database,
  envToCfg,
  envToSecrets,
  readEnv,
  httpLogger,
} = require("@atproto/pds");
const pkg = require("@atproto/pds/package.json");

const main = async () => {
  const env = readEnv();
  env.version ||= pkg.version;
  const cfg = envToCfg(env);
  const secrets = envToSecrets(env);
  const pds = await PDS.create(cfg, secrets);
  if (cfg.db.dialect === "pg") {
    // Migrate using credentialed user
    const migrateDb = Database.postgres({
      url: cfg.db.migrationUrl,
      schema: cfg.db.schema,
    });
    await migrateDb.migrateToLatestOrThrow();
    await migrateDb.close();
  } else {
    await pds.ctx.db.migrateToLatestOrThrow();
  }
  await pds.start();
  httpLogger.info("pds is running");
  // Graceful shutdown (see also https://aws.amazon.com/blogs/containers/graceful-shutdowns-with-ecs/)
  process.on("SIGTERM", async () => {
    httpLogger.info("pds is stopping");
    await pds.destroy();
    httpLogger.info("pds is stopped");
  });
};

main();