removed errors

app/graph_trial.py

@@ -0,0 +1,56 @@
+import os
+from app.graph import graph
+import uuid
+
+
+jd_text="""Job Title: Backend Developer
+
+Company name: CodeForge
+We are hiring a Backend Developer to build scalable APIs and backend systems.
+
+Responsibilities:
+- Develop REST APIs using FastAPI
+- Design and manage PostgreSQL databases
+- Implement authentication and authorization systems
+- Optimize performance and scalability
+
+Requirements:
+- Strong knowledge of Python
+- Experience with FastAPI or Django
+- Good understanding of SQL and database design
+- Familiarity with Docker
+
+Constraints:
+- Location: Pune only
+- Full-time role """
+
+
+initial_input = {
+    "candidate_name": "Chirayu Jain",
+    "resume_text": None,
+    "job_description": jd_text,
+    "file_path": r"C:\Users\ATHARVA\Downloads\my codes\web\AdaptiveEngineService\AI_Engine_Evaluation\Testcases\Testresume\ChirayuResume.pdf",
+    "resume_data": None,
+    "extraction_error": None,
+    "JobDescriptionExtract_data": None,
+    "skill_gap_analysis_data": None
+    
+    
+}
+
+
+THREAD_ID = str(uuid.uuid4())
+
+config = {"configurable": {"thread_id": THREAD_ID}}
+
+# Change THREAD_ID to config
+# final_result = graph.invoke(initial_input, config=config)
+
+
+# print(final_result)
+
+
+
+
+ 
+ 

app/main.py

@@ -1,56 +1,73 @@
 import os
+from fastapi import FastAPI, Form, HTTPException
+from fastapi.middleware.cors import CORSMiddleware
+from app.utils.ui_payload_constructor import UIPayload
 from app.graph import graph
-import uuid
-
-
-jd_text="""Job Title: Backend Developer
-
-Company name: CodeForge
-We are hiring a Backend Developer to build scalable APIs and backend systems.
-
-Responsibilities:
-- Develop REST APIs using FastAPI
-- Design and manage PostgreSQL databases
-- Implement authentication and authorization systems
-- Optimize performance and scalability
-
-Requirements:
-- Strong knowledge of Python
-- Experience with FastAPI or Django
-- Good understanding of SQL and database design
-- Familiarity with Docker
-
-Constraints:
-- Location: Pune only
-- Full-time role """
-
-
-initial_input = {
-    "candidate_name": "Chirayu Jain",
-    "resume_text": None,
-    "job_description": jd_text,
-    "file_path": r"C:\Users\ATHARVA\Downloads\my codes\web\AdaptiveEngineService\AI_Engine_Evaluation\Testcases\Testresume\ChirayuResume.pdf",
-    "resume_data": None,
-    "extraction_error": None,
-    "JobDescriptionExtract_data": None,
-    "skill_gap_analysis_data": None
-    
-    
-}
-
-
-THREAD_ID = str(uuid.uuid4())
-
-config = {"configurable": {"thread_id": THREAD_ID}}
-
-# Change THREAD_ID to config
-final_result = graph.invoke(initial_input, config=config)
-
-
-final_result
-
-
-
-
+from app.utils.cloudinary_utils import get_resume_url
  
  
+app = FastAPI(title="Adaptive Onboarding Engine")
+ 
+app.add_middleware(
+    CORSMiddleware,
+    allow_origins=["*"],
+    allow_methods=["*"],
+    allow_headers=["*"],
+)
+ 
+ 
+@app.post("/analyze")
+async def analyze(
+    user_id: str = Form(..., description="User ID — used to fetch resume from Cloudinary"),
+    job_description: str = Form(..., description="Job description text"),
+):
+    # 1. Fetch PDF URL from Cloudinary using user_id
+    try:
+        pdf_url = get_resume_url(user_id)
+    except FileNotFoundError as e:
+        raise HTTPException(status_code=404, detail=str(e))
+ 
+    # 2. Build graph state
+    initial_input = {
+        "candidate_name": None,
+        "resume_text": None,
+        "file_path": pdf_url,
+        "job_description": job_description,
+        "resume_data": None,
+        "extraction_error": None,
+        "JobDescriptionExtract_data": None,
+        "skill_gap_analysis_data": None,
+        "messages": [],
+        "mermaid_code": None,
+        "final_roadmap": None,
+    }
+ 
+    # 3. Run graph — use user_id as thread_id for checkpointer
+    config = {"configurable": {"thread_id": user_id}}
+ 
+    try:
+        final_state = graph.invoke(initial_input, config=config)
+ 
+        if final_state.get("extraction_error"):
+            raise HTTPException(
+                status_code=422,
+                detail=f"Extraction failed: {final_state['extraction_error']}"
+            )
+ 
+        payload = UIPayload.from_state(final_state)
+        return payload.to_dict()
+ 
+    except HTTPException:
+        raise
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=str(e))
+ 
+ 
+@app.get("/health")
+def health():
+    return {"status": "ok", "service": "Adaptive Onboarding Engine"}
+ 
+ 
+if __name__ == "__main__":
+    import uvicorn
+    uvicorn.run(app, host="127.0.0.1", port=8000)