Update main.py

main.py

@@ -9,6 +9,7 @@ import cloudinary
 import cloudinary.uploader
 from cloudinary.utils import cloudinary_url
 import requests
+from tempfile import NamedTemporaryFile
 
 app = FastAPI()
 
@@ -74,7 +75,7 @@ async def decrypt_and_upload(
 ):
     try:
         # Download file data from the URL
-        response = requests.get(url)
+        response = requests.get(url, stream=True)
         if response.status_code != 200:
             return JSONResponse(content={"error": "Failed to download the file."}, status_code=400)
 
@@ -87,20 +88,24 @@ async def decrypt_and_upload(
             mediaKeyExpanded[16:48], mediaData[:-10], mediaKeyExpanded[:16]
         )
 
-        # Determine Cloudinary upload parameters
-        resource_type = "video" if media_type.startswith("video") else "raw"
-        upload_format = extension.get(media_type, "bin")
+        # Save decrypted data to a temporary file
+        with NamedTemporaryFile(delete=False, suffix=f".{extension.get(media_type, 'bin')}") as temp_file:
+            temp_file.write(decrypted_data)
+            temp_file_path = temp_file.name
 
         # Upload decrypted data to Cloudinary
         upload_result = cloudinary.uploader.upload(
-            decrypted_data,
-            resource_type=resource_type,
-            format=upload_format,
+            temp_file_path,
+            resource_type="video" if media_type.startswith("video") else "raw",
+            format=extension.get(media_type, "bin"),
             eager=[{"width": 720, "height": 480, "crop": "pad"}],  # Example transformation
             eager_async=True
         )
         file_url = upload_result.get("secure_url")
 
+        # Clean up temporary file
+        os.remove(temp_file_path)
+
         # Provide Cloudinary URL
         return JSONResponse(content={"decrypted_file_url": file_url})