Update main.py
Browse files
main.py
CHANGED
|
@@ -11,8 +11,7 @@ from src.models import load_all_models
|
|
| 11 |
from src.services.cv_service import CVParsingService
|
| 12 |
from src.services.interview_service import InterviewProcessor
|
| 13 |
from src.services.analysis_service import AnalysisService
|
| 14 |
-
|
| 15 |
-
from services.graph_service import GraphConversationManager
|
| 16 |
from fastapi.responses import JSONResponse
|
| 17 |
from bson import ObjectId
|
| 18 |
|
|
@@ -84,16 +83,18 @@ class MongoJSONEncoder(json.JSONEncoder):
|
|
| 84 |
return str(o)
|
| 85 |
return super().default(o)
|
| 86 |
|
| 87 |
-
|
|
|
|
| 88 |
async def simulate_interview(request: Request):
|
| 89 |
try:
|
| 90 |
payload = await request.json()
|
| 91 |
-
|
|
|
|
| 92 |
return JSONResponse(content=result)
|
| 93 |
|
| 94 |
except Exception as e:
|
| 95 |
logger.error(f"Error in simulate-interview endpoint: {e}", exc_info=True)
|
| 96 |
-
return JSONResponse(content={"error":
|
| 97 |
|
| 98 |
@app.post("/parse-cv/", tags=["CV Parsing"])
|
| 99 |
async def parse_cv(file: UploadFile = File(...)):
|
|
|
|
| 11 |
from src.services.cv_service import CVParsingService
|
| 12 |
from src.services.interview_service import InterviewProcessor
|
| 13 |
from src.services.analysis_service import AnalysisService
|
| 14 |
+
from services.graph_service import GraphInterviewProcessor
|
|
|
|
| 15 |
from fastapi.responses import JSONResponse
|
| 16 |
from bson import ObjectId
|
| 17 |
|
|
|
|
| 83 |
return str(o)
|
| 84 |
return super().default(o)
|
| 85 |
|
| 86 |
+
|
| 87 |
+
@app.post("/api/v1/simulate-interview/")
|
| 88 |
async def simulate_interview(request: Request):
|
| 89 |
try:
|
| 90 |
payload = await request.json()
|
| 91 |
+
processor = GraphInterviewProcessor(payload)
|
| 92 |
+
result = processor.invoke(payload.get("messages", []))
|
| 93 |
return JSONResponse(content=result)
|
| 94 |
|
| 95 |
except Exception as e:
|
| 96 |
logger.error(f"Error in simulate-interview endpoint: {e}", exc_info=True)
|
| 97 |
+
return JSONResponse(content={"error": str(e)}, status_code=500)
|
| 98 |
|
| 99 |
@app.post("/parse-cv/", tags=["CV Parsing"])
|
| 100 |
async def parse_cv(file: UploadFile = File(...)):
|