SHOTS
No project loaded
ACTIVITY
No activity
Select a shot to inspect
No media selected
Select a shot from the file browser
Run the build phases first.
", status_code=404) return FileResponse(index, media_type="text/html") # Mount static files if _STATIC_DIR.is_dir(): app.mount("/static", StaticFiles(directory=str(_STATIC_DIR)), name="static") # ── Routes: Health ───────────────────────────────────────────── @app.get("/api/health") async def health(): project = ws_state.get_project() or _DEFAULT_PROJECT project_dir = PROJECTS_ROOT / project return JSONResponse({ "status": "ok", "project": project, "projects_root": str(PROJECTS_ROOT), "project_exists": project_dir.is_dir(), }) # ── Routes: State ────────────────────────────────────────────── @app.get("/api/state") async def get_state(): state = ws_state.read_state() return JSONResponse(state) @app.post("/api/state/selection") async def update_selection(request: Request): body = await request.json() shot_ids = body.get("shot_ids", []) ws_state.set_selection(shot_ids) # Auto-switch to Inspect tab when a shot is selected if len(shot_ids) == 1: ws_state.set_browse_tab(False) return JSONResponse({"selection": shot_ids}) @app.post("/api/state/viewer") async def update_viewer(request: Request): body = await request.json() ws_state.set_viewer_state( shot_id=body.get("shot_id"), take_index=body.get("take_index"), file_path=body.get("file_path"), media_type=body.get("media_type"), context=body.get("context"), ) return JSONResponse(ws_state.get_viewer_state()) # ── Routes: Shots ────────────────────────────────────────────── @app.get("/api/shots/{project}") async def get_shots(project: str): store = _get_store(project) all_shots = store.get_all_shots() store.close() # Group by episode episodes = {} for shot in all_shots: ep = shot.get("episode_id", "unknown") if ep not in episodes: episodes[ep] = [] takes = shot.get("takes", []) latest_take_path = None if takes: fp = takes[-1].get("file_path", "") if fp: latest_take_path = fp episodes[ep].append({ "shot_id": shot.get("shot_id"), "status": shot.get("status", "previs_pending"), "status_color": _shot_status_color(shot.get("status", "previs_pending")), "take_count": len(takes), "latest_take_path": latest_take_path, "model": shot.get("model"), "is_coverage": shot.get("is_coverage", False), "coverage_of": shot.get("coverage_of"), }) return JSONResponse({ "project": project, "episodes": episodes, "total_shots": len(all_shots), }) @app.get("/api/shot/{project}/{shot_id}") async def get_shot(project: str, shot_id: str): store = _get_store(project) shot = store.get_shot(shot_id) store.close() if shot is None: return JSONResponse({"error": f"Shot '{shot_id}' not found"}, status_code=404) # Resolve take paths takes = shot.get("takes", []) for take in takes: fp = take.get("file_path", "") if fp and not fp.startswith("/"): take["media_url"] = f"/media/{project}/{fp}" # FIX (Opus C3): Include attempts, max_attempts, coverage_of in response # so the inspector can display them correctly. return JSONResponse({ "shot_id": shot_id, "project": project, "episode_id": shot.get("episode_id", ""), "status": shot.get("status", "previs_pending"), "status_color": _shot_status_color(shot.get("status", "previs_pending")), "pipeline": shot.get("pipeline"), "model": shot.get("model"), "cost_incurred": shot.get("cost_incurred", 0), "attempts": shot.get("attempts", 0), "max_attempts": shot.get("max_attempts", 3), "gate_results": shot.get("gate_results", {}), "output_path": shot.get("output_path"), "error_message": shot.get("error_message"), "takes": takes, "take_count": len(takes), "is_coverage": shot.get("is_coverage", False), "coverage_of": shot.get("coverage_of"), "updated_at": shot.get("updated_at"), }) # ── Routes: Activity ─────────────────────────────────────────── @app.get("/api/activity/{project}") async def get_activity(project: str): from pipeline.lib.ops_log import scan_for_dangling_ops ops_log_path = _get_ops_log_path(project) in_flight = scan_for_dangling_ops(ops_log_path) recent = [] if ops_log_path.is_file(): lines = ops_log_path.read_text(encoding="utf-8").strip().split("\n") for line in reversed(lines[-40:]): try: record = json.loads(line) if record.get("status") in ("completed", "failed", "crashed"): recent.append(record) if len(recent) >= 10: break except (json.JSONDecodeError, TypeError): continue return JSONResponse({ "project": project, "in_flight": in_flight, "in_flight_count": len(in_flight), "recent": recent, }) # ── Routes: Media ────────────────────────────────────────────── @app.get("/media/{path:path}") async def serve_media(path: str): """Serve media files from the projects root. Path format: {project}/output/previs/ep_001/shot_001.png or just: {project}/{relative_path} """ full_path = PROJECTS_ROOT / path if not full_path.is_file(): return JSONResponse({"error": f"File not found: {path}"}, status_code=404) # Security: ensure path is within PROJECTS_ROOT try: full_path.resolve().relative_to(PROJECTS_ROOT.resolve()) except ValueError: return JSONResponse({"error": "Access denied"}, status_code=403) # Determine content type ext = full_path.suffix.lower() content_types = { ".png": "image/png", ".jpg": "image/jpeg", ".jpeg": "image/jpeg", ".webp": "image/webp", ".mp4": "video/mp4", ".mov": "video/quicktime", ".webm": "video/webm", } ct = content_types.get(ext, "application/octet-stream") return FileResponse(full_path, media_type=ct) # ── CLI Entry Point ──────────────────────────────────────────── def main(): global _DEFAULT_PROJECT parser = argparse.ArgumentParser(description="Recoil Workspace Server") parser.add_argument("--project", default="tartarus", help="Default project name") parser.add_argument("--port", type=int, default=8450, help="Server port") parser.add_argument("--host", default="127.0.0.1", help="Server host") args = parser.parse_args() _DEFAULT_PROJECT = args.project # Set the project in workspace state on startup ws_state.set_project(args.project) log.info("Starting Recoil Workspace on %s:%d (project: %s)", args.host, args.port, args.project) log.info("Projects root: %s", PROJECTS_ROOT) import uvicorn uvicorn.run(app, host=args.host, port=args.port, log_level="info") if __name__ == "__main__": main() ``` ## Validation ```bash cd /path/to/recoil # Syntax check python3 -c "import ast; ast.parse(open('workspace/server.py').read()); print('PASS: server.py syntax')" # Structural checks grep -q "FastAPI" workspace/server.py && echo "PASS: uses FastAPI" || echo "FAIL" grep -q "/api/health" workspace/server.py && echo "PASS: health endpoint" || echo "FAIL" grep -q "/api/state" workspace/server.py && echo "PASS: state endpoint" || echo "FAIL" grep -q "/api/shots/" workspace/server.py && echo "PASS: shots endpoint" || echo "FAIL" grep -q "/api/shot/" workspace/server.py && echo "PASS: shot detail endpoint" || echo "FAIL" grep -q "/api/activity/" workspace/server.py && echo "PASS: activity endpoint" || echo "FAIL" grep -q "/media/" workspace/server.py && echo "PASS: media endpoint" || echo "FAIL" grep -q "uvicorn" workspace/server.py && echo "PASS: uvicorn runner" || echo "FAIL" grep -q "8450" workspace/server.py && echo "PASS: default port 8450" || echo "FAIL" grep -q "attempts" workspace/server.py && echo "PASS: attempts field in shot detail" || echo "FAIL" grep -q "max_attempts" workspace/server.py && echo "PASS: max_attempts field in shot detail" || echo "FAIL" grep -q "coverage_of" workspace/server.py && echo "PASS: coverage_of field in shot detail" || echo "FAIL" # Import check (FastAPI must be installed) python3 -c " import sys; sys.path.insert(0, '.') import workspace.server as srv print(f'PASS: server imports, app={srv.app.title}') " 2>&1 | head -5 ``` ## Do NOT - Create the static/ directory or frontend files (Phase 5) - Add WebSocket endpoints (deferred to v2) - Add authentication - Import or use xterm.js --- # Phase 5: Frontend -- HTML Shell + CSS **Creates:** `workspace/static/index.html`, `workspace/static/workspace.css` **Modifies:** nothing **Depends on:** Phase 1 (design system), Phase 4 (server routes) ## What Already Exists - `workspace/server.py` — serves `/workspace` -> `static/index.html`, mounts `/static/` - `workspace/DESIGN_SYSTEM.md` — color palette, typography, component patterns ## File: workspace/static/index.html ```html