Allow admins to monitor active analyses

app.py

@@ -658,21 +658,22 @@ async def analyze(request: Request, playerId: str = Form(...), clientId: UUID =
         raise
 
 
-def owned_job(client_id, user_id):
+def owned_job(client_id, user_id, is_admin=False):
     job = jobs.get(client_id)
-    if not job or job["userId"] != user_id:
+    if not job or (job["userId"] != user_id and not is_admin):
         raise HTTPException(404, "Analysis not found")
     return job
 
 
 @app.get("/api/progress/{client_id}")
 def progress(client_id: str, request: Request):
-    return {key: value for key, value in owned_job(client_id, request.state.user_id).copy().items() if key not in {"userId", "cancel", "completion"}}
+    job = owned_job(client_id, request.state.user_id, request.state.is_admin)
+    return {key: value for key, value in job.copy().items() if key not in {"userId", "cancel", "completion"}}
 
 
 @app.post("/api/retry-save/{client_id}")
 def retry_save(client_id: str, request: Request):
-    job = owned_job(client_id, request.state.user_id)
+    job = owned_job(client_id, request.state.user_id, request.state.is_admin)
     if job.get("completion"):
         backend(f'/{job["sessionId"]}', job["userId"], "PUT", job["completion"])
         job.pop("completion", None)
@@ -682,12 +683,18 @@ def retry_save(client_id: str, request: Request):
 
 @app.get("/api/active-analyses")
 def active(request: Request):
-    return {"jobs": [progress(key, request) for key, job in list(jobs.items()) if job["userId"] == request.state.user_id and job["status"] in {"uploading", "queued", "running"}]}
+    is_admin = request.state.is_admin
+    return {"jobs": [
+        {key: value for key, value in job.copy().items() if key not in {"userId", "cancel", "completion"}}
+        for job in list(jobs.values())
+        if (is_admin or job["userId"] == request.state.user_id)
+        and job["status"] in {"uploading", "queued", "running"}
+    ]}
 
 
 @app.post("/api/cancel/{client_id}")
 def cancel(client_id: str, request: Request):
-    job = owned_job(client_id, request.state.user_id)
+    job = owned_job(client_id, request.state.user_id, request.state.is_admin)
     if job["status"] not in {"completed", "failed", "cancelled", "sync_failed"}:
         job["cancel"] = True
     return {"status": job["status"], "clientId": client_id}