feat: add bulk delete options

Author: kernelshard

imagekitio/client.py

@@ -12,6 +12,7 @@ class ImageKit(object):
     Main Class What user will use by creating
     instance
     """
+
     def __init__(
         self,
         public_key=None,
@@ -51,6 +52,11 @@ def delete_file(self, file_id: str = None) -> Dict[str, Any]:
         """
         return self.file.delete(file_id)
 
+    def bulk_delete(self, file_ids: list = None):
+        """Delete files in bulk by provided list of ids
+        """
+        return self.file.batch_delete(file_ids)
+
     def purge_cache(self, file_url: str = None) -> Dict[str, Any]:
         """Purge Cache from server by file url
         """

imagekitio/constants/files.py

@@ -19,5 +19,5 @@
     "is_private_file",
     "custom_coordinates",
     "response_fields",
-    "metadata"
+    "metadata",
 ]

imagekitio/constants/url.py

@@ -4,4 +4,5 @@
 class URL(Enum):
     BASE_URL = "https://api.imagekit.io/v1/files"
     PURGE_CACHE = "/purge"
-    UPLOAD = "/upload"
+    UPLOAD_URL = "https://upload.imagekit.io/api/v1/files/upload"
+    BULK_FILE_DELETE = "/batch/deleteByFileIds"

imagekitio/file.py

@@ -26,7 +26,7 @@ def upload(self, file, file_name, options) -> Dict:
             raise TypeError(ERRORS.MISSING_UPLOAD_FILE_PARAMETER.value)
         if not file_name:
             raise TypeError(ERRORS.MISSING_UPLOAD_FILENAME_PARAMETER.value)
-        url = URL.BASE_URL.value + URL.UPLOAD.value
+        url = URL.UPLOAD_URL.value
         headers = self.request.create_headers()
 
         files = {
@@ -142,6 +142,27 @@ def delete(self, file_id: str = None) -> Dict:
         response = {"error": error, "response": response}
         return response
 
+    def batch_delete(self, file_ids: list = None):
+        """Delete bulk files
+        Delete files by batch ids
+        """
+        if not file_ids:
+            raise ValueError("Need to pass ids in list")
+        url = URL.BASE_URL.value + URL.BULK_FILE_DELETE.value
+        resp = self.request.request(
+            method="POST", url=url, headers=self.request.create_headers(), data={"fileIds": file_ids}
+        )
+
+        if resp.status_code > 204:
+            error = resp.text
+            response = None
+        else:
+            error = None
+            response = None
+
+        response = {"error": error, "response": response}
+        return response
+
     def purge_cache(self, file_url: str = None) -> Dict[str, Any]:
         """Use from child class to purge cache
         """

sample/sample.py

@@ -1,5 +1,4 @@
 import base64
-import os
 import sys
 
 sys.path.append("..")
@@ -92,8 +91,10 @@
 
     print("-------------------------------------")
     list_files = imagekit.list_files({"skip": 0, "limit": 2})
-    # file_id = list_files["response"][0]["url"]
-
+    bulk_ids = [
+        list_files["response"][0]["fileId"],
+        list_files["response"][1]["fileId"],
+    ]
     print("List files-", "\n", list_files)
 
 upload = imagekit.upload(
@@ -181,3 +182,8 @@
 print(
     "Phash distance-", imagekit.phash_distance("f06830ca9f1e3e90", "f06830ca9f1e3e90"),
 )
+
+print("-------------------------------------")
+
+
+print("Bulk File delete-", imagekit.bulk_delete(bulk_ids))

setup.py

@@ -9,7 +9,7 @@
     description="Python wrapper for the ImageKit API",
     long_description=long_description,
     long_description_content_type="text/markdown",
-    install_requires=['requests==2.20.1'],
+    install_requires=["requests==2.20.1"],
     url="https://github.com/imagekit-developer/imagekit-python",
     packages=setuptools.find_packages(),
     classifiers=[