"""
  Admin API routes for configuration and management.
  """
  

  from fastapi import APIRouter, HTTPException, Request

  
  from ..models import HealthResponse, ErrorResponse

  from indexer.mapping_generator import get_tenant_index_name

  
  router = APIRouter(prefix="/admin", tags=["admin"])
  
  
  @router.get("/health", response_model=HealthResponse)
  async def health_check():
      """
      Health check endpoint.
  
      Returns service status and Elasticsearch connectivity.
      """
      try:

          from ..app import get_es_client, get_config

  
          es_client = get_es_client()
          config = get_config()
  
          # Check ES connectivity
          es_status = "connected" if es_client.ping() else "disconnected"
  
          return HealthResponse(
              status="healthy" if es_status == "connected" else "unhealthy",

              elasticsearch=es_status

          )
  
      except Exception as e:
          return HealthResponse(
              status="unhealthy",

              elasticsearch="error"

          )
  
  
  @router.get("/config")
  async def get_configuration():
      """

      Get the effective application configuration (sanitized).

      """
      try:

          from ..app import get_config

          return get_config().sanitized_dict()
  
      except HTTPException:
          raise
      except Exception as e:
          raise HTTPException(status_code=500, detail=str(e))

  
  @router.get("/config/meta")
  async def get_configuration_meta():
      """Get configuration metadata for observability."""
      try:
          from ..app import get_config
  
          config = get_config()

          return {

              "environment": config.runtime.environment,
              "config_hash": config.metadata.config_hash,
              "loaded_files": list(config.metadata.loaded_files),
              "deprecated_keys": list(config.metadata.deprecated_keys),

          }

      except HTTPException:
          raise

      except Exception as e:
          raise HTTPException(status_code=500, detail=str(e))
  
  

  @router.get("/stats")

  async def get_index_stats(http_request: Request):

      """
      Get index statistics.
      """
      try:

          from urllib.parse import parse_qs
          from ..app import get_es_client

  
          es_client = get_es_client()

  
          tenant_id = http_request.headers.get("X-Tenant-ID")
          if not tenant_id:
              query_string = http_request.url.query
              if query_string:
                  params = parse_qs(query_string)
                  tenant_id = params.get("tenant_id", [None])[0]
  
          if not tenant_id:
              raise HTTPException(
                  status_code=400,
                  detail="tenant_id is required. Provide it via header 'X-Tenant-ID' or query parameter 'tenant_id'",
              )
  
          index_name = get_tenant_index_name(tenant_id)
          if not es_client.client.indices.exists(index=index_name):
              raise HTTPException(
                  status_code=404,
                  detail=f"Tenant index not found: {index_name}",
              )

  
          # Get document count

          doc_count = es_client.client.count(index=index_name).get("count", 0)

  
          # Get index size (if available)
          try:

              stats = es_client.client.indices.stats(index=index_name)
              size_in_bytes = stats["indices"][index_name]["total"]["store"]["size_in_bytes"]

              size_mb = size_in_bytes / (1024 * 1024)

          except Exception:

              size_mb = None
  
          return {

              "tenant_id": str(tenant_id),
              "index_name": index_name,

              "document_count": doc_count,
              "size_mb": round(size_mb, 2) if size_mb else None
          }
  
      except Exception as e:
          raise HTTPException(status_code=500, detail=str(e))