Update services/salesforce_dispatcher.py

services/salesforce_dispatcher.py

@@ -1,7 +1,7 @@
 import json
 import os
 import logging
-from datetime import datetime
+from typing import Dict, Any
 
 # Setup logging
 logging.basicConfig(
@@ -10,32 +10,13 @@ logging.basicConfig(
     format="%(asctime)s - %(levelname)s - %(message)s"
 )
 
-# Directory for Salesforce logs
-SALESFORCE_LOG_DIR = "salesforce_logs"
-os.makedirs(SALESFORCE_LOG_DIR, exist_ok=True)
-
-def dispatch_to_salesforce(detections, timestamp):
+def send_to_salesforce(payload: Dict[str, Any]) -> None:
     """
-    Dispatch detection data to Salesforce (simulated by logging to a JSON file).
+    Simulated Salesforce integration by logging to console.
     Args:
-        detections: Dict containing detection data (items, metrics, etc.)
-        timestamp: Timestamp of the detection
+        payload: Dict containing detection data (items, metrics, etc.)
     """
     try:
-        # Prepare data
-        data = {
-            "timestamp": timestamp,
-            "detections": detections["items"],
-            "metrics": detections["metrics"],
-            "frame_count": detections["frame_count"],
-            "gps_coordinates": detections["gps_coordinates"]
-        }
-
-        # Write to JSON file
-        log_file = os.path.join(SALESFORCE_LOG_DIR, f"detections_{timestamp.replace(':', '-')}.json")
-        with open(log_file, "w") as f:
-            json.dump(data, f, indent=2)
-
-        logging.info(f"Dispatched detections to Salesforce log: {log_file}")
+        logging.info(f"Salesforce Dispatch Simulated: {json.dumps(payload, indent=2)}")
     except Exception as e:
         logging.error(f"Error dispatching to Salesforce: {str(e)}")