Update main.py

main.py

@@ -976,9 +976,8 @@ import logging
 
 class ConversationalAIHandler:
     def __init__(self):
-        # CORRECTED: The base_url should be the root of the v1 API.
-        # Specific paths like '/agents' or '/conversations' will be appended later.
-        self.base_url = "https://api.elevenlabs.io/v1"
+        # The base URL for the specific Conversational AI API
+        self.base_url = "https://api.elevenlabs.io/v1/conversational-ai"
         self.api_key = os.getenv("ELEVENLABS_API_KEY")
         self.headers = {
             "xi-api-key": self.api_key,
@@ -987,7 +986,6 @@ class ConversationalAIHandler:
 
     def get_british_male_voice_id(self):
         """Get British male voice ID"""
-        # This method's logic is sound and remains unchanged.
         try:
             logger.info(f"[VOICE] Using known voice ID for Daniel: {KNOWN_VOICE_IDS['Daniel']}")
             return KNOWN_VOICE_IDS["Daniel"]
@@ -1000,55 +998,59 @@ class ConversationalAIHandler:
         try:
             logger.info(f"[AGENT] Starting agent creation/retrieval for project: {project_id}")
 
-            # Step 1: Check for and verify an existing agent.
+            # Verification of conversational agents requires listing all agents, which is inefficient.
+            # We will rely on the database ID and create a new one if it fails to be used later.
             existing_agent_id = db_ref.child(f'projects/{project_id}/agent_id').get()
             if existing_agent_id:
-                logger.info(f"[AGENT] Found existing agent ID: {existing_agent_id}. Verifying...")
-                # CORRECTED: Use the correct verification endpoint.
-                verify_url = f"{self.base_url}/agents/{existing_agent_id}"
-                try:
-                    response = requests.get(verify_url, headers=self.headers, timeout=15)
-                    if response.status_code == 200:
-                        logger.info(f"[AGENT] Existing agent {existing_agent_id} verified and active.")
-                        return existing_agent_id
-                    else:
-                        logger.warning(f"[AGENT] Verification failed for agent {existing_agent_id} (Status: {response.status_code}). Creating a new one.")
-                except Exception as e:
-                    logger.warning(f"[AGENT] Error verifying existing agent: {str(e)}. Creating a new one.")
-
-            # Step 2: If no valid agent exists, create a new one.
-            logger.info(f"[AGENT] Creating new agent.")
+                logger.info(f"[AGENT] Found existing agent ID in DB: {existing_agent_id}. Assuming it is active.")
+                return existing_agent_id
+
+            logger.info(f"[AGENT] No existing agent ID found in DB. Creating a new agent.")
             voice_id = self.get_british_male_voice_id()
 
             diy_expert_prompt = f"""
             You are an experienced DIY expert with years of hands-on experience in Home Appliance Repair, Automotive Maintenance, Gardening & Urban Farming,
-            Upcycling & Sustainable Crafts, or DIY Project Creation. You speak in a friendly, knowledgeable British manner and provide
+            Upcycling & Sustainable Crafts, or DIY Project Creation. You speak in a friendly, knowledgeable British manner and provide 
             practical, actionable advice. You're working on this specific project:
             Project: {project_data.get('projectTitle', 'DIY Project')}
             Description: {project_data.get('projectDescription', '')}
             Initial Plan: {project_data.get('initialPlan', '')}
-            Provide helpful, step-by-step guidance while being encouraging and safety-conscious.
+            Provide helpful, step-by-step guidance while being encouraging and safety-conscious. 
             Ask clarifying questions when needed and share relevant tips from your experience.
             """
 
-            # CORRECTED: The payload for agent creation is a flatter structure.
-            # The complex 'conversation_config' is not used for the standard /agents endpoint.
-            agent_payload = {
-                "name": f"DIY Expert - {project_data.get('projectTitle', project_id)}",
-                "prompt": diy_expert_prompt,
-                "voice_id": voice_id,
-                "initial_message": "Hello! I'm your Sozo DIY expert assistant. I'm here to help you with your project. What would you like to work on today?",
-                "webhook_url": f"{os.getenv('BASE_URL', 'https://rairo-neofix-api.hf.space')}/api/webhook/agent/{project_id}",
-                "model": "eleven_turbo_v2" # A default model is recommended
+            # This is the correct, detailed payload required by the conversational-ai endpoint.
+            agent_data = {
+                "name": f"DIY Expert - {project_data.get('projectTitle', project_data.get('title', 'Project'))}",
+                "conversation_config": {
+                    "agent": {
+                        "prompt": {"prompt": diy_expert_prompt},
+                        "first_message": "Hello! I'm your Sozo DIY expert assistant. I'm here to help you with your project. What would you like to work on today?",
+                        "language": "en"
+                    },
+                    "asr": {
+                        "provider": "deepgram",
+                        "user_input_audio_format": "pcm_16000"
+                    },
+                    "tts": {"voice_id": voice_id},
+                    "llm": {
+                        "provider": "openai",
+                        "model": "gpt-4"
+                    }
+                },
+                "platform_settings": {
+                    "webhook_url": f"{os.getenv('BASE_URL', 'https://rairo-neofix-api.hf.space')}/api/webhook/agent/{project_id}"
+                }
             }
 
-            # CORRECTED: Use the single, correct endpoint for agent creation.
+            # This is the correct endpoint that was causing the 404 Not Found error.
             creation_url = f"{self.base_url}/agents"
-            logger.info(f"[AGENT] Posting to agent creation endpoint: {creation_url}")
+            logger.info(f"[AGENT] Posting to the correct endpoint: {creation_url}")
 
-            response = requests.post(creation_url, headers=self.headers, json=agent_payload, timeout=30)
+            response = requests.post(creation_url, headers=self.headers, json=agent_data, timeout=30)
 
-            if response.status_code == 200: # A successful creation returns status 200
+            # A successful creation with this endpoint returns 201 Created.
+            if response.status_code == 201:
                 agent_info = response.json()
                 agent_id = agent_info.get("agent_id")
                 logger.info(f"[AGENT] New agent created successfully: {agent_id}")
@@ -1060,7 +1062,6 @@ class ConversationalAIHandler:
                 logger.info(f"[AGENT] Agent ID stored in database.")
                 return agent_id
             else:
-                # This will now give a much more informative error if the payload is wrong.
                 logger.error(f"[AGENT] Failed to create agent. Status: {response.status_code}, Response: {response.text}")
                 raise Exception(f"Failed to create agent: HTTP {response.status_code} - {response.text}")
 
@@ -1070,12 +1071,13 @@ class ConversationalAIHandler:
 
     def start_conversation(self, agent_id):
         """Start a conversation with the agent"""
-        logger.info(f"[CONVERSATION] Starting conversation with agent: {agent_id}")
-        # CORRECTED: Use the single, correct endpoint for starting a conversation with an agent.
-        conversation_url = f"{self.base_url}/agents/{agent_id}/conversations"
         try:
+            logger.info(f"[CONVERSATION] Starting conversation with agent: {agent_id}")
+            conversation_url = f"{self.base_url}/agents/{agent_id}/conversations"
+
             response = requests.post(conversation_url, headers=self.headers, json={}, timeout=30)
-            if response.status_code == 200: # Successful start returns 200
+
+            if response.status_code == 201:
                 conversation_info = response.json()
                 conversation_id = conversation_info.get("conversation_id")
                 logger.info(f"[CONVERSATION] Conversation started successfully: {conversation_id}")
@@ -1083,31 +1085,31 @@ class ConversationalAIHandler:
             else:
                 logger.error(f"[CONVERSATION] Failed to start conversation. Status: {response.status_code}, Response: {response.text}")
                 raise Exception(f"Failed to start conversation: {response.text}")
+
         except Exception as e:
             logger.error(f"[CONVERSATION] An exception occurred in start_conversation: {e}")
             raise
 
     def send_message(self, agent_id, conversation_id, message):
         """Send a message to the conversation"""
-        # The 'agent_id' is not required for this endpoint, but we'll keep the signature for compatibility with your calling code.
-        logger.info(f"[MESSAGE] Sending message to conversation: {conversation_id}")
-        # CORRECTED: Use the single, correct endpoint for sending a message.
-        message_url = f"{self.base_url}/conversations/{conversation_id}/messages"
-        
-        # CORRECTED: The payload for sending a message is simpler.
-        message_payload = {
-            "text": message
-        }
-
         try:
-            response = requests.post(message_url, headers=self.headers, json=message_payload, timeout=30)
+            logger.info(f"[MESSAGE] Sending message to conversation: {conversation_id}")
+            message_url = f"{self.base_url}/agents/{agent_id}/conversations/{conversation_id}/messages"
+            
+            payload = {
+                "message": message,
+                "message_type": "text"
+            }
+
+            response = requests.post(message_url, headers=self.headers, json=payload, timeout=30)
+
             if response.status_code == 200:
                 logger.info(f"[MESSAGE] Message sent successfully to {conversation_id}.")
-                # The response is streaming audio, but we can return the successful JSON confirmation.
                 return response.json()
             else:
                 logger.error(f"[MESSAGE] Failed to send message. Status: {response.status_code}, Response: {response.text}")
                 raise Exception(f"Failed to send message: {response.text}")
+
         except Exception as e:
             logger.error(f"[MESSAGE] An exception occurred in send_message: {e}")
             raise