Delete mcapi.py

mcapi.py

@@ -1,240 +0,0 @@
-"""mcapi.py — Paper/Purpur server jars + Java resolution (live APIs, future-proof)."""
-
-from __future__ import annotations
-
-import os
-import re
-import tarfile
-import tempfile
-
-import httpx
-
-UA = {"User-Agent": "MCPanel/2.0 (HuggingFace Space)"}
-PAPER_API = "https://fill.papermc.io/v3/projects/paper"
-PURPUR_API = "https://api.purpurmc.org/v2/purpur"
-TOOLS_DIR = os.environ.get("SERVER_DIR", "/data") + "/tools"
-
-
-# ---------------------------------------------------------------------------
-# Java resolution
-# ---------------------------------------------------------------------------
-
-def _major(java_bin: str) -> int | None:
-    try:
-        import subprocess
-        out = subprocess.check_output([java_bin, "-version"],
-                                      stderr=subprocess.STDOUT, timeout=15).decode(errors="replace")
-        m = re.search(r'version\s+"(\d+)(?:\.(\d+))?', out)
-        if m:
-            if int(m.group(1)) == 1:
-                return int(m.group(2) or 8)
-            return int(m.group(1))
-    except Exception:
-        pass
-    return None
-
-
-def _find_javas() -> dict:
-    javas = {}
-    for root in ("/usr/lib/jvm", "/usr/local/lib/jvm", "/opt/java"):
-        if not os.path.isdir(root):
-            continue
-        for name in sorted(os.listdir(root)):
-            jp = os.path.join(root, name, "bin", "java")
-            if os.path.exists(jp):
-                maj = _major(jp)
-                if maj:
-                    javas.setdefault(maj, jp)
-    return javas
-
-
-def installed_java() -> list:
-    return sorted(_find_javas().keys())
-
-
-def java_min_for_version(version: str) -> int:
-    v = str(version).strip()
-    m = re.match(r"^(\d+)(?:\.(\d+))?", v)
-    if not m:
-        return 21
-    major, minor = int(m.group(1)), int(m.group(2) or 0)
-    if major == 1:
-        if minor >= 20:
-            return 21
-        if minor >= 17:
-            return 17
-        return 8
-    return 25 if major >= 20 else 21
-
-
-def _adoptium_url(major: int) -> list:
-    base = ("https://api.adoptium.net/v3/binary/latest/{m}/ga/"
-            "linux/x64/jdk/hotspot/normal/eclipse?project=jdk")
-    return [base.format(m=major),
-            f"https://api.adoptium.net/v3/binary/latest/{major}/ga/linux/x64/jdk/hotspot/",
-            f"https://github.com/adoptium/temurin{major}-binaries/releases/latest/download/"]
-
-
-async def _download_tar(url: str, tmp_path: str) -> bool:
-    try:
-        async with httpx.AsyncClient(follow_redirects=True, timeout=httpx.Timeout(1200, connect=40)) as c:
-            async with c.stream("GET", url, headers=UA) as r:
-                r.raise_for_status()
-                with open(tmp_path, "wb") as f:
-                    async for chunk in r.aiter_bytes(256 * 1024):
-                        f.write(chunk)
-        return True
-    except Exception:
-        return False
-
-
-def _provisioned(major: int) -> str | None:
-    found = _find_javas()
-    if major in found:
-        return found[major]
-    root = os.path.join(TOOLS_DIR, f"jdk-{major}")
-    for dp, _, files in os.walk(root):
-        if "java" in files:
-            return os.path.join(dp, "java")
-    return None
-
-
-async def ensure_java(major: int) -> str:
-    have = _find_javas()
-    if major in have:
-        return have[major]
-    existing = _provisioned(major)
-    if existing:
-        return existing
-    dest_dir = os.path.join(TOOLS_DIR, f"jdk-{major}")
-    os.makedirs(dest_dir, exist_ok=True)
-    with tempfile.NamedTemporaryFile(suffix=".tar.gz", delete=False) as tmp:
-        tmp_path = tmp.name
-    ok = False
-    for url in _adoptium_url(major):
-        if await _download_tar(url, tmp_path):
-            ok = True
-            break
-    if ok:
-        try:
-            with tarfile.open(tmp_path, "r:gz") as t:
-                t.extractall(dest_dir, filter="data")
-        except Exception:
-            ok = False
-    os.remove(tmp_path)
-    found = _provisioned(major)
-    if found:
-        return found
-    # last resort: any java on PATH
-    return "java"
-
-
-async def resolve_java(jar_name: str, version: str = "") -> str:
-    min_j = java_min_for_version(version or jar_name)
-    try:
-        return await ensure_java(min_j)
-    except Exception:
-        return "java"
-
-
-# ---------------------------------------------------------------------------
-# Paper (new fill.papermc.io API v3)
-# ---------------------------------------------------------------------------
-
-def paper_catalog() -> list:
-    """List of {version, java} for all Paper versions."""
-    with httpx.Client(timeout=20, follow_redirects=True) as c:
-        r = c.get(f"{PAPER_API}/versions", headers=UA)
-        r.raise_for_status()
-        entries = r.json().get("versions", [])
-    out = []
-    for e in entries:
-        v = e.get("version", {})
-        vid = v.get("id", "")
-        # keep only stable releases (drop -rc / -pre / -beta / -snapshot)
-        if "-" in vid:
-            continue
-        jm = (v.get("java") or {}).get("version") or {}
-        out.append({"version": vid, "java": jm.get("minimum")})
-    return out
-
-
-def paper_latest_build(version: str) -> dict:
-    with httpx.Client(timeout=20, follow_redirects=True) as c:
-        r = c.get(f"{PAPER_API}/versions/{version}/builds", headers=UA)
-        r.raise_for_status()
-        builds = r.json()
-    stable = [b for b in builds if b.get("channel") == "STABLE"] or builds
-    b = stable[0]
-    dl = (b.get("downloads") or {}).get("server:default", {})
-    return {
-        "build": b.get("id"),
-        "name": dl.get("name") or f"paper-{version}-{b.get('id')}.jar",
-        "url": dl.get("url"),
-        "sha256": (dl.get("checksums") or {}).get("sha256"),
-        "size": dl.get("size"),
-    }
-
-
-# ---------------------------------------------------------------------------
-# Purpur (api.purpurmc.org — still active)
-# ---------------------------------------------------------------------------
-
-def purpur_versions() -> list:
-    with httpx.Client(timeout=20, follow_redirects=True) as c:
-        r = c.get(PURPUR_API, headers=UA)
-        r.raise_for_status()
-        return r.json().get("versions", [])
-
-
-def purpur_latest_build(version: str) -> dict:
-    with httpx.Client(timeout=20, follow_redirects=True) as c:
-        r = c.get(f"{PURPUR_API}/{version}", headers=UA)
-        r.raise_for_status()
-        latest = int(r.json().get("builds", {}).get("latest", "1"))
-    return {
-        "build": latest,
-        "name": f"purpur-{version}-{latest}.jar",
-        "url": f"{PURPUR_API}/{version}/{latest}/download",
-        "sha256": None,
-        "size": None,
-    }
-
-
-# ---------------------------------------------------------------------------
-# Combined catalog for the UI
-# ---------------------------------------------------------------------------
-
-def all_versions() -> dict:
-    paper = []
-    purpur = []
-    try:
-        paper = paper_catalog()
-    except Exception:
-        paper = []
-    try:
-        purpur = [{"version": v, "java": java_min_for_version(v)} for v in purpur_versions()]
-    except Exception:
-        purpur = []
-    # newest first, keeping the java requirement alongside
-    p_sorted = sorted(paper, key=lambda x: x["version"], reverse=True)
-    q_sorted = sorted(purpur, key=lambda x: x["version"], reverse=True)
-    return {"paper": p_sorted, "purpur": q_sorted}
-
-
-def filename_for(provider: str, version: str, build) -> str:
-    return f"{provider}-{version}.jar"
-
-
-# ---------------------------------------------------------------------------
-# Download
-# ---------------------------------------------------------------------------
-
-async def download_jar(url: str, dest: str) -> None:
-    """Stream a jar to disk without buffering it all in RAM."""
-    async with httpx.AsyncClient(follow_redirects=True, timeout=httpx.Timeout(900, connect=30)) as c:
-        async with c.stream("GET", url, headers=UA) as r:
-            r.raise_for_status()
-            with open(dest, "wb") as f:
-                async for chunk in r.aiter_bytes(256 * 1024):
-                    f.write(chunk)