Optimize dashboard, summary api

Author: hoangdohuy

Architect_MultiClient_Server/dashboard/package-lock.json

@@ -8,10 +8,10 @@
     "preview": "vite preview"
   },
   "dependencies": {
+    "axios": "^1.6.2",
     "react": "^18.2.0",
     "react-dom": "^18.2.0",
-    "react-router-dom": "^6.20.0",
-    "axios": "^1.6.2"
+    "react-router-dom": "^6.20.0"
   },
   "devDependencies": {
     "@types/react": "^18.2.43",
@@ -20,6 +20,6 @@
     "autoprefixer": "^10.4.16",
     "postcss": "^8.4.32",
     "tailwindcss": "^3.3.6",
-    "vite": "^5.0.8"
+    "vite": "^5.4.21"
   }
 }

Architect_MultiClient_Server/dashboard/package.json

@@ -21,7 +21,7 @@ function App() {
       <main className="max-w-7xl mx-auto px-4 sm:px-6 lg:px-8 py-8">
         <Routes>
           <Route path="/" element={<RoomList />} />
-          <Route path="/room/:roomName" element={<RoomDetail />} />
+          <Route path="/room/:roomId" element={<RoomDetail />} />
         </Routes>
       </main>
     </div>

Architect_MultiClient_Server/dashboard/src/App.jsx

@@ -1,13 +1,13 @@
 import { useState, useEffect } from 'react';
 import { useParams, useNavigate } from 'react-router-dom';
 import { 
-  getRoomByName, 
-  getRoomStatistics, 
-  getSummaryByRoom
+  getRoomById, 
+  getRoomStatisticsById, 
+  getSummaryByRoomId
 } from '../services/api';
 
 const RoomDetail = () => {
-  const { roomName } = useParams();
+  const { roomId } = useParams();
   const navigate = useNavigate();
 
   const [room, setRoom] = useState(null);
@@ -19,7 +19,7 @@ const RoomDetail = () => {
 
   useEffect(() => {
     fetchRoomData();
-  }, [roomName]);
+  }, [roomId]);
 
   const fetchRoomData = async () => {
     try {
@@ -28,9 +28,9 @@ const RoomDetail = () => {
 
       // Fetch room details, statistics, and summaries in parallel
       const [roomData, statsData, summaryData] = await Promise.all([
-        getRoomByName(roomName),
-        getRoomStatistics(roomName),
-        getSummaryByRoom(roomName)
+        getRoomById(roomId),
+        getRoomStatisticsById(roomId),
+        getSummaryByRoomId(roomId)
       ]);
 
       setRoom(roomData.room);
@@ -174,7 +174,7 @@ const RoomDetail = () => {
           >
             ← Back
           </button>
-          <h2 className="text-3xl font-bold text-gray-900">{roomName}</h2>
+          <h2 className="text-3xl font-bold text-gray-900">{room.room_name}</h2>
           {getStatusBadge(room.status)}
         </div>
         <button

Architect_MultiClient_Server/dashboard/src/components/RoomDetail.jsx

@@ -141,7 +141,7 @@ const RoomList = () => {
                   <tr 
                     key={room._id} 
                     className="hover:bg-gray-50 cursor-pointer transition"
-                    onClick={() => navigate(`/room/${room.room_name}`)}
+                    onClick={() => navigate(`/room/${room._id}`)}
                   >
                     <td className="px-6 py-4 whitespace-nowrap">
                       <div className="text-sm font-medium text-gray-900">
@@ -161,7 +161,7 @@ const RoomList = () => {
                       <button
                         onClick={(e) => {
                           e.stopPropagation();
-                          navigate(`/room/${room.room_name}`);
+                          navigate(`/room/${room._id}`);
                         }}
                         className="text-blue-600 hover:text-blue-900 font-medium"
                       >

Architect_MultiClient_Server/dashboard/src/components/RoomList.jsx

@@ -29,11 +29,21 @@ export const getRoomByName = async (roomName) => {
   return response.data;
 };
 
+export const getRoomById = async (roomId) => {
+  const response = await apiClient.get(`/api/transcripts/rooms/id/${roomId}`);
+  return response.data;
+};
+
 export const getRoomStatistics = async (roomName) => {
   const response = await apiClient.get(`/api/transcripts/rooms/${roomName}/statistics`);
   return response.data;
 };
 
+export const getRoomStatisticsById = async (roomId) => {
+  const response = await apiClient.get(`/api/transcripts/rooms/id/${roomId}/statistics`);
+  return response.data;
+};
+
 // Summary APIs
 export const getSummaryByRoom = async (roomName, startTime = null, endTime = null) => {
   const queryParams = new URLSearchParams();
@@ -46,6 +56,11 @@ export const getSummaryByRoom = async (roomName, startTime = null, endTime = nul
   return response.data;
 };
 
+export const getSummaryByRoomId = async (roomId) => {
+  const response = await apiClient.get(`/api/summary/room/id/${roomId}`);
+  return response.data;
+};
+
 // Transcript APIs
 export const getFullTranscript = async (trackId) => {
   const response = await apiClient.get(`/api/transcripts/tracks/${trackId}/transcript`);

Architect_MultiClient_Server/dashboard/src/services/api.js

@@ -20,6 +20,7 @@
     SkipQuery,
     validate_date_range
 )
+from bson import ObjectId
 
 router = APIRouter(prefix="/api/transcripts/rooms", tags=["Rooms"])
 logger = get_logger(__name__)
@@ -170,3 +171,82 @@ async def get_room_statistics(
     except Exception as e:
         logger.error(f"Failed to get room statistics: {e}")
         raise HTTPException(status_code=500, detail=str(e))
+
+
+@router.get("/id/{room_id}", response_description="Get room by ID")
+async def get_room_by_id(
+    room_id: str,
+    auth: Dict[str, Any] = Depends(verify_api_key)
+):
+    """
+    Get room details by room ID.
+    
+    - **room_id**: The ObjectId of the room to retrieve
+    """
+    try:
+        mongodb = get_mongodb_service()
+        if not mongodb.connected:
+            await mongodb.connect()
+        
+        # Validate ObjectId format
+        try:
+            ObjectId(room_id)
+        except Exception:
+            raise HTTPException(status_code=400, detail=f"Invalid room_id format: '{room_id}'")
+        
+        room = await mongodb.get_room_by_id(room_id)
+        if not room:
+            raise HTTPException(status_code=404, detail=f"Room with ID '{room_id}' not found")
+        
+        room["_id"] = str(room["_id"])
+        
+        return {
+            "status": "ok",
+            "room": room
+        }
+    except HTTPException:
+        raise
+    except Exception as e:
+        logger.error(f"Failed to get room: {e}")
+        raise HTTPException(status_code=500, detail=str(e))
+
+
+@router.get("/id/{room_id}/statistics", response_description="Get room statistics by ID")
+async def get_room_statistics_by_id(
+    room_id: str,
+    auth: Dict[str, Any] = Depends(verify_api_key)
+):
+    """
+    Get detailed statistics for a specific room by ID.
+    
+    - **room_id**: The ObjectId of the room
+    
+    Returns:
+    - Total tracks, completed/remaining tracks
+    - Total duration in seconds
+    - Total transcript segments
+    """
+    try:
+        mongodb = get_mongodb_service()
+        if not mongodb.connected:
+            await mongodb.connect()
+        
+        # Validate ObjectId format
+        try:
+            ObjectId(room_id)
+        except Exception:
+            raise HTTPException(status_code=400, detail=f"Invalid room_id format: '{room_id}'")
+        
+        stats = await mongodb.get_room_statistics_by_id(room_id)
+        if not stats:
+            raise HTTPException(status_code=404, detail=f"Room with ID '{room_id}' not found")
+        
+        return {
+            "status": "ok",
+            "statistics": stats
+        }
+    except HTTPException:
+        raise
+    except Exception as e:
+        logger.error(f"Failed to get room statistics: {e}")
+        raise HTTPException(status_code=500, detail=str(e))

Architect_MultiClient_Server/orchestrator_service/api/room_api.py

@@ -79,10 +79,24 @@ async def get_summary_by_room_name(
     """
     mongodb = get_mongodb_service()
     summaries = await mongodb.get_summary_by_room_name(room_name, start_time, end_time)
+    return {
+        "status": "ok",
+        "data": summaries,
+        "count": len(summaries)
+    }
+
+@client_router.get("/room/id/{room_id}", response_description="Get summary by room ID")
+async def get_summary_by_room_id(
+    room_id: str,
+    ):
+    """
+    Get summary by room id.
+    """
+    mongodb = get_mongodb_service()
+    summaries = await mongodb.get_summary_by_room_id(room_id)
     # remove unnecessary fields
     for summary in summaries:
         summary.pop("_id", None)
-        summary.pop("room_id", None)
         summary.pop("summary_text", None)
     return {
         "status": "ok",

Architect_MultiClient_Server/orchestrator_service/api/summary_api.py

@@ -410,6 +410,43 @@ async def get_room_statistics(self, room_name: str) -> Dict[str, Any]:
             logger.error(f"Failed to get room statistics: {e}")
             return {}
 
+    async def get_room_statistics_by_id(self, room_id: str) -> Dict[str, Any]:
+        """Get detailed statistics for a room by ID"""
+        try:
+            room = await self.get_room_by_id(room_id)
+            if not room:
+                return {}
+            
+            tracks = await self.get_tracks_by_room(room_id)
+            
+            total_duration = 0
+            total_segments = 0
+            
+            for track in tracks:
+                chunks = await self.get_chunks_by_track(str(track["_id"]))
+                for chunk in chunks:
+                    total_segments += chunk.get("item_count", 0)
+                
+                audio_info = track.get("audio_info", {})
+                duration_ns = int(audio_info.get("duration_sec", "0"))
+                total_duration += duration_ns / 1_000_000_000  # Convert to seconds
+            
+            return {
+                "room_id": room_id,
+                "room_name": room.get("room_name"),
+                "status": room.get("status"),
+                "total_tracks": len(tracks),
+                "completed_tracks": room.get("completed_tracks", 0),
+                "remain_tracks": room.get("remain_tracks", 0),
+                "total_duration_sec": total_duration,
+                "total_segments": total_segments,
+                "created_at": room.get("created_at"),
+                "completed_at": room.get("completed_at")
+            }
+        except Exception as e:
+            logger.error(f"Failed to get room statistics by ID: {e}")
+            return {}
+
     async def get_participant_statistics(self, participant_identity: str) -> Dict[str, Any]:
         """Get statistics for a participant across all rooms"""
         try:
@@ -499,10 +536,12 @@ async def get_summary_by_room_name(self, room_name: str, start_time: Optional[da
         try:
             # 1. get room list
             query = {"room_name": room_name}
-            if start_time:
-                query["created_at"] = {"$gte": start_time}
-            if end_time:
-                query["created_at"] = {"$lte": end_time}
+            if start_time or end_time:
+                query["created_at"] = {}
+                if start_time:
+                    query["created_at"]["$gte"] = start_time
+                if end_time:
+                    query["created_at"]["$lte"] = end_time
             cursor = self.rooms_collection.find(query).sort("created_at", -1)
             room_list = await cursor.to_list(None)
             room_dict = {str(room["_id"]): room for room in room_list}
@@ -515,13 +554,36 @@ async def get_summary_by_room_name(self, room_name: str, start_time: Optional[da
 
             # Override created_at and completed_at
             for summary in summary_list:
-                summary["created_at"] = room_dict.get(str(summary["room_id"])).get("created_at")
-                summary["completed_at"] = room_dict.get(str(summary["room_id"])).get("completed_at")
+                created_at = room_dict.get(str(summary["room_id"])).get("created_at")
+                completed_at = room_dict.get(str(summary["room_id"])).get("completed_at")
+                
+                # Format datetime to ISO 8601 with Z suffix (UTC) and rounded to seconds
+                if isinstance(created_at, datetime):
+                    summary["created_at"] = created_at.replace(microsecond=0).isoformat() + 'Z'
+                else:
+                    summary["created_at"] = created_at
+                
+                if isinstance(completed_at, datetime):
+                    summary["completed_at"] = completed_at.replace(microsecond=0).isoformat() + 'Z'
+                else:
+                    summary["completed_at"] = completed_at
+                
+                summary.pop("_id", None)
+                summary.pop("room_id", None)
+                summary.pop("summary_text", None)
             return summary_list
         except Exception as e:
             logger.error(f"Failed to get summary by room name: {e}")
             return []
 
+    async def get_summary_by_room_id(self, room_id: str) -> List[Dict[str, Any]]:
+        """Get summary by room id"""
+        try:
+            return await self.summary_collection.find({"room_id": room_id}).to_list(None)
+        except Exception as e:
+            logger.error(f"Failed to get summary by room id: {e}")
+            return []
+
     # ========================================
     # 🏭 SINGLETON PATTERN
     # ========================================