Clean diagnostics: keep status/version/proxy only

node_probe.py

@@ -1,35 +1,22 @@
-"""Minimal Node capability probe — proves the runtime works inside the Space.
+"""Node backend bridge — runs the existing Next.js Respite backend inside
+the Space container (userspace Node, no root) and reverse-proxies to it.
 
 Mounted under /respite/v2/node/*:
   /status  → is the runtime bootstrapped, is the child alive
   /version → runs `node --version` as a child process
-  /server  → start a trivial Node HTTP server on localhost, then GET it
-  /proxy   → reverse-proxy any /respite/v2/node/proxy/<path> to the Node server
+  /proxy   → reverse-proxy <path> (+ query/body/headers) to the Node backend,
+             streaming both ways (SSE included)
 """
 
-import json
 import os
 import subprocess
-import threading
-import time
-import urllib.request
 
 import httpx
 from fastapi import Request
-from fastapi.responses import JSONResponse, Response
+from fastapi.responses import JSONResponse
 
 import node_runtime
 
-_TRIVIAL_SERVER_JS = """const http = require('http');
-const s = http.createServer((req, res) => {
-  res.writeHead(200, {'content-type': 'application/json'});
-  res.end(JSON.stringify({ok: true, url: req.url, ts: Date.now()}));
-});
-s.listen(3211, '127.0.0.1', () => console.log('trivial server on 3211'));
-"""
-_trivial_proc = None
-_trivial_lock = threading.Lock()
-
 
 def _node_path() -> str | None:
     try:
@@ -48,27 +35,6 @@ def register_routes(fa_app):
             "backend_dir": node_runtime.BACKEND_DIR,
         })
 
-    @fa_app.get("/respite/v2/node/envcheck")
-    def _envcheck():
-        keys = sorted(k for k in os.environ if "API" in k.upper() or "KEY" in k.upper() or "TOKEN" in k.upper())
-        return JSONResponse({"matching_keys": keys, "hf_token_present": bool(os.environ.get("HF_TOKEN"))})
-
-    @fa_app.get("/respite/v2/node/childenv")
-    def _childenv():
-        """What env does the Node child see? (names only)"""
-        node = _node_path()
-        if not node:
-            return JSONResponse({"error": "no node"}, status_code=500)
-        r = subprocess.run(
-            [node, "-e", "const o={};for(const k of Object.keys(process.env))if(/API|KEY|TOKEN/i.test(k))o[k]=(process.env[k]||'').length;console.log(JSON.stringify(o))"],
-            capture_output=True, text=True, timeout=30,
-        )
-        import json as _j
-        try:
-            return JSONResponse({"child_keys": _j.loads(r.stdout.strip())})
-        except Exception:
-            return JSONResponse({"stdout": r.stdout[:300], "stderr": r.stderr[:300]})
-
     @fa_app.get("/respite/v2/node/version")
     def _version():
         node = _node_path()
@@ -77,30 +43,6 @@ def register_routes(fa_app):
         r = subprocess.run([node, "--version"], capture_output=True, text=True, timeout=30)
         return JSONResponse({"stdout": r.stdout.strip(), "stderr": r.stderr.strip()[:400], "code": r.returncode})
 
-    @fa_app.get("/respite/v2/node/server")
-    def _server():
-        """Start a trivial Node HTTP server on 127.0.0.1:3211 and fetch it."""
-        global _trivial_proc
-        node = _node_path()
-        if not node:
-            return JSONResponse({"error": "node bootstrap failed"}, status_code=500)
-        with _trivial_lock:
-            if _trivial_proc is None or _trivial_proc.poll() is not None:
-                path = os.path.join(node_runtime.RUNTIME_DIR, "trivial.js")
-                os.makedirs(node_runtime.RUNTIME_DIR, exist_ok=True)
-                with open(path, "w") as f:
-                    f.write(_TRIVIAL_SERVER_JS)
-                _trivial_proc = subprocess.Popen(
-                    [node, path], stdout=subprocess.PIPE, stderr=subprocess.STDOUT, text=True
-                )
-                time.sleep(1.5)
-        try:
-            with urllib.request.urlopen("http://127.0.0.1:3211/ping", timeout=5) as resp:
-                body = json.loads(resp.read().decode())
-            return JSONResponse({"fetch_ok": True, "body": body})
-        except Exception as e:
-            return JSONResponse({"fetch_ok": False, "error": str(e)}, status_code=500)
-
     @fa_app.get("/respite/v2/node/proxy/{path:path}")
     @fa_app.post("/respite/v2/node/proxy/{path:path}")
     async def _proxy(request: Request, path: str):