import {
  cloneEnvWithPlatformSemantics,
  createConfigRuntimeEnv,
} from "../../config/config-env-vars.js";
import {
  ALLOW_OLDER_BINARY_DESTRUCTIVE_ACTIONS_ENV,
  formatFutureConfigActionBlock,
  resolveFutureConfigActionBlock,
} from "../../config/future-version-guard.js";
// Gateway-specific future-config actions shared by pre-bootstrap and runtime startup.
import type { ConfigFileSnapshot, OpenClawConfig } from "../../config/types.js";
import type { RuntimeEnv } from "../../runtime.js";
import type { GatewayRunOpts } from "./run-options.js";

export type GatewayRunPreBootstrapOptions = Pick<GatewayRunOpts, "force" | "reset">;

type GatewayRunFutureConfigGuardParams = {
  opts: GatewayRunPreBootstrapOptions;
  snapshot?: ConfigFileSnapshot | null;
  config?: Pick<OpenClawConfig, "env" | "meta"> | null;
};

function resolveGatewayRunFutureConfigBlock(params: GatewayRunFutureConfigGuardParams) {
  const processServiceMode = Boolean(process.env.OPENCLAW_SERVICE_MARKER?.trim());
  const candidateConfig =
    params.config ??
    (params.snapshot?.valid ? (params.snapshot.sourceConfig ?? params.snapshot.config) : undefined);
  const candidateServiceMode =
    !params.opts.reset &&
    Boolean(
      candidateConfig
        ? createConfigRuntimeEnv(candidateConfig, process.env).OPENCLAW_SERVICE_MARKER?.trim()
        : undefined,
    );
  const serviceMode = processServiceMode || candidateServiceMode;
  // Reset runs before service/force startup, while ordinary startup now runs state migrations.
  const futureAction = params.opts.reset
    ? { action: "reset the dev gateway state", exitCode: 1 }
    : serviceMode
      ? { action: "start the gateway service", exitCode: 78 }
      : params.opts.force
        ? { action: "force-kill gateway port listeners", exitCode: 1 }
        : { action: "run automatic gateway startup migrations", exitCode: 1 };
  const guardEnv = serviceMode ? cloneEnvWithPlatformSemantics(process.env) : process.env;
  if (serviceMode) {
    delete guardEnv[ALLOW_OLDER_BINARY_DESTRUCTIVE_ACTIONS_ENV];
  }
  const block = resolveFutureConfigActionBlock({
    action: futureAction.action,
    snapshot: params.snapshot,
    config: params.config,
    env: guardEnv,
  });
  return block ? { block, exitCode: futureAction.exitCode, serviceMode } : null;
}

export function enforceGatewayRunFutureConfigGuard(
  params: GatewayRunFutureConfigGuardParams & { runtime: RuntimeEnv },
): boolean {
  const resolved = resolveGatewayRunFutureConfigBlock(params);
  if (!resolved) {
    return true;
  }
  if (resolved.serviceMode) {
    delete process.env[ALLOW_OLDER_BINARY_DESTRUCTIVE_ACTIONS_ENV];
  }
  params.runtime.error(formatFutureConfigActionBlock(resolved.block));
  params.runtime.exit(resolved.exitCode);
  return false;
}