FIX: Correct bulk API usage for insert/update operations

app.py

@@ -54,22 +54,19 @@ def salesforce_data_loader(username, password, security_token, sandbox, operatio
                 # Determine object based on columns (simple heuristic)
                 columns = df.columns.str.lower()
                 if any(col in columns for col in ['firstname', 'lastname', 'email']):
-                    sf_object = sf_connection.Contact
                     object_name = "Contact"
                 elif any(col in columns for col in ['company', 'name']):
-                    sf_object = sf_connection.Account  
                     object_name = "Account"
                 else:
-                    sf_object = sf_connection.Lead
                     object_name = "Lead"
                 
-                # Perform operation
+                # Perform operation using bulk API correctly
                 if operation == "insert":
-                    result = sf_object.bulk.insert(cleaned_records)
+                    result = sf_connection.bulk.__getattr__(object_name).insert(cleaned_records)
                 elif operation == "update":
-                    result = sf_object.bulk.update(cleaned_records)
+                    result = sf_connection.bulk.__getattr__(object_name).update(cleaned_records)
                 else:
-                    return connection_msg + "❌ Invalid operation"
+                    return connection_msg + "❌ Invalid operation. Use 'insert' or 'update'"
                 
                 # Process results
                 success_count = sum(1 for r in result if r.get('success'))