cahnge

app/core/config.py

@@ -8,6 +8,7 @@ class Settings(BaseSettings):
  
     GROQ_API_KEY: str
     PINECONE_API_KEY: str
+    WEB_BASE_URL: str
     # CLOUDINARY_CLOUD_NAME: str
     # CLOUDINARY_API_KEY: str
     # CLOUDINARY_API_SECRET: str

app/main.py

@@ -5,9 +5,12 @@ from pathlib import Path
 from fastapi import FastAPI, UploadFile, File, Form, HTTPException
 from fastapi.middleware.cors import CORSMiddleware
 from langgraph.checkpoint.memory import MemorySaver
-
+from app.utils.ui_payload_constructor import UIPayload
+from app.core.config import settings
 from app.graph import graph
 
+WEB_URL=settings.WEB_BASE_URL
+
 app = FastAPI(title="Adaptive Onboarding Engine")
 
 app.add_middleware(
@@ -19,31 +22,6 @@ app.add_middleware(
 
 checkpointer = MemorySaver()
 
-# -----------------------------
-# Payload Builder
-# (inline from your export_ui_payload logic)
-# -----------------------------
-
-REQUIRED_KEYS = ["candidate_name", "skill_gap_analysis_data", "mermaid_code", "final_roadmap"]
-
-def build_ui_payload(state: dict) -> dict:
-    ui_data = {}
-    for key in REQUIRED_KEYS:
-        val = state.get(key)
-        if val is None:
-            continue
-        if hasattr(val, "model_dump"):
-            ui_data[key] = val.model_dump()
-        else:
-            ui_data[key] = val
-    return ui_data
-
-
-# -----------------------------
-# POST /analyze
-# Accepts: resume PDF (file upload) + job description (form field)
-# Returns: UI payload JSON
-# -----------------------------
 
 @app.post("/analyze")
 async def analyze(

app/utils/cloudinary.py

@@ -0,0 +1,31 @@
+import cloudinary
+from cloudinary import Search
+from app.core.config import settings
+
+# Configure
+cloudinary.config(
+    cloud_name=settings.CLOUDINARY_CLOUD_NAME,
+    api_key=settings.CLOUDINARY_API_KEY,
+    api_secret=settings.CLOUDINARY_API_SECRET,
+    secure=True
+)
+
+def get_resume_url(thread_id: str) -> str:
+    """
+    Searches Cloudinary for the resume PDF in the thread's folder
+    and returns the secure URL.
+    """
+    result = Search() \
+        .expression(f'folder:"threads/{thread_id}/*"') \
+        .sort_by('public_id', 'desc') \
+        .max_results(1) \
+        .execute()
+
+    resources = result.get("resources", [])
+
+    if not resources:
+        raise FileNotFoundError(f"No resume found for thread_id: {thread_id}")
+
+    pdf_url = resources[0]["secure_url"]
+    print(f"Found resume: {pdf_url}")
+    return pdf_url

app/utils/ui_payload_constructor.py

@@ -0,0 +1,32 @@
+from typing import Optional, Dict, Any
+
+class UIPayload:
+    def __init__(
+        self,
+        candidate_name: Optional[str],
+        skill_gap_analysis_data: Optional[Dict[str, Any]],
+        mermaid_code: Optional[str],
+        final_roadmap: Optional[Dict[str, Any]],
+    ):
+        self.candidate_name = candidate_name
+        self.skill_gap_analysis_data = skill_gap_analysis_data
+        self.mermaid_code = mermaid_code
+        self.final_roadmap = final_roadmap
+
+    @classmethod
+    def from_state(cls, state: dict) -> "UIPayload":
+        return cls(
+            candidate_name=state.get("candidate_name"),
+            skill_gap_analysis_data=(
+                state["skill_gap_analysis_data"].model_dump()
+                if state.get("skill_gap_analysis_data") else None
+            ),
+            mermaid_code=state.get("mermaid_code"),
+            final_roadmap=state.get("final_roadmap"),
+        )
+
+    def to_dict(self) -> dict:
+        return {
+            k: v for k, v in self.__dict__.items()
+            if v is not None       # exclude None values
+        }

requirements.txt

@@ -9,4 +9,5 @@ uvicorn
 pinecone-text
 sentence-transformers
 python-multipart
-pymupdf
+pymupdf
+cloudinary