Upload 15 files

app/agy_server.py

@@ -496,6 +496,51 @@ async def delete_key(key_id: int, _: dict = Depends(require_superadmin)):
     return {"revoked": db.revoke_api_key(key_id)}
 
 
+@app.get("/admin/agy-health")
+async def agy_health(_: dict = Depends(require_superadmin)):
+    """Diagnose agy on this host: binary, creds file, and a live `agy -p` run + log."""
+    import subprocess
+    import tempfile
+    from . import agy_bridge as ab
+
+    info: dict = {"agy_bin": ab.AGY_BIN, "agy_bin_exists": Path(ab.AGY_BIN).is_file(),
+                  "AGY_CREDS_JSON_set": bool(ab._CREDS_JSON), "creds_filename": ab._CREDS_FILENAME}
+    home = key_home(None)
+    try:
+        ab.ensure_home(home)
+        cred = ab.agy_dir(home) / ab._CREDS_FILENAME
+        info["injected_creds_path"] = str(cred)
+        info["injected_creds_exists"] = cred.is_file()
+    except Exception as e:
+        info["ensure_home_err"] = str(e)[:200]
+    try:
+        v = subprocess.run([ab.AGY_BIN, "--version"], capture_output=True, text=True,
+                           timeout=20, env=ab._child_env(home))
+        info["version"] = ((v.stdout or v.stderr) or "").strip()[:120]
+    except Exception as e:
+        info["version_err"] = str(e)[:200]
+    d = Path(tempfile.mkdtemp())
+    log = d / "agy.log"
+    try:
+        p = subprocess.run([ab.AGY_BIN, "-p", "hi", "--log-file", str(log)], cwd=str(d),
+                           capture_output=True, text=True, timeout=60, env=ab._child_env(home))
+        info["run_exit"] = p.returncode
+        info["run_stdout"] = (p.stdout or "")[:300]
+        info["run_stderr"] = (p.stderr or "")[:400]
+        info["log_tail"] = (log.read_text(errors="replace")[-2000:] if log.is_file() else "no log file")
+    except Exception as e:
+        info["run_err"] = str(e)[:300]
+    # list what agy actually created under HOME (to find the real creds location)
+    try:
+        found = []
+        for pat in ("*.json", "credentials*", "oauth*"):
+            found += [str(x) for x in Path(home).rglob(pat)][:20]
+        info["home_json_files"] = found[:30]
+    except Exception:
+        pass
+    return info
+
+
 @app.get("/admin/system-prompt")
 async def get_sys_prompt(_: dict = Depends(require_superadmin)):
     custom = db.get_setting("system_prompt")