Update main.py

main.py

@@ -12,9 +12,15 @@ from src.services.cv_service import CVParsingService
 from src.services.interview_service import InterviewProcessor
 from src.services.analysis_service import AnalysisService
 
+from services.graph_service import GraphConversationManager 
+from fastapi.responses import JSONResponse
+from bson import ObjectId
+
 os.environ['HOME'] = '/tmp'
 os.makedirs('/tmp/feedbacks', exist_ok=True)
 
+graph_manager = GraphConversationManager()
+
 app = FastAPI(
     title="AIrh Interview Assistant",
     description="API pour l'analyse de CV et la simulation d'entretiens d'embauche avec analyse asynchrone.",
@@ -72,6 +78,23 @@ async def health_check():
     }
     return HealthCheck(services=services)
 
+class MongoJSONEncoder(json.JSONEncoder):
+    def default(self, o):
+        if isinstance(o, ObjectId):
+            return str(o)
+        return super().default(o)
+
+@app.post("/simulate-interview/")
+async def simulate_interview(request: Request):
+    try:
+        payload = await request.json()
+        result = graph_manager.invoke(payload)
+        return JSONResponse(content=result)
+
+    except Exception as e:
+        logger.error(f"Error in simulate-interview endpoint: {e}", exc_info=True)
+        return JSONResponse(content={"error": "An internal error occurred."}, status_code=500)
+
 @app.post("/parse-cv/", tags=["CV Parsing"])
 async def parse_cv(file: UploadFile = File(...)):
     if file.content_type != "application/pdf":
@@ -89,7 +112,7 @@ async def parse_cv(file: UploadFile = File(...)):
         os.remove(tmp_path)
     
     return result
-
+'''
 @app.post("/simulate-interview/", tags=["Interview"])
 async def simulate_interview(request: InterviewRequest, background_tasks: BackgroundTasks):
     processor = InterviewProcessor(
@@ -114,7 +137,7 @@ async def simulate_interview(request: InterviewRequest, background_tasks: Backgr
         )
     
     return {"response": response_content}
-
+'''
 @app.get("/get-feedback/{user_id}", response_model=Feedback, tags=["Analysis"])
 async def get_feedback(user_id: str):
     feedback_path = f"/tmp/feedbacks/{user_id}.json"