Only reset requested utility meter with no tariff (#115170)

pull/115186/head
gibwar 2024-04-08 02:05:46 -06:00 committed by Franck Nijhof
parent 9a342f87c0
commit 8c0b44d6d5
No known key found for this signature in database
GPG Key ID: D62583BA8AB11CA3
2 changed files with 140 additions and 1 deletions

View File

@ -578,7 +578,13 @@ class UtilityMeterSensor(RestoreSensor):
async def async_reset_meter(self, entity_id):
"""Reset meter."""
if self._tariff is not None and self._tariff_entity != entity_id:
if self._tariff_entity is not None and self._tariff_entity != entity_id:
return
if (
self._tariff_entity is None
and entity_id is not None
and self.entity_id != entity_id
):
return
_LOGGER.debug("Reset utility meter <%s>", self.entity_id)
self._last_reset = dt_util.utcnow()

View File

@ -983,6 +983,139 @@ async def test_service_reset_no_tariffs(
assert state.attributes.get("last_period") == "3"
@pytest.mark.parametrize(
("yaml_config", "config_entry_configs"),
[
(
{
"utility_meter": {
"energy_bill": {
"source": "sensor.energy",
},
"water_bill": {
"source": "sensor.water",
},
},
},
None,
),
(
None,
[
{
"cycle": "none",
"delta_values": False,
"name": "Energy bill",
"net_consumption": False,
"offset": 0,
"periodically_resetting": True,
"source": "sensor.energy",
"tariffs": [],
},
{
"cycle": "none",
"delta_values": False,
"name": "Water bill",
"net_consumption": False,
"offset": 0,
"periodically_resetting": True,
"source": "sensor.water",
"tariffs": [],
},
],
),
],
)
async def test_service_reset_no_tariffs_correct_with_multi(
hass: HomeAssistant, yaml_config, config_entry_configs
) -> None:
"""Test complex utility sensor service reset for multiple sensors with no tarrifs.
See GitHub issue #114864: Service "utility_meter.reset" affects all meters.
"""
# Home assistant is not runnit yet
hass.state = CoreState.not_running
last_reset = "2023-10-01T00:00:00+00:00"
mock_restore_cache_with_extra_data(
hass,
[
(
State(
"sensor.energy_bill",
"3",
attributes={
ATTR_LAST_RESET: last_reset,
},
),
{},
),
(
State(
"sensor.water_bill",
"6",
attributes={
ATTR_LAST_RESET: last_reset,
},
),
{},
),
],
)
if yaml_config:
assert await async_setup_component(hass, DOMAIN, yaml_config)
await hass.async_block_till_done()
else:
for entry in config_entry_configs:
config_entry = MockConfigEntry(
data={},
domain=DOMAIN,
options=entry,
title=entry["name"],
)
config_entry.add_to_hass(hass)
assert await hass.config_entries.async_setup(config_entry.entry_id)
await hass.async_block_till_done()
state = hass.states.get("sensor.energy_bill")
assert state
assert state.state == "3"
assert state.attributes.get("last_reset") == last_reset
assert state.attributes.get("last_period") == "0"
state = hass.states.get("sensor.water_bill")
assert state
assert state.state == "6"
assert state.attributes.get("last_reset") == last_reset
assert state.attributes.get("last_period") == "0"
now = dt_util.utcnow()
with freeze_time(now):
await hass.services.async_call(
domain=DOMAIN,
service=SERVICE_RESET,
service_data={},
target={"entity_id": "sensor.energy_bill"},
blocking=True,
)
await hass.async_block_till_done()
state = hass.states.get("sensor.energy_bill")
assert state
assert state.state == "0"
assert state.attributes.get("last_reset") == now.isoformat()
assert state.attributes.get("last_period") == "3"
state = hass.states.get("sensor.water_bill")
assert state
assert state.state == "6"
assert state.attributes.get("last_reset") == last_reset
assert state.attributes.get("last_period") == "0"
@pytest.mark.parametrize(
("yaml_config", "config_entry_config"),
[