Fix CRUD endpoints with proper MongoDB queries and validation

main.py

@@ -970,11 +970,20 @@ async def update_checklist_item(user_id: str, item_id: str, item_data: dict):
     try:
         logger.info(f"Updating item {item_id} for user: {user_id}")
         
+        # Check if checklist exists
+        checklist = await db.checklists.find_one({"userId": user_id})
+        if not checklist:
+            logger.warning(f"No checklist found for user {user_id}")
+            raise HTTPException(
+                status_code=status.HTTP_404_NOT_FOUND,
+                detail=f"Checklist not found for user {user_id}. Please create a checklist first."
+            )
+        
         # Prepare update fields
         update_fields = {}
         for field in ['requirement', 'compliance', 'deviation', 'action']:
             if field in item_data:
-                update_fields[f"sections.$[section].items.$[item].{field}"] = item_data[field]
+                update_fields[f"sections.$[].items.$[item].{field}"] = item_data[field]
         
         if not update_fields:
             raise HTTPException(
@@ -984,9 +993,9 @@ async def update_checklist_item(user_id: str, item_id: str, item_data: dict):
         
         # Update the item
         result = await db.checklists.update_one(
-            {"userId": user_id, "sections.items.id": item_id},
+            {"userId": user_id},
             {"$set": update_fields},
-            array_filters=[{"section.items.id": item_id}]
+            array_filters=[{"item.id": item_id}]
         )
         
         if result.modified_count > 0:
@@ -1029,6 +1038,15 @@ async def delete_checklist_item(user_id: str, item_id: str):
     try:
         logger.info(f"Deleting item {item_id} for user: {user_id}")
         
+        # Check if checklist exists
+        checklist = await db.checklists.find_one({"userId": user_id})
+        if not checklist:
+            logger.warning(f"No checklist found for user {user_id}")
+            raise HTTPException(
+                status_code=status.HTTP_404_NOT_FOUND,
+                detail=f"Checklist not found for user {user_id}. Please create a checklist first."
+            )
+        
         # Remove the item from the checklist
         result = await db.checklists.update_one(
             {"userId": user_id},
@@ -1137,6 +1155,15 @@ async def delete_checklist_section(user_id: str, section_id: str):
     try:
         logger.info(f"Deleting section {section_id} for user: {user_id}")
         
+        # Check if checklist exists
+        checklist = await db.checklists.find_one({"userId": user_id})
+        if not checklist:
+            logger.warning(f"No checklist found for user {user_id}")
+            raise HTTPException(
+                status_code=status.HTTP_404_NOT_FOUND,
+                detail=f"Checklist not found for user {user_id}. Please create a checklist first."
+            )
+        
         # Remove the section from the checklist
         result = await db.checklists.update_one(
             {"userId": user_id},