Check point 4

app.py

@@ -16,6 +16,7 @@ import asyncio
 import uvicorn
 from queue import Queue
 import logging
+from gradio_webrtc import WebRTC
 
 # Set up logging
 logging.basicConfig(level=logging.INFO)
@@ -419,7 +420,7 @@ class RealtimeSpeakerDiarization:
             # Setup recorder configuration
             recorder_config = {
                 'spinner': False,
-                'use_microphone': True,  # Changed to True for direct microphone input
+                'use_microphone': False,  # Change to False for Hugging Face Spaces
                 'model': FINAL_TRANSCRIPTION_MODEL,
                 'language': TRANSCRIPTION_LANGUAGE,
                 'silero_sensitivity': SILERO_SENSITIVITY,
@@ -650,7 +651,9 @@ def start_recording():
     """Start recording and transcription"""
     try:
         result = diarization_system.start_recording()
-        return f"🎙️ {result}"
+        # Connect WebRTC to server stream
+        audio_webrtc.stream_url = "/stream"  # This is your FastRTC endpoint
+        return result
     except Exception as e:
         return f"❌ Failed to start recording: {str(e)}"
 
@@ -700,6 +703,14 @@ def create_interface():
         
         with gr.Row():
             with gr.Column(scale=2):
+                # Add WebRTC component for audio streaming
+                audio_webrtc = WebRTC(
+                    label="Audio Input",
+                    sources=["microphone"],
+                    streaming=True,
+                    rtc_configuration={"iceServers": [{"urls": ["stun:stun.l.google.com:19302"]}]}
+                )
+                
                 # Conversation display
                 conversation_output = gr.HTML(
                     value="<div style='padding: 20px; background: #f8f9fa; border-radius: 10px; min-height: 300px;'><i>Click 'Initialize System' to start...</i></div>",
@@ -773,6 +784,8 @@ def create_interface():
         
         def on_start():
             result = start_recording()
+            # Connect WebRTC to server stream
+            audio_webrtc.stream_url = "/stream"  # This is your FastRTC endpoint
             return result, gr.update(interactive=False), gr.update(interactive=True)
         
         def on_stop():