feat: add Cloudinary support as an alternative image storage mode

app/core/config.py

@@ -73,7 +73,7 @@ class Settings(BaseSettings):
         return f"redis://{self.REDIS_HOST}:{self.REDIS_PORT}/0"
 
     # Storage Configurations
-    STORAGE_MODE: str = "local" # "local" hoặc "r2"
+    STORAGE_MODE: str = "local" # "local", "r2", hoặc "cloudinary"
     UPLOAD_DIR: str = "uploads"
     SERVER_HOST_URL: str = "http://localhost:8000"
 
@@ -83,6 +83,11 @@ class Settings(BaseSettings):
     R2_SECRET_ACCESS_KEY: str = "change_me_r2_secret_key"
     R2_ENDPOINT_URL: str = "https://change-me-account-id.r2.cloudflarestorage.com"
 
+    # Cloudinary Configs
+    CLOUDINARY_CLOUD_NAME: Optional[str] = None
+    CLOUDINARY_API_KEY: Optional[str] = None
+    CLOUDINARY_API_SECRET: Optional[str] = None
+
 
     # Qdrant Vector DB
     QDRANT_HOST: str = "localhost"

app/services/storage.py

@@ -15,6 +15,16 @@ class StorageService:
                 aws_secret_access_key=settings.R2_SECRET_ACCESS_KEY,
                 endpoint_url=settings.R2_ENDPOINT_URL
             )
+        elif settings.STORAGE_MODE == "cloudinary":
+            self.s3_client = None
+            import cloudinary
+            import cloudinary.uploader
+            cloudinary.config(
+                cloud_name=settings.CLOUDINARY_CLOUD_NAME,
+                api_key=settings.CLOUDINARY_API_KEY,
+                api_secret=settings.CLOUDINARY_API_SECRET,
+                secure=True
+            )
         else:
             self.s3_client = None
 
@@ -42,6 +52,25 @@ class StorageService:
             except Exception as e:
                 logging.error(f"Failed to upload local file: {e}")
                 return None
+        elif settings.STORAGE_MODE == "cloudinary":
+            try:
+                import cloudinary.uploader
+                # Parse folder path and filename from sanitized path
+                path_parts = sanitized_object_name.split("/")
+                folder = "wardrobe/" + "/".join(path_parts[:-1]) if len(path_parts) > 1 else "wardrobe"
+                filename = os.path.splitext(path_parts[-1])[0]
+                
+                result = cloudinary.uploader.upload(
+                    file_content,
+                    folder=folder,
+                    public_id=filename,
+                    overwrite=True,
+                    resource_type="auto"
+                )
+                return result.get("secure_url")
+            except Exception as e:
+                logging.error(f"Failed to upload file to Cloudinary: {e}")
+                return None
         else:
             # Cloudflare R2 Upload
             try:
@@ -85,6 +114,28 @@ class StorageService:
             except Exception as e:
                 logging.error(f"Failed to delete local file: {e}")
                 return False
+        elif settings.STORAGE_MODE == "cloudinary":
+            try:
+                import cloudinary.uploader
+                import re
+                
+                # Parse public_id from Cloudinary URL:
+                # https://res.cloudinary.com/<cloud_name>/image/upload/v<version>/<folder>/<public_id>.<ext>
+                if "res.cloudinary.com" in object_name_or_url:
+                    match = re.search(r"/upload/(?:v\d+/)?(.+)$", object_name_or_url)
+                    if match:
+                        public_id_with_ext = match.group(1)
+                        public_id = os.path.splitext(public_id_with_ext)[0]
+                    else:
+                        public_id = object_name_or_url
+                else:
+                    public_id = object_name_or_url
+                
+                result = cloudinary.uploader.destroy(public_id)
+                return result.get("result") == "ok"
+            except Exception as e:
+                logging.error(f"Failed to delete file from Cloudinary: {e}")
+                return False
         else:
             try:
                 if not self.s3_client:

pyproject.toml

@@ -42,4 +42,5 @@ dependencies = [
     "huggingface-hub>=0.23.0",
     "matplotlib>=3.9.1",
     "tqdm>=4.66.4",
+    "cloudinary>=1.41.0",
 ]