From 7e51da50c80e6c432234f2ea4faaf0b06613e634 Mon Sep 17 00:00:00 2001
From: ZGaetano <zgaetano@wilddragon.net>
Date: Tue, 14 Apr 2026 10:12:46 -0400
Subject: [PATCH] fix: inject hls_manager into routes module so preview
 endpoints work

---
 backend/app/main.py | 44 ++++++++++++++++----------------------------
 1 file changed, 16 insertions(+), 28 deletions(-)

diff --git a/backend/app/main.py b/backend/app/main.py
index b33ecdb..8af314f 100644
--- a/backend/app/main.py
+++ b/backend/app/main.py
@@ -14,13 +14,12 @@ from .recorders.recorder import RecorderManager
 from .recorders.scte35 import SCTE35Manager
 from .utils.hls import HLSPreviewManager
 from .api.routes import router
-from .api import routes as routes_module  # to set module-level globals
+from .api import routes as routes_module
 from .api.websocket import ConnectionManager
 
 logger = logging.getLogger(__name__)
 settings = Settings()
 
-# Global manager instances
 recorder_manager: RecorderManager | None = None
 scte35_manager: SCTE35Manager | None = None
 hls_manager: HLSPreviewManager | None = None
@@ -29,48 +28,43 @@ connection_manager = ConnectionManager()
 
 @asynccontextmanager
 async def lifespan(app: FastAPI):
-    """Initialize and cleanup application resources."""
     global recorder_manager, scte35_manager, hls_manager
-    
-    # Startup
+
     logger.info("Starting Deltacast SDI Recorder...")
-    
+
     recorder_manager = RecorderManager(settings)
     recorder_manager.initialize()
-    
+
     scte35_manager = SCTE35Manager()
-    
+
     hls_manager = HLSPreviewManager(settings)
-    
-    # Inject managers into routes module
+
+    # Inject all managers into routes module
     routes_module.recorder_manager = recorder_manager
     routes_module.scte35_manager = scte35_manager
-    
-    # Start background task for status broadcasting
+    routes_module.hls_manager = hls_manager
+
     status_task = asyncio.create_task(broadcast_port_status())
-    
-    logger.info("Deltacast SDI Recorder started successfully")
-    
-    yield  # Application runs here
-    
-    # Shutdown
+
+    logger.info(f"Deltacast SDI Recorder started — {settings.deltacast_port_count} ports")
+
+    yield
+
     logger.info("Shutting down Deltacast SDI Recorder...")
     status_task.cancel()
     try:
         await status_task
     except asyncio.CancelledError:
         pass
-    
-    # Stop all recorders and previews
+
     for port_index in range(settings.deltacast_port_count):
         await recorder_manager.stop_recording(port_index)
         await hls_manager.stop_preview(port_index)
-    
+
     logger.info("Shutdown complete")
 
 
 async def broadcast_port_status():
-    """Background task: broadcast port status to all WebSocket clients every 1 second."""
     while True:
         try:
             if recorder_manager is not None:
@@ -92,7 +86,6 @@ app = FastAPI(
     lifespan=lifespan
 )
 
-# CORS - allow all origins for local network use
 app.add_middleware(
     CORSMiddleware,
     allow_origins=["*"],
@@ -101,18 +94,14 @@ app.add_middleware(
     allow_headers=["*"],
 )
 
-# Include API router
 app.include_router(router)
 
 
 @app.websocket("/ws")
 async def websocket_endpoint(websocket: WebSocket):
-    """WebSocket endpoint for real-time port status updates."""
     await connection_manager.connect(websocket)
     try:
         while True:
-            # Keep connection alive, receive any messages
-            # (not used but required to detect disconnect)
             data = await websocket.receive_text()
     except WebSocketDisconnect:
         connection_manager.disconnect(websocket)
@@ -120,7 +109,6 @@ async def websocket_endpoint(websocket: WebSocket):
 
 @app.get("/hls/{filename}")
 async def serve_hls(filename: str):
-    """Serve HLS segment and playlist files."""
     hls_path = Path("/tmp/hls") / filename
     if not hls_path.exists():
         raise HTTPException(status_code=404, detail="HLS file not found")