jeans/core
jeans/core
1
0
Fork 0
mirror of https://github.com/home-assistant/core.git synced 2025-07-17 10:17:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

Discard outdated data reported by AEMET stations (#48417)

Browse Source 
* aemet: achieve 100% test coverage

Signed-off-by: Álvaro Fernández Rojas <noltari@gmail.com>

* aemet: discard outdated station data

Signed-off-by: Álvaro Fernández Rojas <noltari@gmail.com>

* aemet: fix AemetSensor/AemetForecastSensor inheritance

AbstractAemetSensor already inherits SensorEntity.

Signed-off-by: Álvaro Fernández Rojas <noltari@gmail.com>
This commit is contained in:
Álvaro Fernández Rojas 2021-03-27 22:33:24 +01:00 committed by GitHub
parent 051f29f9b6
commit 23d7330a2f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 31 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
homeassistant/components/aemet/sensor.py
View File

@ -1,6 +1,4 @@
"""Support for the AEMET OpenData service.""" """Support for the AEMET OpenData service."""
from homeassistant.components.sensor import SensorEntity
from .abstract_aemet_sensor import AbstractAemetSensor from .abstract_aemet_sensor import AbstractAemetSensor
from .const import ( from .const import (
DOMAIN, DOMAIN,
@ -58,7 +56,7 @@ async def async_setup_entry(hass, config_entry, async_add_entities):
async_add_entities(entities) async_add_entities(entities)
class AemetSensor(AbstractAemetSensor, SensorEntity): class AemetSensor(AbstractAemetSensor):
"""Implementation of an AEMET OpenData sensor.""" """Implementation of an AEMET OpenData sensor."""
def __init__( def __init__(
@ -81,7 +79,7 @@ class AemetSensor(AbstractAemetSensor, SensorEntity):
return self._weather_coordinator.data.get(self._sensor_type) return self._weather_coordinator.data.get(self._sensor_type)
class AemetForecastSensor(AbstractAemetSensor, SensorEntity): class AemetForecastSensor(AbstractAemetSensor):
"""Implementation of an AEMET OpenData forecast sensor.""" """Implementation of an AEMET OpenData forecast sensor."""
def __init__( def __init__(
@ -108,9 +106,10 @@ class AemetForecastSensor(AbstractAemetSensor, SensorEntity):
@property @property
def state(self): def state(self):
"""Return the state of the device.""" """Return the state of the device."""
forecast = None
forecasts = self._weather_coordinator.data.get( forecasts = self._weather_coordinator.data.get(
FORECAST_MODE_ATTR_API[self._forecast_mode] FORECAST_MODE_ATTR_API[self._forecast_mode]
) )
if forecasts: if forecasts:
return forecasts[0].get(self._sensor_type) forecast = forecasts[0].get(self._sensor_type)
return None return forecast

39
homeassistant/components/aemet/weather_update_coordinator.py
View File

@ -82,6 +82,7 @@ from .const import (
_LOGGER = logging.getLogger(__name__) _LOGGER = logging.getLogger(__name__)
STATION_MAX_DELTA = timedelta(hours=2)
WEATHER_UPDATE_INTERVAL = timedelta(minutes=10) WEATHER_UPDATE_INTERVAL = timedelta(minutes=10)
@ -241,6 +242,7 @@ class WeatherUpdateCoordinator(DataUpdateCoordinator):
weather_response.hourly[ATTR_DATA][0][AEMET_ATTR_ELABORATED] weather_response.hourly[ATTR_DATA][0][AEMET_ATTR_ELABORATED]
) )
now = dt_util.now() now = dt_util.now()
now_utc = dt_util.utcnow()
hour = now.hour hour = now.hour
# Get current day # Get current day
@ -253,10 +255,18 @@ class WeatherUpdateCoordinator(DataUpdateCoordinator):
day = cur_day day = cur_day
break break
# Get station data # Get latest station data
station_data = None station_data = None
station_dt = None
if weather_response.station: if weather_response.station:
station_data = weather_response.station[ATTR_DATA][-1] for _station_data in weather_response.station[ATTR_DATA]:
if AEMET_ATTR_STATION_DATE in _station_data:
_station_dt = dt_util.parse_datetime(
_station_data[AEMET_ATTR_STATION_DATE] + "Z"
)
if not station_dt or _station_dt > station_dt:
station_data = _station_data
station_dt = _station_dt
condition = None condition = None
humidity = None humidity = None
@ -299,17 +309,20 @@ class WeatherUpdateCoordinator(DataUpdateCoordinator):
# Overwrite weather values with closest station data (if present) # Overwrite weather values with closest station data (if present)
if station_data: if station_data:
if AEMET_ATTR_STATION_DATE in station_data: station_timestamp = dt_util.as_utc(station_dt).isoformat()
station_dt = dt_util.parse_datetime( if (now_utc - station_dt) <= STATION_MAX_DELTA:
station_data[AEMET_ATTR_STATION_DATE] + "Z" if AEMET_ATTR_STATION_HUMIDITY in station_data:
) humidity = format_float(station_data[AEMET_ATTR_STATION_HUMIDITY])
station_timestamp = dt_util.as_utc(station_dt).isoformat() if AEMET_ATTR_STATION_PRESSURE_SEA in station_data:
if AEMET_ATTR_STATION_HUMIDITY in station_data: pressure = format_float(
humidity = format_float(station_data[AEMET_ATTR_STATION_HUMIDITY]) station_data[AEMET_ATTR_STATION_PRESSURE_SEA]
if AEMET_ATTR_STATION_PRESSURE_SEA in station_data: )
pressure = format_float(station_data[AEMET_ATTR_STATION_PRESSURE_SEA]) if AEMET_ATTR_STATION_TEMPERATURE in station_data:
if AEMET_ATTR_STATION_TEMPERATURE in station_data: temperature = format_float(
temperature = format_float(station_data[AEMET_ATTR_STATION_TEMPERATURE]) station_data[AEMET_ATTR_STATION_TEMPERATURE]
)
else:
_LOGGER.warning("Station data is outdated")
# Get forecast from weather data # Get forecast from weather data
forecast_daily = self._get_daily_forecast_from_weather_response( forecast_daily = self._get_daily_forecast_from_weather_response(