fix: resolve server blocking and frontend status caching issues

server.py

@@ -7,7 +7,6 @@ import os
 import shutil
 import uuid
 import json
-# FIXED IMPORT: Importing from root agent.py instead of continuity_agent
 from agent import analyze_only, generate_only
 
 app = FastAPI(title="Continuity", description="AI Video Bridging Service")
@@ -25,16 +24,15 @@ os.makedirs(OUTPUT_DIR, exist_ok=True)
 app.mount("/outputs", StaticFiles(directory=OUTPUT_DIR), name="outputs")
 
 @app.get("/")
-async def read_root():
-    # Serve the dashboard HTML
+def read_root():
     return FileResponse("stitch_continuity_dashboard/code.html")
 
 @app.post("/analyze")
-async def analyze_endpoint(
-    background_tasks: BackgroundTasks,
+def analyze_endpoint(
     video_a: UploadFile = File(...),
     video_c: UploadFile = File(...)
 ):
+    # Changed to 'def' to run in threadpool (prevent blocking)
     try:
         request_id = str(uuid.uuid4())
         ext_a = os.path.splitext(video_a.filename)[1] or ".mp4"
@@ -48,23 +46,7 @@ async def analyze_endpoint(
         with open(path_c, "wb") as buffer:
             shutil.copyfileobj(video_c.file, buffer)
         
-        # Call Agent synchronously for analysis (it's relatively fast usually, but could be async too if desired)
-        # For now keeping it sync as per user previous flows, but could be made async easily.
-        # However, user request specifically focused on "generate" being async. 
-        # But wait, analyze also calls Gemini which can be slow. 
-        # Refactoring to also include job_id for analyze might be good practice but not explicitly requested for "analyze" in prompt detail, 
-        # BUT the user request says: "Update analyze_videos node: Call utils.update_job_status...".
-        # So we should probably treat analyze as async too OR just pass the job_id.
-        # But the frontend flow for analyze currently awaits the response to get the prompt.
-        # If we make it async, we break the frontend flow unless we refactor that too.
-        # The prompt says: "Update code.html ... Update the generate button JavaScript." 
-        # It doesn't explicitly say to update the analyze button logic to be async.
-        # However, update_job_status IS called in analyze_videos.
-        # So, we can pass a job_id if we want status updates, but if we await it, the status updates are only useful if polled in parallel.
-        # For now, I will keep analyze synchronous but pass a dummy job_id if we want logging, or just let it block.
-        # Actually, let's keep it blocking as per original server code, but pass a job_id so at least logs are written.
-        
-        # Call Agent with local paths
+        # This is blocking, so 'def' is required
         result = analyze_only(os.path.abspath(path_a), os.path.abspath(path_c), job_id=request_id)
     
         if result.get("status") == "error":
@@ -80,12 +62,13 @@ async def analyze_endpoint(
         raise HTTPException(status_code=500, detail=str(e))
 
 @app.post("/generate")
-async def generate_endpoint(
+def generate_endpoint(
     background_tasks: BackgroundTasks,
     prompt: str = Body(...),
     video_a_path: str = Body(...),
     video_c_path: str = Body(...)
 ):
+    # Changed to 'def' for safety
     try:
         if not os.path.exists(video_a_path) or not os.path.exists(video_c_path):
              raise HTTPException(status_code=400, detail="Video files not found on server.")
@@ -107,7 +90,7 @@ async def generate_endpoint(
         raise HTTPException(status_code=500, detail=str(e))
 
 @app.get("/status/{job_id}")
-async def get_status(job_id: str):
+def get_status(job_id: str):
     file_path = os.path.join(OUTPUT_DIR, f"{job_id}.json")
     if not os.path.exists(file_path):
         raise HTTPException(status_code=404, detail="Job not found")

stitch_continuity_dashboard/code.html

@@ -389,7 +389,8 @@
           // 2. Poll for Status
           const pollInterval = setInterval(async () => {
             try {
-              const statusRes = await fetch(`/status/${jobId}`);
+              // ADDED TIMESTAMP TO PREVENT CACHING
+              const statusRes = await fetch(`/status/${jobId}?t=${Date.now()}`);
               if (!statusRes.ok) return;
 
               const statusData = await statusRes.json();
@@ -403,66 +404,18 @@
                 // Show Video
                 const bridgeCard = document.getElementById("bridge-card");
                 if (bridgeCard) {
-                  // If video_url is a relative path like "outputs/...", make sure it starts with /
-                  let videoUrl = statusData.video_url;
-                  // The backend returns full local path generally, but server logic for update_job_status
-                  // kept the local path. We need to serve it via the /outputs/ mount.
-                  // Wait, utils.save_video_bytes returns absolute path. 
-                  // server.py: app.mount("/outputs", StaticFiles(directory=OUTPUT_DIR), name="outputs")
-                  // config.py/utils.py save to temp folder? 
-                  // Agent returns local path. 
-                  // In server.py for generate_only, we don't have the final file move logic anymore locally in server.py?
-                  // Ah, right. Agent calls update_job_status with the video_url (local path).
-                  // The frontend needs a URL it can access.
-                  // We need to move the file to OUTPUT_DIR or make sure Agent saves to OUTPUT_DIR.
-                  // Agent uses download_to_temp / save_video_bytes which use tempfile.
-                  // So the file in 'video_url' is in /tmp/... 
-                  // This won't be accessible via /outputs/.
-                  // We need to fix this.
-
-                  // This requires a minor fix in server or agent. 
-                  // Since I can't edit server.py inside this JS block logic easily to change python logic...
-                  // I should probably have updated the Agent to save to OUTPUT_DIR or Server to handle the move?
-                  // BUT, the server.py I just wrote launches generate_only in background.
-                  // generate_only returns the result, but since it's in background, we ignore return.
-                  // The only communication channel is the status file.
-                  // The status file contains 'video_url' which is the temp path.
-                  // Frontend cannot access temp path.
-
-                  // Quick FIX:
-                  // The frontend can't move files.
-                  // The AGENT needs to know where to save, OR Utils.
-                  // OR, we update the logic in agent.py to try to move it? No that's messy.
-                  // Let's look at where static files are served. `/outputs`.
-                  // If the file is in /tmp, we can't serve it.
-
-                  // Maybe I should modify `utils.save_video_bytes` to accept a directory?
-                  // Or I can modify `server.py` to launch a wrapper that moves the file?
-
-                  // I will implement a wrapper in server.py in the NEXT step or modify server.py now if I catch it?
-                  // I already wrote server.py.
-                  // I will apply a fix to `agent.py` or `utils.py` to ensure it saves to `outputs/` OR 
-                  // modify `server.py` to wrap the task.
-                  // Wrapping in server.py is cleanest for separation.
-                  // "generate_only" is imported.
-
-                  // Wait, `utils.update_job_status` writes to `outputs/{job_id}.json`.
-                  // If I change `utils.py` to also move the video if provided?
-                  // That seems like a good side effect for a "helper" dealing with job status in this specific app context.
-                  // Or `agent.py` can move it.
-
-                  // Let's handle this in the JS for now assuming the URL *might* work if I fix it in backend in a sec.
-                  // I'll assume the backend will provide a valid relative URL like `/outputs/filename.mp4`.
-
-                  bridgeCard.innerHTML = `
+                  if (statusData.video_url) {
+                    bridgeCard.innerHTML = `
                         <video controls autoplay loop class="w-full h-full object-cover rounded-2xl border-2 border-primary shadow-neon">
-                        <source src="${videoUrl}" type="video/mp4">
+                        <source src="${statusData.video_url}" type="video/mp4">
                         Your browser does not support the video tag.
                         </video>
-                    `;
-
-                  document.getElementById("analysis-panel").classList.remove("hidden");
-                  document.getElementById("review-panel").classList.add("hidden");
+                       `;
+                    document.getElementById("analysis-panel").classList.remove("hidden");
+                    document.getElementById("review-panel").classList.add("hidden");
+                  } else {
+                    alert("Video generated but URL missing.");
+                  }
                   btn.innerHTML = originalContent;
                   btn.disabled = false;
                   btn.classList.remove("opacity-70", "cursor-not-allowed");