Update conversation_manager.py

conversation_manager.py

@@ -92,7 +92,7 @@ class ConversationManager:
             logger.error(f"Error retrieving history for chat {chat_id}: {e}")
             return []
     
-    def save_history(self, chat_id: str, history: List[Dict[str, Any]]) -> bool:
+    def save_history(self, chat_id: str, history: List[Dict[str, Any]], user_id: str) -> bool:
         """
         Save conversation history for a specific chat ID
         
@@ -113,8 +113,8 @@ class ConversationManager:
         
         try:
             # Check if conversation exists
-            existing = self.supabase.table('conversations').select('session_id').eq('session_id', chat_id).execute()
-            
+            existing = self.supabase.table('conversations').select('session_id').eq('session_id', chat_id).eq('user_id', user_id).execute()
+
             if existing.data and len(existing.data) > 0:
                 # Update existing conversation
                 response = self.supabase.table('conversations').update({
@@ -218,7 +218,7 @@ class ConversationManager:
             logger.error(f"Error deleting history for chat {chat_id}: {e}")
             return False
     
-    def get_all_chat_sessions(self) -> List[Dict[str, Any]]:
+    def get_all_chat_sessions(self, user_id: str) -> List[Dict[str, Any]]:
         """
         Get all chat sessions with basic information
         
@@ -226,8 +226,7 @@ class ConversationManager:
             List of dictionaries with chat session information
         """
         try:
-            response = self.supabase.table('conversations').select('session_id, history, created_at, updated_at').execute()
-            
+            response = self.supabase.table('conversations').select('session_id, history, created_at, updated_at').eq('user_id', user_id).execute()    
             sessions = []
             for conv in response.data:
                 session_id = conv.get('session_id')