Function register

src/instrumentation.ts:35–77

()

}

export async function register() {
  if (process.env.NEXT_RUNTIME === "nodejs") {
    if (globalThis.__polyworldRuntimeStarted) {
      return;
    }

    validateEnv();

    const { startSyncLoop, stopSyncLoop } = await import("./lib/sync");
    startSyncLoop();
    const { startNewsSyncLoop, stopNewsSyncLoop } = await import("./lib/newsSync");
    startNewsSyncLoop();
    const { startSmartMoneySync, stopSmartMoneySync } = await import("./lib/smartMoneySync");
    startSmartMoneySync();
    const { startTweetsSyncLoop, stopTweetsSyncLoop } = await import("./lib/tweetsSync");
    startTweetsSyncLoop();
    const { startResolutionSyncLoop, stopResolutionSyncLoop } = await import("./lib/resolutionSync");
    startResolutionSyncLoop();
    globalThis.__polyworldRuntimeStarted = true;

    if (!globalThis.__polyworldShutdownBound) {
      const shutdown = async () => {
        console.info("[shutdown] Graceful shutdown initiated...");
        stopSyncLoop();
        stopNewsSyncLoop();
        stopSmartMoneySync();
        stopTweetsSyncLoop();
        stopResolutionSyncLoop();
        globalThis.__polyworldRuntimeStarted = false;

        const { closeDb } = await import("./lib/db");
        closeDb();

        console.info("[shutdown] Cleanup complete, exiting.");
        process.exit(0);
      };

      process.on("SIGTERM", shutdown);
      process.on("SIGINT", shutdown);
      globalThis.__polyworldShutdownBound = true;
    }
  }
}