change in main.py to add a more detailed log output

main.py

@@ -101,7 +101,7 @@ You are an expert AI assistant for a premier real estate developer.
 """
 
 
-# --- FIXED: transcribe_audio accepts path + bytes ---
+# --- AUDIO & LLM HELPERS ---
 def transcribe_audio(audio_path: str, audio_bytes: bytes) -> str:
     for attempt in range(3):
         try:
@@ -129,7 +129,7 @@ def transcribe_audio(audio_path: str, audio_bytes: bytes) -> str:
             return text
 
         except Exception as e:
-            logging.error(f"Transcription error (attempt {attempt+1}): {e}")
+            logging.error(f"Transcription error (attempt {attempt+1}): {e}", exc_info=True) # Added exc_info
             if attempt == 2:
                 return ""
     return ""
@@ -145,13 +145,14 @@ def generate_elevenlabs_sync(text: str, voice: str) -> bytes:
                 output_format="mp3_44100_128"
             )
         except Exception as e:
-            logging.error(f"ElevenLabs error (attempt {attempt+1}): {e}")
+            logging.error(f"ElevenLabs error (attempt {attempt+1}): {e}", exc_info=True) # Added exc_info
             if attempt == 2:
                 return b''
     return b''
 
-
+# --- UPDATED formulate_search_plan with logging ---
 async def formulate_search_plan(user_query: str) -> dict:
+    logging.info(f"Formulating search plan for query: {user_query}") # Log incoming query
     for attempt in range(3):
         try:
             response = await run_in_threadpool(
@@ -161,13 +162,24 @@ async def formulate_search_plan(user_query: str) -> dict:
                 response_format={"type": "json_object"},
                 temperature=0.0
             )
-            return json.loads(response.choices[0].message.content)
+            # Log the raw response BEFORE trying to parse
+            raw_response_content = response.choices[0].message.content
+            logging.info(f"Raw Planner LLM response content: {raw_response_content}")
+
+            # Try parsing
+            plan = json.loads(raw_response_content)
+            logging.info(f"Successfully parsed search plan: {plan}")
+            return plan
         except Exception as e:
-            logging.error(f"Planner error (attempt {attempt+1}): {e}")
+            # Log the specific error during parsing or API call, with traceback
+            logging.error(f"Planner error (attempt {attempt+1}): {e}", exc_info=True)
             if attempt == 2:
+                logging.warning("Planner failed after 3 attempts. Using fallback.")
                 return {"search_query": user_query, "filter_table": None}
+    # Fallback if loop finishes unexpectedly
+    logging.error("Planner loop finished unexpectedly. Using fallback.")
     return {"search_query": user_query, "filter_table": None}
-
+# --- END UPDATED FUNCTION ---
 
 async def get_agent_response(user_text: str) -> str:
     for attempt in range(3):
@@ -197,7 +209,7 @@ async def get_agent_response(user_text: str) -> str:
             )
             return response.choices[0].message.content.strip()
         except Exception as e:
-            logging.error(f"RAG error (attempt {attempt+1}): {e}")
+            logging.error(f"RAG error (attempt {attempt+1}): {e}", exc_info=True) # Added exc_info
             if attempt == 2:
                 return "Sorry, I couldn't respond. Please try again."
     return "Sorry, I couldn't respond."
@@ -220,7 +232,7 @@ async def test_text_query_endpoint(query: TextQuery):
     return {"response": response}
 
 
-# --- FIXED: process_audio passes path + bytes ---
+# --- GRADIO AUDIO PROCESSING ---
 async def process_audio(audio_path):
     if not audio_path or not os.path.exists(audio_path):
         return None, "No valid audio file received."
@@ -262,7 +274,7 @@ async def process_audio(audio_path):
         return out_path, f"**You:** {user_text}\n\n**AI:** {agent_response}"
 
     except Exception as e:
-        logging.error(f"Audio processing error: {e}", exc_info=True)
+        logging.error(f"Audio processing error: {e}", exc_info=True) # Added exc_info
         return None, f"Error: {str(e)}"
 
 
@@ -277,13 +289,9 @@ with gr.Blocks(title="Real Estate AI") as demo:
     
     out_text = gr.Textbox(label="Conversation", lines=8)
 
-    # Only trigger on real file (not example text)
     inp.change(process_audio, inp, [out_audio, out_text])
 
-    # --- FIXED: Examples now use real audio files (optional) ---
-    # Remove text examples to avoid FileNotFoundError
-    # Or: Record real .wav files and upload to repo
-    # For now: disable examples
+    # Removed examples to avoid FileNotFoundError with text inputs
     # gr.Examples(examples=[], inputs=inp)