Fix Cloudinary file upload issues: Add file existence checks, better error handling, and detailed logging for upload debugging

app.py

@@ -334,18 +334,35 @@ async def process_text_to_3d(job_id: str, prompt: str, user_id: Optional[str]):
         
         job_manager.update_job_progress(job_id, "uploading_results", 90, "Uploading 3D model...")
         
-        # Upload results
-        model_url = await asyncio.to_thread(
-            cloudinary_client.upload_file,
-            depth_result['obj_path'],
-            f"model_{job_id}.obj"
-        )
+        # Check if files exist before uploading
+        if not os.path.exists(depth_result['obj_path']):
+            raise FileNotFoundError(f"OBJ file not found: {depth_result['obj_path']}")
         
-        depth_map_url = await asyncio.to_thread(
-            cloudinary_client.upload_image_from_path,
-            depth_result['depth_map_path'],
-            f"depth_{job_id}"
-        )
+        if not os.path.exists(depth_result['depth_map_path']):
+            raise FileNotFoundError(f"Depth map file not found: {depth_result['depth_map_path']}")
+        
+        logger.info(f"📁 Files exist - OBJ: {depth_result['obj_path']}, Depth: {depth_result['depth_map_path']}")
+        
+        # Upload results with better error handling
+        try:
+            model_url = await asyncio.to_thread(
+                cloudinary_client.upload_file,
+                depth_result['obj_path'],
+                f"model_{job_id}.obj"
+            )
+        except Exception as e:
+            logger.error(f"❌ Failed to upload OBJ file: {str(e)}")
+            raise e
+        
+        try:
+            depth_map_url = await asyncio.to_thread(
+                cloudinary_client.upload_image_from_path,
+                depth_result['depth_map_path'],
+                f"depth_{job_id}"
+            )
+        except Exception as e:
+            logger.error(f"❌ Failed to upload depth map: {str(e)}")
+            raise e
         
         # Complete job
         job_manager.complete_job(job_id, {
@@ -393,18 +410,35 @@ async def process_upload_to_3d(job_id: str, file_content: bytes, filename: str,
         
         job_manager.update_job_progress(job_id, "uploading_results", 90, "Uploading 3D model...")
         
-        # Upload results
-        model_url = await asyncio.to_thread(
-            cloudinary_client.upload_file,
-            depth_result['obj_path'],
-            f"model_{job_id}.obj"
-        )
+        # Check if files exist before uploading
+        if not os.path.exists(depth_result['obj_path']):
+            raise FileNotFoundError(f"OBJ file not found: {depth_result['obj_path']}")
         
-        depth_map_url = await asyncio.to_thread(
-            cloudinary_client.upload_image_from_path,
-            depth_result['depth_map_path'],
-            f"depth_{job_id}"
-        )
+        if not os.path.exists(depth_result['depth_map_path']):
+            raise FileNotFoundError(f"Depth map file not found: {depth_result['depth_map_path']}")
+        
+        logger.info(f"📁 Files exist - OBJ: {depth_result['obj_path']}, Depth: {depth_result['depth_map_path']}")
+        
+        # Upload results with better error handling
+        try:
+            model_url = await asyncio.to_thread(
+                cloudinary_client.upload_file,
+                depth_result['obj_path'],
+                f"model_{job_id}.obj"
+            )
+        except Exception as e:
+            logger.error(f"❌ Failed to upload OBJ file: {str(e)}")
+            raise e
+        
+        try:
+            depth_map_url = await asyncio.to_thread(
+                cloudinary_client.upload_image_from_path,
+                depth_result['depth_map_path'],
+                f"depth_{job_id}"
+            )
+        except Exception as e:
+            logger.error(f"❌ Failed to upload depth map: {str(e)}")
+            raise e
         
         # Complete job
         job_manager.complete_job(job_id, {

utils/cloudinary_client.py

@@ -80,6 +80,17 @@ class CloudinaryClient:
         try:
             logger.info(f"☁️ Uploading file to Cloudinary: {public_id}")
             
+            # Check if file exists and is accessible
+            if not os.path.exists(file_path):
+                raise FileNotFoundError(f"File not found: {file_path}")
+            
+            file_size = os.path.getsize(file_path)
+            logger.info(f"📁 File info - Path: {file_path}, Size: {file_size} bytes")
+            
+            # Verify file is readable
+            with open(file_path, 'rb') as f:
+                f.read(1)  # Try to read first byte
+            
             result = cloudinary.uploader.upload(
                 file_path,
                 public_id=f"text-to-3d/{public_id}",
@@ -94,6 +105,7 @@ class CloudinaryClient:
             
         except Exception as e:
             logger.error(f"❌ Error uploading file to Cloudinary: {str(e)}")
+            logger.error(f"📁 Failed file path: {file_path}")
             raise e
     
     def delete_file(self, public_id: str, resource_type: str = "image") -> bool: