Update services/salesforce_dispatcher.py

services/salesforce_dispatcher.py

@@ -1,24 +1,29 @@
 # services/salesforce_dispatcher.py
-
-import requests
 import json
+import logging
 
-SALESFORCE_WEBHOOK_URL = "https://your-salesforce-instance/services/web-to-case"
+# Configure logging
+logging.basicConfig(level=logging.INFO)
+logger = logging.getLogger(__name__)
 
-def send_to_salesforce(payload):
+def dispatch_to_salesforce(detections, timestamp):
     """
-    FAKE Salesforce integration — DISABLED in HuggingFace Space demo.
-    Replace SALESFORCE_WEBHOOK_URL later with real endpoint during production setup.
+    Dispatch detection data to Salesforce.
+    Args:
+        detections: Detection dictionary
+        timestamp: Timestamp of the frame
+    Returns:
+        bool: Success status
     """
-    print("🚀 [Salesforce Dispatch Simulated] Would have sent:", payload)
-    # Commenting actual POST request to avoid Space crash
-    #
-    # alert_type = "Intrusion" if any(d["label"] == "person" for d in payload["detections"]) else "Anomaly"
-    # summary = {
-    #     "Alert_Type__c": alert_type,
-    #     "ThermalFlag__c": payload["thermal"],
-    #     "ShadowFlag__c": payload["shadow_issue"],
-    #     "Confidence_Score__c": max([d["score"] for d in payload["detections"]], default=0)
-    # }
-    # headers = {"Content-Type": "application/json"}
-    # requests.post(SALESFORCE_WEBHOOK_URL, json=summary, headers=headers)
+    try:
+        # Mock Salesforce dispatch (replace with actual Salesforce API calls)
+        payload = {
+            "timestamp": timestamp,
+            "detections": detections
+        }
+        logger.info(f"Dispatching to Salesforce: {json.dumps(payload, indent=2)}")
+        # Example: Use simple_salesforce or requests to send data to Salesforce
+        return True
+    except Exception as e:
+        logger.error(f"Failed to dispatch to Salesforce: {str(e)}")
+        return False