server.js

import { createServer as createHttpServer } from "node:http";
import { dirname, join } from "node:path";
import { fileURLToPath, pathToFileURL } from "node:url";
import { createApp } from "./src/app.js";
import { loadConfig } from "./src/config.js";
import { LinkStore } from "./src/store.js";

const defaultRootDir = dirname(fileURLToPath(import.meta.url));

export async function startServer({
  rootDir = defaultRootDir,
  env = process.env,
} = {}) {
  const config = await loadConfig({ rootDir, env });
  const store = new LinkStore(config.dataDir);
  await store.load();
  const app = createApp({
    config,
    store,
    publicDir: join(rootDir, "public"),
  });
  const server = createHttpServer(app);

  await new Promise((resolve, reject) => {
    server.once("error", reject);
    server.listen(config.port, config.host, resolve);
  });

  const address = server.address();
  const port = typeof address === "object" ? address.port : config.port;
  console.log(`LinkBoard running at http://${config.host}:${port}`);

  return {
    config,
    server,
    store,
    async close() {
      await new Promise((resolve, reject) => {
        server.close((error) => (error ? reject(error) : resolve()));
      });
      await store.flush();
    },
  };
}

function installShutdown(runtime) {
  for (const signal of ["SIGINT", "SIGTERM"]) {
    process.once(signal, async () => {
      console.log(`${signal} received; shutting down`);
      const forceExit = setTimeout(() => process.exit(1), 10_000);
      forceExit.unref();
      try {
        await runtime.close();
        process.exitCode = 0;
      } catch (error) {
        console.error("Graceful shutdown failed", error);
        process.exitCode = 1;
      }
    });
  }
}

const isEntryPoint =
  process.argv[1] && pathToFileURL(process.argv[1]).href === import.meta.url;
if (isEntryPoint) {
  installShutdown(await startServer());
}