Fix import error: replace hybrid_rag_service with available services

groq_websocket_handler.py

@@ -16,7 +16,8 @@ import uuid
 
 from fastapi import WebSocket, WebSocketDisconnect
 from groq_voice_service import groq_voice_service
-from rag_service import hybrid_rag_service
+from rag_service import search_documents_async
+from hybrid_llm_service import HybridLLMService
 
 logger = logging.getLogger("voicebot")
 
@@ -24,6 +25,7 @@ class GroqWebSocketHandler:
     def __init__(self):
         self.active_connections: Dict[str, WebSocket] = {}
         self.user_sessions: Dict[str, Dict] = {}
+        self.llm_service = HybridLLMService()
         
     async def connect(self, websocket: WebSocket, session_id: str = None):
         """Accept WebSocket connection and initialize session"""
@@ -221,17 +223,24 @@ class GroqWebSocketHandler:
             
             if query_context["requires_documents"]:
                 logger.info(f"📄 Document search required for: {query}")
-                response_data = await hybrid_rag_service.search_and_generate_response(
-                    query=query,
-                    user_language=language,
-                    conversation_history=self.user_sessions[session_id]["conversation_history"][-5:]  # Last 5 messages
+                # Get relevant documents
+                documents = await search_documents_async(query, limit=3)
+                context = "\n".join([doc.get("content", "") for doc in documents])
+                
+                # Generate response with context
+                response_text = await self.llm_service.get_response(
+                    message=query,
+                    context=context
                 )
+                response_data = {"response": response_text}
             else:
                 logger.info(f"💬 General query: {query}")
-                response_data = await hybrid_rag_service.generate_simple_response(
-                    query=query,
-                    user_language=language
+                # Generate simple response without documents
+                response_text = await self.llm_service.get_response(
+                    message=query,
+                    context=""
                 )
+                response_data = {"response": response_text}
             
             processing_time = time.time() - processing_start