Refactor team config retrieval to remove user filter

Updated backend methods to retrieve all team configurations without filtering by user ID. Adjusted related service, API, and database interfaces to reflect this change. Added debug logging for WebSocket messages in both backend and frontend for improved traceability.

Author: Fr4nc3

src/backend/common/database/cosmosdb.py

@@ -334,7 +334,7 @@ async def get_team_by_id(self, id: str) -> Optional[TeamConfiguration]:
         teams = await self.query_items(query, parameters, TeamConfiguration)
         return teams[0] if teams else None
 
-    async def get_all_teams_by_user(self, user_id: str) -> List[TeamConfiguration]:
+    async def get_all_teams(self) -> List[TeamConfiguration]:
         """Retrieve all team configurations for a specific user.
 
         Args:
@@ -343,9 +343,8 @@ async def get_all_teams_by_user(self, user_id: str) -> List[TeamConfiguration]:
         Returns:
             List of TeamConfiguration objects
         """
-        query = "SELECT * FROM c WHERE c.user_id=@user_id AND c.data_type=@data_type ORDER BY c.created DESC"
+        query = "SELECT * FROM c WHERE c.data_type=@data_type ORDER BY c.created DESC"
         parameters = [
-            {"name": "@user_id", "value": user_id},
             {"name": "@data_type", "value": DataType.team_config},
         ]
         teams = await self.query_items(query, parameters, TeamConfiguration)

src/backend/common/database/database_base.py

@@ -159,7 +159,7 @@ async def get_team_by_id(self, id: str) -> Optional[TeamConfiguration]:
         pass
 
     @abstractmethod
-    async def get_all_teams_by_user(self, user_id: str) -> List[TeamConfiguration]:
+    async def get_all_teams(self) -> List[TeamConfiguration]:
         """Retrieve all team configurations for the given user."""
         pass
 

src/backend/v3/api/router.py

@@ -688,7 +688,7 @@ async def get_team_configs(request: Request):
         team_service = TeamService(memory_store)
 
         # Retrieve all team configurations
-        team_configs = await team_service.get_all_team_configurations(user_id)
+        team_configs = await team_service.get_all_team_configurations()
 
         # Convert to dictionaries for response
         configs_dict = [config.model_dump() for config in team_configs]

src/backend/v3/common/services/team_service.py

@@ -271,7 +271,7 @@ async def handle_team_selection(self, user_id: str, team_id: str) -> bool:
             return False
 
     async def get_all_team_configurations(
-        self, user_id: str
+        self
     ) -> List[TeamConfiguration]:
         """
         Retrieve all team configurations for a user.
@@ -283,8 +283,8 @@ async def get_all_team_configurations(
             List of TeamConfiguration objects
         """
         try:
-            # Use the specific get_all_teams_by_user method
-            team_configs = await self.memory_context.get_all_teams_by_user(user_id)
+            # Use the specific get_all_teams method
+            team_configs = await self.memory_context.get_all_teams()
             return team_configs
 
         except (KeyError, TypeError, ValueError) as e:

src/backend/v3/config/settings.py

@@ -199,12 +199,13 @@ async def send_status_update_async(
             )
             return
 
+        print(f" websocket {message}")
         try:
             if hasattr(message, "data") and hasattr(message, "type"):
                 message = message.data
         except Exception as e:
                 print(f"Error loading message data: {e}")
-
+        print(f" websocket after {message}")
         standard_message = {
             "type": message_type,
             "data": message

src/backend/v3/magentic_agents/proxy_agent.py

@@ -81,6 +81,7 @@ async def reduce(self) -> ChatHistory | None:
             return None
         return await self._chat_history.reduce()
 
+
 class ProxyAgentResponseItem:
     """Response item wrapper for proxy agent responses."""
 

src/frontend/src/services/WebSocketService.tsx

@@ -168,6 +168,7 @@ class WebSocketService {
 
         //console.log('WebSocket message received:', message);
         const hasClarification = /\bclarifications?\b/i.test(message.data || '');
+        console.log("Message ':", message);
         if (hasClarification) {
             console.log("Message contains 'clarification':", message.data);
         }