tt

app.py

@@ -113,10 +113,18 @@ async def start_session(user_id: str):
 @app.post("/send_message", response_model=MessageResponse)
 async def send_message(request: MessageRequest):
     try:
+        # Check if user has an active session
+        if request.user_id not in chatbot.conversations or not chatbot.conversations[request.user_id].is_active:
+            # Start a new session if none exists
+            session_id, _ = chatbot.start_session(request.user_id)
+            logger.info(f"Started new session {session_id} for user {request.user_id} during message send")
+        
+        # Process the message
         response = chatbot.process_message(request.user_id, request.message)
         session = chatbot.conversations[request.user_id]
         return MessageResponse(response=response, session_id=session.session_id)
     except Exception as e:
+        logger.error(f"Error processing message for user {request.user_id}: {str(e)}")
         raise HTTPException(status_code=500, detail=str(e))
 
 @app.post("/end_session", response_model=SessionSummary)