SFTP: serve PDFs + store configs in /inserio

backend/api.py

@@ -9,6 +9,7 @@ from dotenv import load_dotenv
 from fastapi import FastAPI, HTTPException
 from fastapi.middleware.cors import CORSMiddleware
 from fastapi.responses import FileResponse
+from backend.sftp_store import SFTPStore
 
 
 # ------------------------------------------------------------------
@@ -102,9 +103,16 @@ def root() -> Dict[str, str]:
 
 @app.get("/api/pdf/{pdf_id}")
 def get_pdf(pdf_id: str):
-    pdf_path = UPLOADS_DIR / pdf_id
-    if not pdf_path.exists():
+    store = SFTPStore()
+    remote_rel = f"pdfs/{pdf_id}.pdf"
+    if not store.exists(remote_rel):
         raise HTTPException(status_code=404, detail="PDF not found")
+    data = store.get_bytes(remote_rel)
+
+    # Return bytes directly (no local disk dependency)
+    from fastapi.responses import Response
+    return Response(content=data, media_type="application/pdf")
+
 
     return FileResponse(
         path=pdf_path,
@@ -115,9 +123,19 @@ def get_pdf(pdf_id: str):
 
 @app.post("/api/send-config")
 def send_config(payload: Dict[str, Any]):
-    out_path = BACKEND_DIR / "trainer_config.json"
-    out_path.write_text(json.dumps(payload, indent=2))
-    return {"ok": True, "written_to": str(out_path)}
+    # Expect payload to include at least: pdf_id, template_id, config
+    pdf_id = str(payload.get("pdf_id", "")).strip()
+    template_id = str(payload.get("template_id", "")).strip()
+    config = payload.get("config")
+
+    if not pdf_id or not template_id or config is None:
+        raise HTTPException(status_code=400, detail="Missing pdf_id/template_id/config")
+
+    store = SFTPStore()
+    remote_json = f"configs/{pdf_id}_{template_id}.json"
+    store.put_bytes(remote_json, json.dumps(payload, indent=2).encode("utf-8"))
+
+    return {"ok": True, "stored": remote_json}
 
 
 @app.post("/api/notify-unknown")

backend/sftp_store.py

@@ -0,0 +1,113 @@
+import os
+import posixpath
+from dataclasses import dataclass
+from typing import Optional
+
+import paramiko
+
+
+@dataclass
+class SFTPConfig:
+    host: str
+    port: int
+    user: str
+    password: str
+    root: str
+
+
+def _cfg() -> SFTPConfig:
+    host = os.getenv("SFTP_HOST", "").strip()
+    port = int(os.getenv("SFTP_PORT", "2222"))
+    user = os.getenv("SFTP_USER", "").strip()
+    password = os.getenv("SFTP_PASS", "")
+    root = os.getenv("SFTP_ROOT", "/inserio").strip() or "/inserio"
+
+    if not host or not user or not password:
+        raise RuntimeError("Missing SFTP_HOST/SFTP_USER/SFTP_PASS")
+
+    # normalize root to POSIX
+    if not root.startswith("/"):
+        root = "/" + root
+    return SFTPConfig(host=host, port=port, user=user, password=password, root=root)
+
+
+class SFTPStore:
+    def __init__(self, cfg: Optional[SFTPConfig] = None):
+        self.cfg = cfg or _cfg()
+
+    def _connect(self):
+        t = paramiko.Transport((self.cfg.host, self.cfg.port))
+        t.connect(username=self.cfg.user, password=self.cfg.password)
+        sftp = paramiko.SFTPClient.from_transport(t)
+        return t, sftp
+
+    def _abs(self, rel: str) -> str:
+        rel = rel.lstrip("/")
+        return posixpath.join(self.cfg.root, rel)
+
+    def mkdir_p(self, remote_dir_rel: str) -> None:
+        t, sftp = self._connect()
+        try:
+            path = self._abs(remote_dir_rel).rstrip("/")
+            parts = path.split("/")
+            cur = ""
+            for part in parts:
+                if not part:
+                    continue
+                cur = cur + "/" + part
+                try:
+                    sftp.stat(cur)
+                except FileNotFoundError:
+                    sftp.mkdir(cur)
+        finally:
+            sftp.close()
+            t.close()
+
+    def put_bytes(self, remote_path_rel: str, data: bytes) -> None:
+        remote_abs = self._abs(remote_path_rel)
+        remote_dir = posixpath.dirname(remote_abs)
+
+        t, sftp = self._connect()
+        try:
+            # mkdir -p
+            parts = remote_dir.split("/")
+            cur = ""
+            for part in parts:
+                if not part:
+                    continue
+                cur = cur + "/" + part
+                try:
+                    sftp.stat(cur)
+                except FileNotFoundError:
+                    sftp.mkdir(cur)
+
+            tmp = remote_abs + ".tmp"
+            with sftp.file(tmp, "wb") as f:
+                f.write(data)
+                f.flush()
+            sftp.rename(tmp, remote_abs)
+        finally:
+            sftp.close()
+            t.close()
+
+    def get_bytes(self, remote_path_rel: str) -> bytes:
+        remote_abs = self._abs(remote_path_rel)
+        t, sftp = self._connect()
+        try:
+            with sftp.file(remote_abs, "rb") as f:
+                return f.read()
+        finally:
+            sftp.close()
+            t.close()
+
+    def exists(self, remote_path_rel: str) -> bool:
+        remote_abs = self._abs(remote_path_rel)
+        t, sftp = self._connect()
+        try:
+            sftp.stat(remote_abs)
+            return True
+        except FileNotFoundError:
+            return False
+        finally:
+            sftp.close()
+            t.close()

requirements.txt

@@ -4,3 +4,5 @@ python-dotenv
 google-auth
 google-auth-oauthlib
 google-api-python-client
+
+paramiko