debug: real /api/sftp-test with socket+paramiko timeouts

backend/api.py

@@ -2,6 +2,8 @@ from __future__ import annotations
 
 import json
 import os
+import socket
+import paramiko
 import concurrent.futures
 
 from pathlib import Path
@@ -225,14 +227,56 @@ def jobs_status(job_id: str, req: StatusReq, x_worker_token: Optional[str] = Hea
     job.message = req.message
     return {"ok": True, "job_id": job_id, "status": job.status}
 
-
 @app.get("/api/sftp-test")
 def api_sftp_test():
-    # returns quickly if SFTP reachable, otherwise errors/timeout
+    host = (os.getenv("SFTP_HOST") or "").strip()
+    port = int((os.getenv("SFTP_PORT") or "2222").strip())
+    user = (os.getenv("SFTP_USER") or "").strip()
+    pw   = (os.getenv("SFTP_PASS") or "").strip()
+    root = (os.getenv("SFTP_ROOT") or ".").strip() or "."
+    timeout = float((os.getenv("SFTP_TIMEOUT_SECONDS") or "8").strip())
+
+    if not host or not user or not pw:
+        raise HTTPException(status_code=500, detail="Missing SFTP secrets: SFTP_HOST/SFTP_USER/SFTP_PASS")
+
+    t0 = time.time()
+    # HARD socket timeout
+    sock = socket.create_connection((host, port), timeout=timeout)
+    t_sock = time.time()
+
+    tr = paramiko.Transport(sock)
+    tr.banner_timeout = timeout
+    tr.auth_timeout = timeout
+
+    tr.connect(username=user, password=pw)
+    t_auth = time.time()
+
+    sftp = paramiko.SFTPClient.from_transport(tr)
+
+    out = {
+        "ok": False,
+        "host": host,
+        "port": port,
+        "user": user,
+        "root": root,
+        "timeout": timeout,
+        "t_sock_ms": int((t_sock - t0) * 1000),
+        "t_auth_ms": int((t_auth - t_sock) * 1000),
+    }
+
     try:
-        # reuse download_bytes to avoid duplication (reads tiny path)
-        # list isn't implemented here, so just try to fetch a known-nonexistent file and ensure it errors fast
-        download_bytes("does_not_exist.txt")
-        return {"ok": True, "note": "unexpectedly read file"}
-    except Exception as e:
-        return {"ok": False, "error": str(e)[:200]}
+        sftp.chdir(root)
+        out["listdir_root"] = sftp.listdir(".")[:50]
+        try:
+            st = sftp.stat("pdfs/demo_test_003.pdf")
+            out["stat_demo_test_003"] = {"size": st.st_size}
+        except Exception as e:
+            out["stat_demo_test_003_error"] = str(e)
+        out["ok"] = True
+        return JSONResponse(out)
+    finally:
+        try:
+            sftp.close()
+        finally:
+            tr.close()
+