Update services/session_manager.py

services/session_manager.py

@@ -285,6 +285,24 @@ class SessionManager:
         history = session.get("conversation_history", [])
         return history[-limit:] if len(history) > limit else history
     
+    def get_all_session_ids(self) -> List[str]:
+        """
+        Get all session IDs from the database
+        
+        Returns:
+            List of session IDs
+        """
+        if self.sessions_col is None:
+            return []
+        
+        try:
+            sessions = self.sessions_col.find({}, {"session_id": 1, "_id": 0})
+            session_ids = [session["session_id"] for session in sessions]
+            return session_ids
+        except Exception as e:
+            print(f"⚠️  Error retrieving session IDs: {e}")
+            return []
+    
     def get_pipeline_executions(
         self,
         session_id: Optional[str] = None,