Skip to content

Commit 0cf957e

Browse files
committed
Fix test-assert
1 parent f3ee249 commit 0cf957e

File tree

2 files changed

+27
-30
lines changed

2 files changed

+27
-30
lines changed

plugwise_usb/nodes/helpers/pulses.py

Lines changed: 26 additions & 29 deletions
Original file line numberDiff line numberDiff line change
@@ -184,40 +184,37 @@ def collected_pulses(
184184
log_pulses = result[0]
185185
reset = result[1]
186186
pulses: int | None = None
187-
timestamp: datetime | None = None
188-
if is_consumption and self._pulses_consumption is not None:
189-
timestamp = self._pulses_timestamp
190-
if from_timestamp != timestamp:
191-
if is_consumption and self._pulses_consumption is not None:
192-
pulses = self._pulses_consumption
193-
timestamp = self._pulses_timestamp
194-
if not is_consumption and self._pulses_production is not None:
195-
pulses = self._pulses_production
196-
timestamp = self._pulses_timestamp
197-
198-
if pulses is None:
199-
_LOGGER.debug(
200-
"collected_pulses | %s | is_consumption=%s, pulses=None",
201-
self._mac,
202-
is_consumption,
203-
)
204-
return (None, None)
205-
187+
timestamp = self._pulses_timestamp
188+
if from_timestamp != timestamp:
189+
if is_consumption and self._pulses_consumption is not None:
190+
pulses = self._pulses_consumption
191+
timestamp = self._pulses_timestamp
192+
if not is_consumption and self._pulses_production is not None:
193+
pulses = self._pulses_production
194+
timestamp = self._pulses_timestamp
195+
196+
if pulses is None:
206197
_LOGGER.debug(
207-
"collected_pulses | pulses=%s | log_pulses=%s | consumption=%s from %s to %s",
208-
pulses,
209-
log_pulses,
198+
"collected_pulses | %s | is_consumption=%s, pulses=None",
199+
self._mac,
210200
is_consumption,
211-
from_timestamp,
212-
timestamp,
213201
)
202+
return (None, None)
214203

215-
# Always return positive values of energy_statistics
216-
return (abs(pulses + log_pulses), timestamp)
204+
_LOGGER.debug(
205+
"collected_pulses | pulses=%s | log_pulses=%s | consumption=%s from %s to %s",
206+
pulses,
207+
log_pulses,
208+
is_consumption,
209+
from_timestamp,
210+
timestamp,
211+
)
217212

218-
delta_cons_pulses: int = 0
219-
delta_prod_pulses: int = 0
220-
delta_cons_pulses = self._pulses_consumption - self._prev_pulses_consumption
213+
delta_cons_pulses: int = 0
214+
delta_prod_pulses: int = 0
215+
delta_cons_pulses = self._pulses_consumption - self._prev_pulses_consumption
216+
if is_consumption and self._pulses_consumption is not None:
217+
timestamp = self._pulses_timestamp
221218
pulses = self._prev_pulses_consumption + delta_cons_pulses
222219
self._prev_pulses_consumption = pulses
223220
self._prev_timestamp = timestamp

tests/test_usb.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1145,7 +1145,7 @@ def test_pulse_collection_consumption(
11451145
assert tst_consumption.log_rollover
11461146
assert tst_consumption.collected_pulses(
11471147
fixed_this_hour, is_consumption=True
1148-
) == (45+ 2222 + 3333, pulse_update_3)
1148+
) == (45+ 2222 + 3333, test_timestamp)
11491149
pulse_update_4 = fixed_this_hour + td(hours=2, seconds=10)
11501150
tst_consumption.update_pulse_counter(321, 0, pulse_update_4)
11511151
assert not tst_consumption.log_rollover

0 commit comments

Comments
 (0)