Update services/sambanova_voice_service.py

services/sambanova_voice_service.py

@@ -11,15 +11,11 @@ from fastrtc import (
     Stream,
     get_stt_model,
 )
-from gradio.utils import get_space
-import asyncio
 
 class SambanovaVoiceService:
-    """Dịch vụ Voice AI với Sambanova API - Fixed Duplicate Block Error"""
+    """Dịch vụ Voice AI với Sambanova API - Fixed State elem_id error"""
     
     def __init__(self):
-        self.curr_dir = Path(__file__).parent
-        
         # Khởi tạo client Sambanova
         self.client = openai.OpenAI(
             api_key=os.environ.get("SAMBANOVA_API_KEY"),
@@ -29,25 +25,28 @@ class SambanovaVoiceService:
         # STT model
         self.model = get_stt_model()
         
-        # RTC configuration - DISABLE TURN để tránh lỗi
+        # RTC configuration - DISABLE TURN
         self.rtc_configuration = None
         
-        # Stream instance - tạo một lần duy nhất
-        self._stream = None
-        
         print("✅ Sambanova Voice Service initialized")
     
-    @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"""
+    def create_stream(self):
+        """Tạo FastRTC stream với components đơn giản"""
         response_handler = self._create_response_handler()
         
+        # Tạo components không dùng elem_id cho State
+        chatbot_input = gr.Chatbot(
+            type="messages", 
+            value=[],
+            label="💬 Voice Conversation",
+            height=300
+        )
+        
+        state_input = gr.State(value=[])
+        
+        chatbot_output = gr.Chatbot(type="messages", value=[])
+        state_output = gr.State(value=[])
+        
         return Stream(
             ReplyOnStopWords(
                 response_handler,
@@ -56,27 +55,11 @@ class SambanovaVoiceService:
             ),
             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,
+            additional_inputs=[chatbot_input, state_input],
+            additional_outputs=[chatbot_output, state_output],
+            additional_outputs_handler=lambda *args: (args[2], args[3]),
+            concurrency_limit=2,
+            time_limit=90,
             rtc_configuration=self.rtc_configuration,
         )
     
@@ -132,8 +115,4 @@ class SambanovaVoiceService:
                 conversation_state.append(error_msg)
                 yield AdditionalOutputs(gradio_chatbot, conversation_state)
         
-        return response
-    
-    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()
+        return response