Update services/salesforce_dispatcher.py

services/salesforce_dispatcher.py

@@ -1,29 +1,41 @@
-# services/salesforce_dispatcher.py
 import json
+import os
 import logging
+from datetime import datetime
 
-# Configure logging
-logging.basicConfig(level=logging.INFO)
-logger = logging.getLogger(__name__)
+# Setup logging
+logging.basicConfig(
+    filename="app.log",
+    level=logging.INFO,
+    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):
     """
-    Dispatch detection data to Salesforce.
+    Dispatch detection data to Salesforce (simulated by logging to a JSON file).
     Args:
-        detections: Detection dictionary
-        timestamp: Timestamp of the frame
-    Returns:
-        bool: Success status
+        detections: Dict containing detection data (items, metrics, etc.)
+        timestamp: Timestamp of the detection
     """
     try:
-        # Mock Salesforce dispatch (replace with actual Salesforce API calls)
-        payload = {
+        # Prepare data
+        data = {
             "timestamp": timestamp,
-            "detections": detections
+            "detections": detections["items"],
+            "metrics": detections["metrics"],
+            "frame_count": detections["frame_count"],
+            "gps_coordinates": detections["gps_coordinates"]
         }
-        logger.info(f"Dispatching to Salesforce: {json.dumps(payload, indent=2)}")
-        # Example: Use simple_salesforce or requests to send data to Salesforce
-        return True
+
+        # 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}")
     except Exception as e:
-        logger.error(f"Failed to dispatch to Salesforce: {str(e)}")
-        return False
+        logging.error(f"Error dispatching to Salesforce: {str(e)}")