Update app.py

app.py

@@ -346,41 +346,6 @@ def generate_answer(message, choice, retrieval_mode):
 
 
 
-# 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] = ""
-
-#     # Detect if the response is from Yelp (i.e., HTML formatted response)
-#     if "<table>" in response:
-#         for chunk in response.splitlines():
-#             history[-1][1] += chunk + "\n"
-#             time.sleep(0.1)  # Adjust the delay as needed
-#             yield history, None
-#         return
-
-#     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
@@ -414,10 +379,8 @@ def bot(history, choice, tts_choice, retrieval_mode):
 
     history.append([response, None])  # Ensure the response is added in the correct format
 
-    # Update the map if there are addresses found in the response
-    if addresses:
-        map_html = update_map_with_response(history)
-        yield history, map_html
+
+
 
 
 
@@ -564,26 +527,6 @@ base_audio_drive = "/data/audio"
 
 #Normal Code with sample rate is 44100 Hz
 
-# def transcribe_function(stream, new_chunk):
-#     try:
-#         sr, y = new_chunk[0], new_chunk[1]
-#     except TypeError:
-#         print(f"Error chunk structure: {type(new_chunk)}, content: {new_chunk}")
-#         return stream, "", None
-
-#     y = y.astype(np.float32) / np.max(np.abs(y))
-
-#     if stream is not None:
-#         stream = np.concatenate([stream, y])
-#     else:
-#         stream = y
-
-#     result = pipe_asr({"array": stream, "sampling_rate": sr}, return_timestamps=False)
-
-#     full_text = result.get("text","")
-    
-#     return stream, full_text, result
-
 def transcribe_function(stream, new_chunk):
     try:
         sr, y = new_chunk[0], new_chunk[1]
@@ -591,29 +534,16 @@ def transcribe_function(stream, new_chunk):
         print(f"Error chunk structure: {type(new_chunk)}, content: {new_chunk}")
         return stream, "", None
 
-    # Check if the array is empty
-    if y.size == 0:
-        print("Received an empty audio chunk, skipping processing.")
-        return stream, "", None
-
-    y = y.astype(np.float32)
-
-    # Check if y is all zeros or contains no valid data
-    if np.max(np.abs(y)) == 0:
-        print("Audio chunk contains only zeros, skipping normalization.")
-        normalized_y = y
-    else:
-        normalized_y = y / np.max(np.abs(y))
+    y = y.astype(np.float32) / np.max(np.abs(y))
 
     if stream is not None:
-        stream = np.concatenate([stream, normalized_y])
+        stream = np.concatenate([stream, y])
     else:
-        stream = normalized_y
+        stream = y
 
-    # Placeholder for ASR pipeline; replace with actual pipeline
     result = pipe_asr({"array": stream, "sampling_rate": sr}, return_timestamps=False)
 
-    full_text = result.get("text", "")
+    full_text = result.get("text","")
     
     return stream, full_text, result
 
@@ -621,6 +551,8 @@ def transcribe_function(stream, new_chunk):
 
 
 
+
+
 def update_map_with_response(history):
     if not history:
         return ""