blackroad-operating-system/services/core-api/app/main.py

"""
BlackRoad OS Core API

Core business logic API with health checks and version info.
Serves as the source of truth for all core operations.
"""
from fastapi import FastAPI, Request
from fastapi.middleware.cors import CORSMiddleware
from fastapi.responses import JSONResponse
import os
import time
from datetime import datetime
import platform

# App metadata
VERSION = "1.0.0"
COMMIT = os.getenv("RAILWAY_GIT_COMMIT_SHA", "local")[:7]
ENVIRONMENT = os.getenv("ENVIRONMENT", "development")

# Create FastAPI app
app = FastAPI(
    title="BlackRoad OS Core API",
    description="Core business logic API for BlackRoad Operating System",
    version=VERSION,
    docs_url="/api/docs",
    redoc_url="/api/redoc",
    openapi_url="/api/openapi.json"
)

# CORS configuration
ALLOWED_ORIGINS = os.getenv("ALLOWED_ORIGINS", "*").split(",")
app.add_middleware(
    CORSMiddleware,
    allow_origins=ALLOWED_ORIGINS,
    allow_credentials=True,
    allow_methods=["*"],
    allow_headers=["*"],
)

# Startup time for uptime calculation
START_TIME = time.time()


@app.get("/")
async def root():
    """Root endpoint"""
    return {
        "service": "BlackRoad OS Core API",
        "version": VERSION,
        "status": "online",
        "docs": "/api/docs"
    }


@app.get("/health")
async def health_check():
    """
    Health check endpoint for Railway and monitoring systems.
    Returns 200 OK if service is healthy.
    """
    uptime_seconds = int(time.time() - START_TIME)

    return JSONResponse(
        status_code=200,
        content={
            "status": "healthy",
            "service": "core-api",
            "version": VERSION,
            "commit": COMMIT,
            "environment": ENVIRONMENT,
            "timestamp": datetime.utcnow().isoformat() + "Z",
            "uptime_seconds": uptime_seconds,
            "python_version": platform.python_version(),
            "system": {
                "platform": platform.system(),
                "release": platform.release(),
                "machine": platform.machine()
            }
        }
    )


@app.get("/version")
async def version_info():
    """
    Version information endpoint.
    Returns detailed version and build information.
    """
    return {
        "version": VERSION,
        "commit": COMMIT,
        "environment": ENVIRONMENT,
        "build_time": os.getenv("BUILD_TIME", "unknown"),
        "python_version": platform.python_version(),
        "deployment": {
            "platform": "Railway",
            "region": os.getenv("RAILWAY_REGION", "unknown"),
            "service_id": os.getenv("RAILWAY_SERVICE_ID", "unknown"),
            "deployment_id": os.getenv("RAILWAY_DEPLOYMENT_ID", "unknown")
        }
    }


@app.get("/api/core/status")
async def core_status():
    """
    Core service status with detailed health information.
    Used by Prism Console and monitoring dashboards.
    """
    uptime_seconds = int(time.time() - START_TIME)
    uptime_hours = uptime_seconds / 3600

    return {
        "service": "core-api",
        "status": "operational",
        "version": VERSION,
        "uptime": {
            "seconds": uptime_seconds,
            "hours": round(uptime_hours, 2),
            "human": f"{int(uptime_hours)}h {int((uptime_hours % 1) * 60)}m"
        },
        "environment": ENVIRONMENT,
        "timestamp": datetime.utcnow().isoformat() + "Z",
        "dependencies": {
            "database": "not_configured",  # TODO: Add DB health check
            "cache": "not_configured"      # TODO: Add Redis health check
        }
    }


# Error handlers
@app.exception_handler(404)
async def not_found_handler(request: Request, exc):
    """Custom 404 handler"""
    return JSONResponse(
        status_code=404,
        content={
            "error": "Not Found",
            "path": str(request.url.path),
            "message": "The requested resource was not found"
        }
    )


@app.exception_handler(500)
async def internal_error_handler(request: Request, exc):
    """Custom 500 handler"""
    return JSONResponse(
        status_code=500,
        content={
            "error": "Internal Server Error",
            "message": "An unexpected error occurred",
            "service": "core-api"
        }
    )


if __name__ == "__main__":
    import uvicorn
    port = int(os.getenv("PORT", 8000))
    uvicorn.run(
        "app.main:app",
        host="0.0.0.0",
        port=port,
        reload=ENVIRONMENT == "development"
    )