Update app.py

app.py

@@ -6,11 +6,13 @@ import numpy as np
 from simple_salesforce import Salesforce
 import time
 
+# Salesforce connection details (replace these with your actual credentials)
+sf = Salesforce(username='prashanth@safetyanaluzer.com', password='SaiPrash461', security_token='MOA3BXBfGyqnjBneog8a9IcGw')
+
 # Test Salesforce connection
 try:
-    sf = Salesforce(username='prashanth@safetyanaluzer.com', password='SaiPrash461', security_token='MOA3BXBfGyqnjBneog8a9IcGw')
     # Simple query to verify the connection
-    result = sf.query("SELECT Id FROM Safety_Video_Reports__c LIMIT 1")
+    result = sf.query("SELECT Id FROM Safety_Video_Report__c LIMIT 1")
     print("✅ Salesforce connection successful.")
 except Exception as e:
     print(f"❌ Error connecting to Salesforce: {e}")
@@ -173,7 +175,7 @@ def send_to_salesforce(violations, score, video_path):
 
     try:
         print(f"Creating Salesforce record with data: {data}")  # Log data being sent to Salesforce
-        result = sf.Safety_Video_Reports__c.create(data)
+        result = sf.Safety_Video_Report__c.create(data)  # Changed the object name to Safety_Video_Report__c
         print(f"✅ Successfully created new report in Salesforce with ID: {result['id']}")
     except Exception as e:
         print(f"❌ Error creating/updating record in Salesforce: {e}")