Create MISO grid alert parser (#8173)

* Update US_MISO.py

* delete target_datetime and sourceType

* include date_time in parser parameters

* Update US_MISO.py

Author: alejandranavcas

config/zones/US-MIDW-MISO.yaml

@@ -932,6 +932,7 @@ parsers:
   production: EIA.fetch_production_mix
   productionCapacity: EIA.fetch_production_capacity
   productionPerModeForecast: US_MISO.fetch_wind_solar_forecasts
+  gridAlerts: US_MISO.fetch_grid_alerts
 region: Americas
 sources:
   INCER ACV:

parsers/US_MISO.py

@@ -14,10 +14,15 @@
 
 from electricitymap.contrib.config import ZoneKey
 from electricitymap.contrib.lib.models.event_lists import (
+    GridAlertList,
     ProductionBreakdownList,
     TotalConsumptionList,
 )
-from electricitymap.contrib.lib.models.events import EventSourceType, ProductionMix
+from electricitymap.contrib.lib.models.events import (
+    EventSourceType,
+    GridAlertType,
+    ProductionMix,
+)
 
 SOURCE = "misoenergy.org"
 ZONE = "US-MIDW-MISO"
@@ -217,11 +222,70 @@ def fetch_wind_solar_forecasts(
     return production_breakdowns.to_list()
 
 
+def fetch_grid_alerts(
+    zone_key: ZoneKey = ZoneKey(ZONE),
+    session: Session | None = None,
+    target_datetime: datetime | None = None,
+    logger: Logger = getLogger(__name__),
+) -> list[dict[str, Any]]:
+    """Fetch Grid Alerts from MISO"""
+    session = session or Session()
+
+    # API URL
+    url = "https://www.misoenergy.org/api/topicnotifications/getrecentnotifications"
+
+    # Request payload (can be adjusted if you want specific filters)
+    payload = {"topics": ["RealTime"], "take": 0}  # take 0 is equal to get all possible
+    # TODO: do we just need the last one?
+
+    # Request headers
+    headers = {
+        "Content-Type": "application/json",
+        "Accept": "application/json",
+        "User-Agent": "Mozilla/5.0",
+        "Referer": "https://www.misoenergy.org/markets-and-operations/notifications/real-time-operations-notifications/",
+        "X-Requested-With": "XMLHttpRequest",
+    }
+
+    # Make the POST request
+    response = session.post(url, json=payload, headers=headers)
+
+    # Check for success
+    if response.status_code == 200:
+        notifications = response.json()
+
+    # TODO: maybe extract locationRegion from each notification?
+    # TODO: maybe extract startTime and endTime from each notification?
+    # TODO: maybe extract alertType from each notification?
+
+    # Record events in grid_alert_list
+    grid_alert_list = GridAlertList(logger)
+    for notification in notifications:
+        publish_datetime = datetime.fromisoformat(
+            notification["publishDateUnformatted"]
+        )  # in UTC
+        grid_alert_list.append(
+            zoneKey=zone_key,
+            locationRegion=None,
+            source=SOURCE,
+            alertType=GridAlertType.undefined,
+            message=notification["subject"] + "\n" + notification["body"],
+            issuedTime=publish_datetime,
+            startTime=None,  # if None, it defaults to issuedTime
+            endTime=None,
+        )
+    return grid_alert_list.to_list()
+
+
 if __name__ == "__main__":
-    # print("fetch_production() ->")
-    # print(fetch_production())
+    from pprint import pprint
+
+    print("fetch_production() ->")
+    print(fetch_production())
 
     print(fetch_consumption_forecast())
 
-    # print("fetch_wind_solar_forecasts() ->")
-    # print(fetch_wind_solar_forecasts())
+    print("fetch_wind_solar_forecasts() ->")
+    print(fetch_wind_solar_forecasts())
+
+    pprint(fetch_grid_alerts())