import { createServer } from "node:http";
import { createDefaultCentralAuth, type CentralAuth } from "../auth/index.js";
import { createInMemoryCentralPorts } from "../controlPlane/inMemoryCentralPorts.js";
import { CENTRAL_SERVICE_ID } from "../controlPlane/shared.js";
import { errorMessage, handleCentralCorsPreflight, sendJson } from "./http.js";
import { handleMateriaCentralRequest } from "./routes.js";
import type { ControlPlanePorts } from "../../application/controlPlane.js";

export { createInMemoryCentralPorts } from "../controlPlane/inMemoryCentralPorts.js";
export type { InMemoryCentralPortsOptions } from "../controlPlane/inMemoryCentralPorts.js";
export { CENTRAL_SERVICE_ID, CENTRAL_CONTROL_PLANE_SCOPE } from "../controlPlane/shared.js";
export { sendJson, readJsonBody, isPlainObject, errorMessage, applyCentralCorsHeaders, handleCentralCorsPreflight, CENTRAL_CORS_ALLOW_ORIGIN } from "./http.js";
export { handleCentralHealthRoute } from "./health.js";
export type { CentralHealthRouteDeps } from "./health.js";
export { handleCentralStatusRoute } from "./status.js";
export type { CentralStatusRouteDeps } from "./status.js";
export { handleCentralCatalogRoute } from "./catalog.js";
export type { CentralCatalogRouteDeps } from "./catalog.js";
export { handleCentralModelPolicyRoute } from "./modelPolicy.js";
export type { CentralModelPolicyRouteDeps } from "./modelPolicy.js";
export { handleCentralModelCatalogRoute } from "./modelCatalog.js";
export type { CentralModelCatalogRouteDeps } from "./modelCatalog.js";
export { handleCentralTelemetryRoute } from "./telemetry.js";
export type { CentralTelemetryRouteDeps } from "./telemetry.js";
export { handleMateriaCentralRequest } from "./routes.js";
export type { MateriaCentralRouteDeps } from "./routes.js";

export interface MateriaCentralServerOptions {
  host?: string;
  port?: number;
  /**
   * Control-plane ports backing the server. Defaults to a fresh in-memory
   * central-admin port set. Callers may inject ports for testing or for a
   * future central-connected client adapter.
   */
  ports?: ControlPlanePorts;
  /**
   * Auth configuration for the route guards. Defaults to a dev-token adapter
   * with the documented development-only token set and the default central role
   * registry. Supply a custom {@link CentralAuth} (future OAuth/OIDC adapter +
   * custom roles) for non-local deployments (docs/enterprise-control-plane.md
   * §13).
   */
  auth?: CentralAuth;
  /** Human-readable label surfaced on health/status envelopes. */
  label?: string;
}

export interface MateriaCentralServer {
  /** The underlying Node HTTP server. */
  server: ReturnType<typeof createServer>;
  /** Resolved bind host. */
  host: string;
  /** Requested bind port (use `server.address()` for the actual bound port). */
  port: number;
  /** Control-plane ports backing the server. */
  ports: ControlPlanePorts;
  /** Resolved auth configuration used by route guards. */
  auth: CentralAuth;
}

/**
 * Create the central control-plane server.
 *
 * Separate from the local-session WebUI server (src/webui/server/index.ts):
 * startup does not open a local repository session, does not read
 * `.pi/pi-materia/quest-board.json`, and does not expose local-session routes.
 * Backed by in-memory adapters only at this stage
 * (docs/enterprise-control-plane.md §3.3, §8, §16.4).
 */
export function createMateriaCentralServer(options: MateriaCentralServerOptions = {}): MateriaCentralServer {
  const host = options.host ?? "127.0.0.1";
  const port = options.port ?? 0;
  const auth = options.auth ?? createDefaultCentralAuth();
  const ports = options.ports ?? createInMemoryCentralPorts({
    ...(options.label !== undefined ? { label: options.label } : {}),
    authMethods: [auth.methodKind],
  });

  const server = createServer(async (req, res) => {
    try {
      if (handleCentralCorsPreflight(req, res)) return;
      await handleMateriaCentralRequest(req, res, { ports, auth, ...(options.label !== undefined ? { label: options.label } : {}) });
    } catch (error) {
      sendJson(res, 500, { ok: false, scope: "control-plane", service: CENTRAL_SERVICE_ID, error: errorMessage(error) });
    }
  });

  return { server, host, port, ports, auth };
}

if (import.meta.url === `file://${process.argv[1]}`) {
  const port = Number.parseInt(process.env.MATERIA_CENTRAL_PORT ?? "0", 10);
  const host = process.env.MATERIA_CENTRAL_HOST ?? "127.0.0.1";
  const label = process.env.MATERIA_CENTRAL_LABEL;
  const created = createMateriaCentralServer({
    host,
    port: Number.isFinite(port) ? port : 0,
    ...(label !== undefined ? { label } : {}),
  });
  created.server.listen(created.port, created.host, () => {
    const address = created.server.address();
    const actualPort = typeof address === "object" && address ? address.port : created.port;
    const mode = created.ports.telemetry.mode().mode;
    console.log(`${CENTRAL_SERVICE_ID} (central control plane, mode=${mode}) listening at http://${created.host}:${actualPort}`);
  });
}