Auto-bundle config+pdf to SFTP on send-config or pdf upload

backend/api.py

@@ -38,6 +38,41 @@ BACKEND_DIR = REPO_ROOT / "backend"
 UPLOADS_DIR = Path(os.environ.get("PDF_TRAINER_UPLOADS_DIR") or "/data/uploads")
 CONFIGS_DIR = UPLOADS_DIR / "configs"
 
+def _maybe_bundle_to_sftp(pdf_id: str, template_id: str) -> dict:
+    """
+    If both config + PDF exist locally in this API container AND SFTP env vars exist,
+    push JSON + PDF to SFTP. Otherwise no-op.
+    Returns small status dict.
+    """
+    try:
+        # only attempt if env looks configured
+        if not (os.environ.get("SFTP_HOST") and os.environ.get("SFTP_USER") and os.environ.get("SFTP_PASS")):
+            return {"sftp": "skipped_not_configured"}
+
+        cfg_path = CONFIGS_DIR / f"{pdf_id}__{template_id}.json"
+        pdf_path = UPLOADS_DIR / f"{pdf_id}.pdf"
+        name_path = UPLOADS_DIR / f"{pdf_id}.name.txt"
+
+        if not cfg_path.exists():
+            return {"sftp": "skipped_no_config"}
+        if not pdf_path.exists():
+            return {"sftp": "skipped_no_pdf"}
+
+        cfg_bytes = cfg_path.read_bytes()
+        pdf_bytes = pdf_path.read_bytes()
+        pdf_name = (name_path.read_text(encoding="utf-8").strip() if name_path.exists() else f"{pdf_id}.pdf") or f"{pdf_id}.pdf"
+
+        remote_dir = store_to_sftp(
+            pdf_id=pdf_id,
+            template_id=template_id,
+            cfg_json_bytes=cfg_bytes,
+            pdf_bytes=pdf_bytes,
+            pdf_name=pdf_name,
+        )
+        return {"sftp": "ok", "remote_dir": remote_dir}
+    except Exception as e:
+        return {"sftp": "error", "error": str(e)}
+
 
 # Load backend/.env explicitly ONCE for this process
 load_dotenv(BACKEND_DIR / ".env", override=True)
@@ -73,6 +108,15 @@ async def put_pdf(pdf_id: str, file: UploadFile = File(...), pdf_name: str = For
     (UPLOADS_DIR / f"{pdf_id}.pdf").write_bytes(data)
     if pdf_name:
         (UPLOADS_DIR / f"{pdf_id}.name.txt").write_text(pdf_name.strip(), encoding="utf-8")
+    # If any configs already exist for this pdf_id, bundle now.
+    sftp_results = []
+    try:
+        for cfg in CONFIGS_DIR.glob(f"{pdf_id}__*.json"):
+            tid = cfg.name.split("__", 1)[1].rsplit(".json", 1)[0]
+            sftp_results.append(_maybe_bundle_to_sftp(pdf_id, tid))
+    except Exception:
+        pass
+
     return {"ok": True}
 
 @app.post("/api/send-config")
@@ -130,8 +174,8 @@ async def send_config(request: Request):
     except Exception as e:
         print(f"[SFTP] store failed: {e}")
     pdf_path = UPLOADS_DIR / f"{pdf_id}.pdf"
-    return {"ok": True, "stored": str(out_path), "pdf_exists": pdf_path.exists()}
-
+    sftp_status = _maybe_bundle_to_sftp(pdf_id, template_id)
+    return {"ok": True, "stored": str(out_path), "pdf_exists": pdf_path.exists(), **sftp_status}
 @app.get("/api/config/{pdf_id}/{template_id}")
 def get_config(pdf_id: str, template_id: str):
     path = CONFIGS_DIR / f"{pdf_id}__{template_id}.json"