Check point 4

app.py

@@ -706,7 +706,6 @@ def create_interface():
                 # 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"]}]}
                 )
@@ -840,7 +839,14 @@ def create_interface():
         # Auto-refresh status every 2 seconds  
         status_timer = gr.Timer(2)
         status_timer.tick(refresh_status, outputs=[status_output])
-    
+
+        # After creating the WebRTC component:
+        audio_webrtc.stream(
+            fn=process_webrtc_audio,
+            inputs=[audio_webrtc],
+            outputs=[conversation_output]
+        )
+
     return interface
 
 
@@ -953,4 +959,10 @@ if __name__ == "__main__":
         api_thread.start()
         
         # Start Gradio in main thread
-        run_gradio()
+        run_gradio()
+
+def process_webrtc_audio(frames):
+    # Process frames and send them to your diarization system
+    for frame in frames:
+        diarization_system.process_audio_chunk(frame)
+    return get_conversation()