Skip to content

Commit aca9ceb

Browse files
committed
Force _log_production to True
1 parent 1fc1280 commit aca9ceb

File tree

1 file changed

+14
-2
lines changed

1 file changed

+14
-2
lines changed

plugwise_usb/nodes/helpers/pulses.py

Lines changed: 14 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,7 @@ def __init__(self, mac: str) -> None:
8888

8989
self._logs: dict[int, dict[int, PulseLogRecord]] | None = None
9090
self._log_addresses_missing: list[int] | None = None
91-
self._log_production: bool | None = None
91+
self._log_production = True # : bool | None = None
9292
self._pulses_consumption: int | None = None
9393
self._pulses_production: int | None = None
9494
self._pulses_timestamp: datetime | None = None
@@ -373,7 +373,19 @@ def add_log(
373373
import_only: bool = False,
374374
) -> bool:
375375
"""Store pulse log."""
376-
log_record = PulseLogRecord(timestamp, pulses, CONSUMED)
376+
_LOGGER.debug(
377+
"add_log | address=%s | slot=%s | timestamp=%s | pulses=%s | import_only=%s",
378+
address,
379+
slot,
380+
timestamp,
381+
pulses,
382+
import_only,
383+
)
384+
direction = CONSUMED
385+
if pulses < 0:
386+
direction = PRODUCED
387+
388+
log_record = PulseLogRecord(timestamp, pulses, direction)
377389
if not self._add_log_record(address, slot, log_record):
378390
if not self._log_exists(address, slot):
379391
return False

0 commit comments

Comments
 (0)