Update app.py

app.py

@@ -277,48 +277,11 @@ def generate_answer(message, choice, retrieval_mode):
     else:
         return "Invalid retrieval mode selected.", []
 
-# def bot(history, choice, tts_choice, retrieval_mode):
-#     if not history:
-#         return history
-    
-#     response, addresses = generate_answer(history[-1][0], choice, retrieval_mode)
-#     history[-1][1] = ""
-
-#     with concurrent.futures.ThreadPoolExecutor() as executor:
-#         if tts_choice == "Alpha":
-#             audio_future = executor.submit(generate_audio_elevenlabs, response)
-#         elif tts_choice == "Beta":
-#             audio_future = executor.submit(generate_audio_parler_tts, response)
-#         elif tts_choice == "Gamma":
-#             audio_future = executor.submit(generate_audio_mars5, response)
-
-#         for character in response:
-#             history[-1][1] += character
-#             time.sleep(0.05)
-#             yield history, None
-
-#         audio_path = audio_future.result()
-#         yield history, audio_path
-
-#     history.append([response, None])  # Ensure the response is added in the correct format
-
-
 def bot(history, choice, tts_choice, retrieval_mode):
     if not history:
         return history
     
-    user_message = history[-1][0]
-    response = ""
-    addresses = []
-
-    # Check if the question is about restaurants
-    if "restaurant" in user_message.lower():
-        # Use the agent to get the response
-        response = agent.run(user_message)
-    else:
-        # Otherwise, use the existing logic
-        response, addresses = generate_answer(user_message, choice, retrieval_mode)
-    
+    response, addresses = generate_answer(history[-1][0], choice, retrieval_mode)
     history[-1][1] = ""
 
     with concurrent.futures.ThreadPoolExecutor() as executor:
@@ -340,6 +303,7 @@ def bot(history, choice, tts_choice, retrieval_mode):
     history.append([response, None])  # Ensure the response is added in the correct format
 
 
+
 def add_message(history, message):
     history.append((message, None))
     return history, gr.Textbox(value="", interactive=True, placeholder="Enter message or upload file...", show_label=False)
@@ -692,32 +656,6 @@ def update_images():
 
 
 
-#Crew AI Integration
-
-from crewai import Agent
-from langchain.agents import Tool
-from langchain.utilities import GoogleSerperAPIWrapper
-
-# Setup API keys
-os.environ["SERP_API"] = "Your Key"
-
-search = GoogleSerperAPIWrapper()
-
-# Create and assign the search tool to an agent
-serper_tool = Tool(
-    name="Intermediate Answer",
-    func=search.run,
-    description="Useful for search-based queries",
-)
-
-agent = Agent(
-    role='Research Analyst',
-    goal='Provide up-to-date market analysis',
-    backstory='An expert analyst with a keen eye for market trends.',
-    tools=[serper_tool]
-)
-
-
 
 def fetch_local_events():
     api_key = os.environ['SERP_API']