Wrap DSMR protocol in RFXtrx wrapper

Browse Source
This commit is contained in:
Ronald Pijnacker 2021-12-30 17:01:29 +01:00
parent d7e1f41162
commit 3eed3654d4
1 changed files with 23 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
dsmr_parser/clients/protocol.py
View File

@ -142,3 +142,26 @@ class DSMRProtocol(asyncio.Protocol):
async def wait_closed(self): async def wait_closed(self):
"""Wait until connection is closed.""" """Wait until connection is closed."""
await self._closed.wait() await self._closed.wait()
PACKETTYPE_DSMR = 0x62
SUBTYPE_P1 = 0x01
class RFXtrxDSMRProtocol(DSMRProtocol):
_data = b''
def data_received(self, data):
"""Add incoming data to buffer."""
data = self._data + data
while (len(data) > 0 and (packetlength := data[0]+1) <= len(data)):
packettype = data[1]
subtype = data[2]
if (packettype == PACKETTYPE_DSMR and subtype == SUBTYPE_P1):
dsmr_data = data[4:packetlength]
super().data_received(dsmr_data)
data = data[packetlength:]
self._data = data