routers/logs.py

from fastapi import APIRouter
from fastapi.responses import JSONResponse, HTMLResponse
import docker

router = APIRouter()

docker_client = docker.from_env()

@router.get("/fetch/{container_name}")
def stream_logs(container_name: str):
    try:
        container = docker_client.containers.get(container_name)
        logs = container.logs(tail=100).decode()
        return HTMLResponse(f"<pre>{logs}</pre>")
    except Exception as e:
        return JSONResponse({"error": str(e)}, status_code=500)