Update main.py

main.py

@@ -33,7 +33,7 @@ logging.basicConfig(
     format='[%(asctime)s] %(levelname)s: %(message)s',
     datefmt='%I:%M:%S %p',
     handlers=[
-        logging.FileHandler("app.log"),
+        logging.FileHandler("app.log", encoding="utf-8"),
         logging.StreamHandler()
     ]
 )
@@ -279,6 +279,12 @@ def send_event_alerts(events):
                     <td style="padding: 8px 0;">{ev.get('location', '-')}</td>
                 </tr>
 
+                <tr>
+                    <td style="padding: 8px 0; font-weight: bold;">Status</td>
+                    <td style="padding: 8px 0;">:</td>
+                    <td style="padding: 8px 0;">{ev.get('status', '-')}</td>
+                </tr>
+
                 <tr>
                     <td style="padding: 8px 0; font-weight: bold;">Logger URL</td>
                     <td style="padding: 8px 0;">:</td>
@@ -473,9 +479,9 @@ def process_tick():
         # Task 1: Load state if we just started
         if LAST_EVENT_ID is None:
             load_state()
-                
-        new_events, err = check_new_events(LAST_EVENT_ID, xsrf, bip)
-        
+
+        # FETCH ALL EVENTS FIRST (Safer architecture integration)
+        data, err = fetch_bip_events(xsrf, bip, page=1)
         if err:
             logger.error(f"Error scraping events: {err}")
             send_email_message(
@@ -489,6 +495,19 @@ def process_tick():
             logger.error("Notifier is shutting down completely because of the scraping error.")
             raise SystemExit(1)
             
+        resources = data.get("resources", [])
+        parsed_events = [parse_event(r) for r in resources] if resources else []
+        
+        # 1. Track state changes for *all* fetched events (New Feature)
+        try:
+            from event_state_tracker import track_event_changes
+            track_event_changes(parsed_events)
+        except Exception as e:
+            logger.error(f"Event state tracker failed: {e}")
+
+        # 2. Check for entirely new events (Existing Logic)
+        new_events, _ = check_new_events(LAST_EVENT_ID, xsrf, bip)
+            
         if new_events:
             # If LAST_EVENT_ID is None, it's the very first startup run. Set ID without alerting.
             if LAST_EVENT_ID is None: