Update services/sambanova_voice_service.py

services/sambanova_voice_service.py

@@ -5,21 +5,17 @@ from pathlib import Path
 import gradio as gr
 import numpy as np
 import openai
-from fastapi import FastAPI
-from fastapi.responses import HTMLResponse, StreamingResponse
 from fastrtc import (
     AdditionalOutputs,
     ReplyOnStopWords,
     Stream,
     get_stt_model,
-    get_cloudflare_turn_credentials_async,  # Sử dụng Cloudflare free
 )
 from gradio.utils import get_space
-from pydantic import BaseModel
 import asyncio
 
 class SambanovaVoiceService:
-    """Dịch vụ Voice AI với Sambanova API - Fixed TURN issue"""
+    """Dịch vụ Voice AI với Sambanova API - Fixed Duplicate Block Error"""
     
     def __init__(self):
         self.curr_dir = Path(__file__).parent
@@ -33,22 +29,58 @@ class SambanovaVoiceService:
         # STT model
         self.model = get_stt_model()
         
-        # RTC configuration - Sử dụng Cloudflare free hoặc None
-        self.rtc_configuration = asyncio.run(self._get_turn_config())
+        # RTC configuration - DISABLE TURN để tránh lỗi
+        self.rtc_configuration = None
+        
+        # Stream instance - tạo một lần duy nhất
+        self._stream = None
         
         print("✅ Sambanova Voice Service initialized")
     
-    async def _get_turn_config(self):
-        """Lấy TURN configuration - sử dụng Cloudflare free"""
-        try:
-            config = await get_cloudflare_turn_credentials_async()
-            print("✅ Using Cloudflare TURN servers")
-            return config
-        except Exception as e:
-            print(f"⚠️ Cannot get TURN credentials, using None: {e}")
-            return None  # Sẽ hoạt động trên local network
+    @property
+    def stream(self):
+        """Lazy initialization của stream"""
+        if self._stream is None:
+            self._stream = self._create_stream()
+        return self._stream
+    
+    def _create_stream(self):
+        """Tạo FastRTC stream - internal method"""
+        response_handler = self._create_response_handler()
+        
+        return Stream(
+            ReplyOnStopWords(
+                response_handler,
+                stop_words=["computer", "hey", "hello", "xin chào", "llama"],
+                input_sample_rate=16000,
+            ),
+            mode="send",
+            modality="audio",
+            additional_inputs=[
+                gr.Chatbot(
+                    type="messages", 
+                    value=[],
+                    label="💬 Voice Conversation",
+                    height=400,
+                    elem_id="sambanova_chatbot"  # Thêm ID duy nhất
+                ), 
+                gr.State(value=[], elem_id="sambanova_state")
+            ],
+            additional_outputs=[
+                gr.Chatbot(
+                    type="messages", 
+                    value=[],
+                    elem_id="sambanova_chatbot_output"
+                ), 
+                gr.State(value=[], elem_id="sambanova_state_output")
+            ],
+            additional_outputs_handler=lambda chatbot, state, new_chatbot, new_state: (new_chatbot, new_state),
+            concurrency_limit=3,
+            time_limit=120,
+            rtc_configuration=self.rtc_configuration,
+        )
     
-    def create_response_handler(self):
+    def _create_response_handler(self):
         """Tạo response handler cho voice streaming"""
         
         def response(
@@ -68,15 +100,12 @@ class SambanovaVoiceService:
                     yield AdditionalOutputs(gradio_chatbot, conversation_state)
                     return
                 
-                # Thêm audio vào chatbot
-                sample_rate, array = audio
-                gradio_chatbot.append(
-                    {"role": "user", "content": f"🎤: {text}"}  # Simplified - chỉ hiển thị text
-                )
-                yield AdditionalOutputs(gradio_chatbot, conversation_state)
-
-                # Thêm text vào conversation state
+                # Thêm user message
+                user_msg = {"role": "user", "content": f"🎤: {text}"}
+                gradio_chatbot.append(user_msg)
                 conversation_state.append({"role": "user", "content": text})
+                
+                yield AdditionalOutputs(gradio_chatbot, conversation_state)
 
                 # Gọi Sambanova API
                 print("🤖 Calling Sambanova API...")
@@ -105,34 +134,6 @@ class SambanovaVoiceService:
         
         return response
     
-    def create_stream(self):
-        """Tạo FastRTC stream"""
-        response_handler = self.create_response_handler()
-        
-        return Stream(
-            ReplyOnStopWords(
-                response_handler,
-                stop_words=["computer", "hey", "hello", "xin chào", "llama"],
-                input_sample_rate=16000,
-            ),
-            mode="send",
-            modality="audio",
-            additional_inputs=[
-                gr.Chatbot(
-                    type="messages", 
-                    value=[],
-                    label="�� Voice Conversation",
-                    height=400
-                ), 
-                gr.State(value=[])
-            ],
-            additional_outputs=[
-                gr.Chatbot(type="messages", value=[]), 
-                gr.State(value=[])
-            ],
-
-            additional_outputs_handler=lambda chatbot, state, new_chatbot, new_state: (new_chatbot, new_state),
-            concurrency_limit=3,
-            time_limit=120,
-            rtc_configuration=self.rtc_configuration,
-        )
+    def get_ui_component(self):
+        """Lấy UI component của stream - đảm bảo chỉ gọi một lần"""
+        return self.stream.ui()