Upload 4 files

README.md

@@ -133,7 +133,7 @@ See `CHANGELOG_V194.md` for the Model Pre-scan Decision Card UI pass.
 See `CHANGELOG_V195.md` for the Runtime CSS Cleanup with Legacy Safety Net pass.
 
 
-Current release: Agentic Space Factory v198.26.89.
+Current release: Agentic Space Factory v198.26.94.
 
 ## v198.26.87 — Runs Explorer Badge Rail Alignment
 

app.py

@@ -11,7 +11,7 @@ from fastapi import FastAPI, HTTPException, Request
 from fastapi.responses import HTMLResponse, JSONResponse, FileResponse, RedirectResponse
 from huggingface_hub import HfApi, attach_huggingface_oauth
 
-from src.bucket import RunPaths, check_user_bucket, create_user_bucket, delete_run_folder, read_run_bundle, list_recent_runs, read_json, write_json, write_launch_metadata
+from src.bucket import RunPaths, check_user_bucket, create_user_bucket, delete_run_folder, read_run_bundle, list_recent_runs, read_json, upsert_run_index_entry, write_json, write_launch_metadata
 from src.config import settings, user_bucket_source
 from src.eval_config import activate_eval_archive_config, disable_eval_archive_config, flush_eval_archive_records, public_eval_config
 from src.eval_archive import maybe_publish_eval_record
@@ -144,6 +144,53 @@ def _auth_recovery_payload(reason: str = "not_authenticated", detail: str | None
         },
     }
 
+
+def _api_me_payload(ctx: dict[str, Any]) -> dict[str, Any]:
+    return {
+        "authenticated": True,
+        "username": ctx["username"],
+        "profile": {
+            "name": ctx["profile"].get("name"),
+            "preferred_username": ctx["profile"].get("preferred_username"),
+            "picture": ctx["profile"].get("picture"),
+            "is_pro": ctx.get("is_pro"),
+            "can_pay": ctx.get("can_pay"),
+        },
+        "scopes": ctx.get("scopes", []),
+        "missing_scopes": ctx.get("missing_scopes", []),
+        "warnings": ctx.get("warnings", []),
+        "auth_lifetime": ctx.get("auth_lifetime"),
+        "anonymous_eval": public_eval_config(ctx["username"] if ctx else None),
+        "expires_at": ctx.get("expires_at"),
+        "login_url": "/oauth/huggingface/login",
+        "refresh_login_url": "/auth/refresh-login",
+        "reset_url": "/auth/logout-local",
+        "logout_url": "/auth/logout-local",
+    }
+
+
+def _resumable_payload_from_runs(
+    runs: list[dict[str, Any]],
+    *,
+    bucket_source: str,
+    token: str | None,
+) -> dict[str, Any]:
+    resumable = find_latest_resumable_run(runs)
+    selected = resumable or (runs[0] if runs else None)
+    if not selected:
+        return {"run": None, "view": None, "bucket_source": bucket_source, "reason": "no_run"}
+    run_id = validate_run_id(str(selected.get("run_id")))
+    snapshot = _build_live_run_snapshot(run_id, bucket_source=bucket_source, token=token, include_heavy=False)
+    return {
+        "run": selected,
+        "view": snapshot["view"],
+        "summary": snapshot["summary"],
+        "state": snapshot["state"],
+        "bucket_source": bucket_source,
+        "reason": "latest_resumable_run" if resumable else "latest_run",
+    }
+
+
 def _json_error(exc: Exception) -> HTTPException:
     if isinstance(exc, HTTPException):
         return exc
@@ -707,28 +754,38 @@ def register_custom_routes(fastapi_app: FastAPI) -> None:
             payload = _auth_recovery_payload(str(exc.detail), str(exc.detail))
             payload["anonymous_eval"] = public_eval_config(None)
             return JSONResponse(payload, status_code=401)
+        return JSONResponse(_api_me_payload(ctx))
+
+    @fastapi_app.get("/api/bootstrap")
+    async def api_bootstrap(request: Request, bucket_name: str = settings.bucket_name, limit: int = 100):  # type: ignore[no-untyped-def]
+        try:
+            ctx = _oauth_context_from_request(request)
+        except HTTPException as exc:
+            payload = _auth_recovery_payload(str(exc.detail), str(exc.detail))
+            payload["anonymous_eval"] = public_eval_config(None)
+            return JSONResponse(payload, status_code=401)
+        bucket_source = user_bucket_source(username=ctx["username"], bucket_name=bucket_name)
+        bucket_status = check_user_bucket(username=ctx["username"], bucket_name=bucket_name, token=ctx["token"])
+        runs: list[dict[str, Any]] = []
+        resumable = {"run": None, "view": None, "bucket_source": bucket_source, "reason": "bucket_not_ready"}
+        if bucket_status.get("ok"):
+            runs = list_recent_runs(bucket_source=bucket_source, token=ctx["token"], limit=limit)
+            resumable = _resumable_payload_from_runs(runs, bucket_source=bucket_source, token=ctx["token"])
         return JSONResponse(
             {
-                "authenticated": True,
-                "username": ctx["username"],
-                "profile": {
-                    "name": ctx["profile"].get("name"),
-                    "preferred_username": ctx["profile"].get("preferred_username"),
-                    "picture": ctx["profile"].get("picture"),
-                    "is_pro": ctx.get("is_pro"),
-                    "can_pay": ctx.get("can_pay"),
+                "schema_version": "asf_bootstrap.v1",
+                "me": _api_me_payload(ctx),
+                "bucket": bucket_status,
+                "runs": {
+                    "runs": runs,
+                    "bucket_source": bucket_source,
+                    "bucket_uri": f"hf://buckets/{bucket_source}",
+                    "limit": limit,
                 },
-                "scopes": ctx.get("scopes", []),
-                "missing_scopes": ctx.get("missing_scopes", []),
-                "warnings": ctx.get("warnings", []),
-                "auth_lifetime": ctx.get("auth_lifetime"),
-                "anonymous_eval": public_eval_config(ctx["username"] if ctx else None),
-                "expires_at": ctx.get("expires_at"),
-                "login_url": "/oauth/huggingface/login",
-                "refresh_login_url": "/auth/refresh-login",
-                "reset_url": "/auth/logout-local",
-                "logout_url": "/auth/logout-local",
-            }
+                "resumable": resumable,
+                "bucket_source": bucket_source,
+            },
+            headers={"Cache-Control": "no-store, no-cache, must-revalidate", "Pragma": "no-cache"},
         )
 
 
@@ -1173,6 +1230,7 @@ def register_custom_routes(fastapi_app: FastAPI) -> None:
             write_json(paths.state, cancelled_state, token=ctx["token"])
             write_json(f"{paths.root}/summary.json", cancelled_summary, token=ctx["token"])
             write_json(f"{paths.root}/cancel.json", cancel_meta, token=ctx["token"])
+            upsert_run_index_entry(run_id, bucket_source=bucket_source, summary=cancelled_summary, token=ctx["token"])
             append_run_event(
                 run_id,
                 bucket_source=bucket_source,
@@ -1944,6 +2002,28 @@ def _write_parent_linked_validation_state(parent_run_id: str, linked: list[dict[
         linked_payload["effective_status"] = "validated_after_manual_space_test"
     write_json(f"{paths.root}/linked_validations.json", linked_payload, token=token)
     write_json(f"{paths.root}/manual_validation_status.json", manual_status, token=token)
+    try:
+        index_summary = {
+            "run_id": parent_run_id,
+            "updated_at": linked_payload.get("updated_at"),
+            "linked_validation_count": len(compact),
+            "linked_validations_count": len(compact),
+        }
+        if manual_status.get("status") == "success":
+            index_summary.update({
+                "manual_validation_passed": True,
+                "post_build_status": linked_payload.get("effective_status") or "validated_after_manual_space_test",
+                "effective_status": linked_payload.get("effective_status") or "validated_after_manual_space_test",
+                "latency_seconds": manual_status.get("latency_seconds"),
+                "observed_latency_seconds": manual_status.get("observed_latency_seconds"),
+                "recommended_zero_gpu_duration_seconds": manual_status.get("recommended_zero_gpu_duration_seconds"),
+                "recommendation_source": manual_status.get("recommendation_source") or "linked_space_test",
+                "recommendation_hardware": manual_status.get("recommendation_hardware"),
+                "hardware_used_for_validation": manual_status.get("hardware_used_for_validation"),
+            })
+        upsert_run_index_entry(parent_run_id, bucket_source=bucket_source, summary=index_summary, token=token)
+    except Exception:
+        pass
     return {"linked_validations": linked_payload, "manual_validation_status": manual_status}
 
 def create_app() -> FastAPI:
@@ -1970,4 +2050,3 @@ def create_app() -> FastAPI:
 
 
 app = create_app()
-