Update app.py

app.py

@@ -325,24 +325,71 @@ async def generate_test(
 
     return test
 
-@app.get("/dpps/{dpp_name}", summary="Get all questions from a specific DPP", tags=["DPPs"])
+@app.get("/dpps/{dpp_name}", 
+    summary="Get all questions from a specific DPP", 
+    tags=["DPPs"],
+    response_description="List of questions from the specified DPP."
+)
 @cached(ttl=300, cache=SimpleMemoryCache, serializer=JsonSerializer())
 async def get_dpp_questions(
-    dpp_name: str = Path(..., description="Name of the DPP file without .db extension")
+    dpp_name: str = Path(..., description="Name of the DPP file without .db extension"),
+    offset: int = Query(0, ge=0, description="Offset for pagination"),
+    limit: int = Query(1000, ge=1, le=1000, description="Limit for pagination")
 ):
-    db_path = f"dpps/{dpp_name}.db"
-    if not os.path.exists(db_path):
-        raise HTTPException(status_code=404, detail="DPP file not found.")
-
-    # Connect to the database asynchronously
-    async with aiosqlite.connect(db_path) as db:
-        cursor = await db.execute("SELECT * FROM selected_questions")
-        questions = await cursor.fetchall()
-
-    if not questions:
-        raise HTTPException(status_code=404, detail="No questions found in the DPP.")
-
-    return {"dpp": dpp_name, "questions": [dict(q) for q in questions]}
+    """
+    Get questions from a specific DPP file with pagination support.
+    
+    Args:
+        dpp_name: Name of the DPP file (without .db extension)
+        offset: Number of questions to skip
+        limit: Maximum number of questions to return
+        
+    Returns:
+        Dictionary containing DPP name and list of questions
+    """
+    db_path = Path("dpps") / f"{dpp_name}.db"
+    
+    if not db_path.exists():
+        raise HTTPException(
+            status_code=404, 
+            detail=f"DPP file '{dpp_name}' not found"
+        )
+    
+    try:
+        async with aiosqlite.connect(str(db_path)) as db:
+            db.row_factory = aiosqlite.Row
+            
+            # First get total count
+            async with db.execute("SELECT COUNT(*) as count FROM selected_questions") as cursor:
+                total_count = (await cursor.fetchone())['count']
+            
+            # Then get paginated questions
+            query = "SELECT * FROM selected_questions LIMIT ? OFFSET ?"
+            async with db.execute(query, [limit, offset]) as cursor:
+                questions = await cursor.fetchall()
+                
+            if not questions:
+                raise HTTPException(
+                    status_code=404,
+                    detail=f"No questions found in DPP '{dpp_name}' for the specified page"
+                )
+                
+            return {
+                "dpp_name": dpp_name,
+                "total_questions": total_count,
+                "questions": [dict(q) for q in questions],
+                "pagination": {
+                    "offset": offset,
+                    "limit": limit,
+                    "total": total_count
+                }
+            }
+            
+    except aiosqlite.Error as e:
+        raise HTTPException(
+            status_code=500,
+            detail=f"Database error occurred while accessing DPP '{dpp_name}': {str(e)}"
+        )
 
 # Main application runner
 if __name__ == "__main__":