Class Lifecycle

src/runtime/lifecycle.ts:20–109

export class Lifecycle implements LifecycleHandler, LifecycleInfo {
  private readonly server: Server;
  private readonly exitFn: ExitFn;

  private adapters: PlatformAdapter[] = [];
  private stopReason: StopReason | null = null;

  constructor(server: Server, exitFn: ExitFn = (code) => process.exit(code)) {
    this.server = server;
    this.exitFn = exitFn;

  }

  registerAdapters(adapters: PlatformAdapter[]): void {
    this.adapters = adapters;
  }



  async requestRestart(trigger: LifecycleTrigger): Promise<CommandResult> {
    return this.requestStop("restart", trigger);
  }

  async requestShutdown(trigger: LifecycleTrigger): Promise<CommandResult> {
    return this.requestStop("shutdown", trigger);
  }

  private async requestStop(
    reason: StopReason,
    trigger: LifecycleTrigger,
  ): Promise<CommandResult> {
    if (this.stopReason) {
      const message =
        this.stopReason === "restart"
          ? "Restart already in progress."
          : "Shutdown already in progress.";
      return { success: true, message };
    }

    this.stopReason = reason;
    console.log(`[Lifecycle] ${reason} requested via ${trigger}`);

    setTimeout(() => {
      void this.gracefulStopAndExit(reason);
    }, 50);

    return {
      success: true,
      message: reason === "restart" ? "Restarting..." : "Shutting down...",
    };
  }

  private async gracefulStopAndExit(reason: StopReason): Promise<void> {
    try {
      await Promise.race([
        this.gracefulStop(),
        new Promise<void>((resolve) => {
          setTimeout(() => {