feat: Add V3 API endpoints with file metadata - sessions list, history, and pipeline executions

api_routes_v2.py

@@ -2470,6 +2470,120 @@ async def regenerate_file_url(file_id: str):
         raise HTTPException(status_code=404, detail=f"File not found: {str(e)}")
 
 
+# V3 API Endpoints - Add to api_routes_v2.py before # HEALTH section
+
+# ========================
+# V3 SESSIONS API
+# ========================
+
+@router.get("/sessions")
+def get_all_sessions(limit: int = 100):
+    """Get all sessions sorted by last_activity with current_file metadata"""
+    try:
+        sessions = session_manager.get_all_sessions(limit=limit)
+        return {"sessions": sessions}
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=f"Failed to get sessions: {str(e)}")
+
+
+@router.get("/sessions/{session_id}/history")
+def get_session_complete_history(session_id: str, limit: int = 50):
+    """Get complete session history with file metadata (file, fileName, fileUrl)"""
+    try:
+        session = session_manager.get_session(session_id)
+        if not session:
+            raise HTTPException(status_code=404, detail="Session not found")
+        
+        messages = session_manager.get_messages(session_id, limit=limit, include_content=True)
+        
+        return {
+            "session_id": session_id,
+            "chat_name": session.get("chat_name"),
+            "created_at": session.get("created_at"),
+            "last_activity": session.get("last_activity"),
+            "state": session.get("state"),
+            "messages": messages
+        }
+    except HTTPException:
+        raise
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=f"Failed to get session history: {str(e)}")
+
+
+@router.get("/sessions/{session_id}/pipelines")
+def get_session_pipeline_executions(session_id: str, limit: int = 50):
+    """Get all pipeline executions for session with final_output_url"""
+    try:
+        from services.pipeline_manager import get_pipeline_manager
+        
+        pipeline_mgr = get_pipeline_manager()
+        pipelines = pipeline_mgr.get_session_pipelines(session_id, limit=limit)
+        
+        return {
+            "session_id": session_id,
+            "pipelines": pipelines
+        }
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=f"Failed to get pipeline executions: {str(e)}")
+
+
+# V3 API Endpoints - Add to api_routes_v2.py before # HEALTH section
+
+# ========================
+# V3 SESSIONS API
+# ========================
+
+@router.get("/sessions")
+def get_all_sessions(limit: int = 100):
+    """Get all sessions sorted by last_activity with current_file metadata"""
+    try:
+        sessions = session_manager.get_all_sessions(limit=limit)
+        return {"sessions": sessions}
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=f"Failed to get sessions: {str(e)}")
+
+
+@router.get("/sessions/{session_id}/history")
+def get_session_complete_history(session_id: str, limit: int = 50):
+    """Get complete session history with file metadata (file, fileName, fileUrl)"""
+    try:
+        session = session_manager.get_session(session_id)
+        if not session:
+            raise HTTPException(status_code=404, detail="Session not found")
+        
+        messages = session_manager.get_messages(session_id, limit=limit, include_content=True)
+        
+        return {
+            "session_id": session_id,
+            "chat_name": session.get("chat_name"),
+            "created_at": session.get("created_at"),
+            "last_activity": session.get("last_activity"),
+            "state": session.get("state"),
+            "messages": messages
+        }
+    except HTTPException:
+        raise
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=f"Failed to get session history: {str(e)}")
+
+
+@router.get("/sessions/{session_id}/pipelines")
+def get_session_pipeline_executions(session_id: str, limit: int = 50):
+    """Get all pipeline executions for session with final_output_url"""
+    try:
+        from services.pipeline_manager import get_pipeline_manager
+        
+        pipeline_mgr = get_pipeline_manager()
+        pipelines = pipeline_mgr.get_session_pipelines(session_id, limit=limit)
+        
+        return {
+            "session_id": session_id,
+            "pipelines": pipelines
+        }
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=f"Failed to get pipeline executions: {str(e)}")
+
+
 # ========================
 # HEALTH
 # ========================

services/session_manager.py

@@ -204,6 +204,18 @@ class SessionManager:
                 # If S3 fetch fails, use preview
                 msg["content"] = msg["content_preview"]
                 msg["file_data"] = {}
+            
+            # V3 API: Add file metadata fields
+            msg["file"] = False
+            if msg.get("file_id"):
+                try:
+                    file_record = self.db["files"].find_one({"file_id": msg["file_id"]})
+                    if file_record:
+                        msg["file"] = True
+                        msg["fileName"] = file_record["file_name"]
+                        msg["fileUrl"] = file_record["presigned_url"]
+                except Exception as e:
+                    print(f"⚠️ Failed to get file metadata: {e}")
         
         return messages
     
@@ -427,6 +439,36 @@ class SessionManager:
         print("⚠️ save_pipeline_execution is deprecated. Use pipeline_manager instead.")
         return True
     
+    def get_all_sessions(self, limit: int = 100) -> List[Dict[str, Any]]:
+        """
+        Get all sessions sorted by last_activity
+        Includes current_file metadata
+        """
+        sessions = list(self.sessions_collection.find(
+            {},
+            {"_id": 0}
+        ).sort("last_activity", -1).limit(limit))
+        
+        # Add current file info to each session
+        for session in sessions:
+            session["file"] = False
+            
+            if session.get("current_file_id"):
+                try:
+                    file_record = self.db["files"].find_one({"file_id": session["current_file_id"]})
+                    if file_record:
+                        session["current_file"] = {
+                            "file_id": file_record["file_id"],
+                            "file_name": file_record["file_name"],
+                            "file_url": file_record["presigned_url"],
+                            "uploaded_at": file_record["uploaded_at"]
+                        }
+                        session["file"] = True
+                except Exception as e:
+                    print(f"⚠️ Failed to get file info: {e}")
+        
+        return sessions
+    
     def close(self):
         """Close MongoDB connection"""
         if self.client: