Remove PDF existence requirement from API handlers

backend/api.py

@@ -87,14 +87,12 @@ async def put_pdf(pdf_id: str, file: UploadFile = File(...), pdf_name: str = For
 @app.post("/api/send-config")
 async def send_config(request: Request):
     """
-    Store config (always) and email pipeline (best-effort).
-
-    Required JSON payload:
-      - pdf_id: str
-      - template_id: str
-      - config: dict
+    Store config JSON for later pipelines.
+    Do NOT require PDF to exist.
+    Do NOT send email from this API container (no Gmail creds in HF).
     """
     payload = await request.json()
+
     pdf_id = (payload.get("pdf_id") or "").strip()
     template_id = (payload.get("template_id") or "").strip()
     config = payload.get("config")
@@ -106,84 +104,15 @@ async def send_config(request: Request):
     if not isinstance(config, dict):
         raise HTTPException(status_code=400, detail="Missing config object")
 
-    # PDF must exist in API uploads (worker uploads it first)
-        # Always store config, even if PDF is missing in this container
     CONFIGS_DIR.mkdir(parents=True, exist_ok=True)
     out_path = CONFIGS_DIR / f"{pdf_id}__{template_id}.json"
-    out_path.write_text(json.dumps({"pdf_id": pdf_id, "template_id": template_id, "config": config}, indent=2), encoding="utf-8")
-
-    pdf_path = UPLOADS_DIR / f"{pdf_id}.pdf"
-    pdf_exists = pdf_path.exists()
-    name_path = UPLOADS_DIR / f"{pdf_id}.name.txt"
-    pdf_name = name_path.read_text(encoding="utf-8").strip() if name_path.exists() else f"{pdf_id}.pdf"
-
-    # 1) STORE config on disk (source of truth)
-    CONFIGS_DIR.mkdir(parents=True, exist_ok=True)
-    out_path = CONFIGS_DIR / f"trainer_config_{pdf_id}_{template_id}.json"
     out_path.write_text(
         json.dumps({"pdf_id": pdf_id, "template_id": template_id, "config": config}, indent=2),
         encoding="utf-8",
     )
 
-    # 2) EMAIL pipeline best-effort (never 500 if email fails)
-    email_ok = False
-    email_err = ""
-    try:
-        pipeline_to = _get_env_required("PDF_PIPELINE_PIPELINE_NOTIFY_TO")
-        notify_from = _get_env_required("PDF_PIPELINE_NOTIFY_FROM")
-
-        # creds/token can be path OR raw json text; we only support path in HF container
-        creds = (os.environ.get("PDF_PIPELINE_GMAIL_CREDENTIALS_JSON") or "").strip()
-        token = (os.environ.get("PDF_PIPELINE_GMAIL_TOKEN_JSON") or "").strip()
-
-        if not creds or not token or not Path(creds).exists() or not Path(token).exists():
-            raise RuntimeError("Gmail OAuth files not present in container (expected file paths)")
-
-        subject = f"PDF_TRAINER_CONFIG_SUBMITTED | template_id={template_id}"
-        trainer_base_url = (os.environ.get("PDF_TRAINER_BASE_URL") or "").strip()
-        trainer_link = f"{trainer_base_url.rstrip('/')}/?pdf_id={pdf_id}" if trainer_base_url else f"(trainer url not set) pdf_id={pdf_id}"
-
-        body = (
-            "Hi,\n\n"
-            "A PDF Trainer configuration was submitted.\n\n"
-            f"template_id: {template_id}\n"
-            f"pdf_id: {pdf_id}\n"
-            f"trainer_link: {trainer_link}\n\n"
-            "Attachments:\n"
-            f"- {out_path.name}\n"
-            f"- {pdf_name}\n\n"
-            "Thank you,\n"
-            "Inserio Automation\n"
-        )
-
-        cfg_bytes = out_path.read_bytes()
-        attachments = [
-            (out_path.name, cfg_bytes),
-            (pdf_name, pdf_path.read_bytes()),
-        ]
-
-        gmail = _gmail()
-        gmail.send_email(
-            to_email=pipeline_to,
-            from_email=notify_from,
-            subject=subject,
-            body_text=body,
-            attachments=attachments,
-        )
-        email_ok = True
-
-    except Exception as e:
-        email_err = str(e)
-
-    return {
-        "ok": True,
-        "stored": str(out_path),
-        "pdf_present": True,
-        "email_ok": email_ok,
-        "email_error": email_err,
-    }
-
-
+    pdf_path = UPLOADS_DIR / f"{pdf_id}.pdf"
+    return {"ok": True, "stored": str(out_path), "pdf_exists": pdf_path.exists()}
 @app.post("/api/notify-unknown")
 async def notify_unknown(payload: Dict[str, Any]):
     """
@@ -211,11 +140,6 @@ async def notify_unknown(payload: Dict[str, Any]):
     rep_to = _get_env_required("PDF_PIPELINE_NOTIFY_TO")
     notify_from = _get_env_required("PDF_PIPELINE_NOTIFY_FROM")
     trainer_base_url = (os.environ.get("PDF_TRAINER_BASE_URL") or "http://localhost:5173").strip()
-
-    pdf_path = UPLOADS_DIR / f"{pdf_id}.pdf"
-    if not pdf_path.exists():
-        raise HTTPException(status_code=404, detail="PDF not found for pdf_id")
-
     name_path = UPLOADS_DIR / f"{pdf_id}.name.txt"
     pdf_name = name_path.read_text(encoding="utf-8").strip() if name_path.exists() else f"{pdf_id}.pdf"