Update storage/pending_videos_routers.py

storage/pending_videos_routers.py

@@ -48,7 +48,36 @@ def clear_media(token: str = Query(..., description="Token required for authoriz
     return {"status": "ok", "message": "All peding_videos files deleted successfully"}
 
 
-@router.post("/upload_peding_video", tags=["Pending Videos Manager"])
+@router.delete("/clear_pending_video", tags=["Pending Videos Manager"])
+def clear_pending_video(
+    sha1: str = Query(..., description="SHA1 folder to delete inside pending_videos"),
+    token: str = Query(..., description="Token required for authorization")
+):
+    """
+    Delete a specific SHA1 folder inside /data/pending_videos.
+    Steps:
+    - Validate the token.
+    - Ensure the folder exists.
+    - Delete the folder and all its contents.
+    - Return a JSON response confirming the deletion.
+    """
+    validate_token(token)
+
+    PENDING_ROOT = Path("/data/pending_videos")
+    target_folder = PENDING_ROOT / sha1
+
+    if not target_folder.exists() or not target_folder.is_dir():
+        raise HTTPException(status_code=404, detail=f"Folder {sha1} does not exist in pending_videos")
+
+    try:
+        shutil.rmtree(target_folder)
+    except Exception as e:
+        raise HTTPException(status_code=500, detail=f"Failed to delete {sha1}: {e}")
+
+    return {"status": "ok", "message": f"Pending video folder {sha1} deleted successfully"}
+
+
+@router.post("/upload_pending_video", tags=["Pending Videos Manager"])
 async def upload_video(
     video: UploadFile = File(...),
     token: str = Query(..., description="Token required for authorization")
@@ -107,7 +136,7 @@ async def upload_video(
     )
 
 
-@router.get("/download_peding_video", tags=["Pending Videos Manager"])
+@router.get("/download_pending_video", tags=["Pending Videos Manager"])
 def download_video(
     sha1: str,
     token: str = Query(..., description="Token required for authorization")
@@ -166,7 +195,7 @@ def download_video(
         filename=video_path.name
     )
 
-@router.get("/list_peding_videos", tags=["Pending Videos Manager"])
+@router.get("/list_pending_videos", tags=["Pending Videos Manager"])
 def list_all_videos(
     token: str = Query(..., description="Token required for authorization")
 ):