Alerts & Notifications

CONF_IMPORT_THRESHOLD_W = "import_threshold_w"
DEFAULT_IMPORT_THRESHOLD_W = 800

CONF_EXPORT_THRESHOLD_W = "export_threshold_w"
DEFAULT_EXPORT_THRESHOLD_W = 800

CONF_DURATION_THRESHOLD_MIN = "duration_threshold_min"
DEFAULT_DURATION_THRESHOLD_MIN = 10

def should_trigger_export_alert(
    *,
    grid_export_w: int,
    export_threshold_w: int,
    export_duration_min: int,
    duration_threshold_min: int,
    export_alert_sent: bool,
) -> bool:
    """Return True when export alert should be sent now."""
    return (
        not export_alert_sent
        and grid_export_w > max(0, export_threshold_w)
        and export_duration_min >= max(1, duration_threshold_min)
    )

if should_trigger_export_alert(
    grid_export_w=export_w,
    export_threshold_w=export_threshold_w,
    export_duration_min=export_duration_min,
    duration_threshold_min=duration_threshold_min,
    export_alert_sent=self._export_alert_sent,
):
    await self.hass.services.async_call(
        "persistent_notification",
        "create",
        {
            "title": "Energy Control Pro: Prolonged Grid Export",
            "message": (
                f"Grid export is above {export_threshold_w} W for "
                f"{duration_threshold_min} minutes. "
                f"Current: {export_w} W, duration: {export_duration_min} min."
            ),
            "notification_id": "energy_control_pro_prolonged_grid_export",
        },
        blocking=False,
    )
    self._export_alert_sent = True

self._export_alert_sent = reset_export_alert_if_not_exporting(
    export_alert_sent=self._export_alert_sent,
    energy_state=energy_state,
)

def reset_export_alert_if_not_exporting(
    *,
    export_alert_sent: bool,
    energy_state: str,
) -> bool:
    """Reset export alert flag once export event ends."""
    if energy_state != ENERGY_STATE_EXPORTING:
        return False
    return export_alert_sent

def should_trigger_import_alert(
    *,
    grid_import_w: int,
    solar_w: int,
    import_threshold_w: int,
    import_alert_sent: bool,
) -> bool:
    """Return True when import-with-solar alert should be sent now."""
    return (
        not import_alert_sent
        and grid_import_w > max(0, import_threshold_w)
        and solar_w > 300
    )

import_condition = (
    import_w > max(0, import_threshold_w) and solar_w > 300
)
if should_trigger_import_alert(
    grid_import_w=import_w,
    solar_w=solar_w,
    import_threshold_w=import_threshold_w,
    import_alert_sent=self._import_alert_sent,
):
    await self.hass.services.async_call(
        "persistent_notification",
        "create",
        {
            "title": "Energy Control Pro: Importing While Solar Available",
            "message": (
                "You are importing energy while solar production is available. "
                f"Import: {import_w} W, Solar: {solar_w} W, "
                f"duration: {import_duration_min} min."
            ),
            "notification_id": "energy_control_pro_import_while_solar",
        },
        blocking=False,
    )
    self._import_alert_sent = True
if not import_condition:
    self._import_alert_sent = False

if not import_condition:
    self._import_alert_sent = False

await self._async_process_alerts(data)

self._import_start: datetime | None = None
self._export_start: datetime | None = None
self._import_alert_sent = False
self._export_alert_sent = False

await self.hass.services.async_call(
    "persistent_notification",
    "create",
    {
        "title": "...",
        "message": "...",
        "notification_id": "unique_id",
    },
    blocking=False,
)

trigger:
  - platform: event
    event_type: call_service
    event_data:
      domain: persistent_notification
      service: create
      service_data:
        notification_id: energy_control_pro_prolonged_grid_export
action:
  - service: notify.mobile_app
    data:
      title: "High Solar Export Detected"
      message: "Consider turning on additional loads to use excess solar power."

trigger:
  - platform: numeric_state
    entity_id: sensor.grid_export_power
    above: 800
    for:
      minutes: 10
condition:
  - condition: state
    entity_id: switch.pool_pump
    state: 'off'
action:
  - service: switch.turn_on
    target:
      entity_id: switch.pool_pump
  - service: notify.mobile_app
    data:
      message: "Turned on pool pump due to high solar export"

import_threshold_w: 500      # Alert when importing > 500W
export_threshold_w: 1000     # Alert when exporting > 1000W
duration_threshold_min: 15   # Require 15 minutes of continuous export