neben/badesee-preprocessor
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix downlink message

Browse Source
This commit is contained in:
Wolfgang Hottgenroth 2023-01-29 00:34:22 +01:00
parent 160cefaeeb
commit a9d9597e62
Signed by: wn
GPG Key ID: 836E9E1192A6B132
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/preprocess.py
View File

@ -86,9 +86,11 @@ def mqttOnMessageCallback(client, userdata, message):
if (received_sensor_address not in sensors): if (received_sensor_address not in sensors):
raise UnknownSensorException(received_sensor_address) raise UnknownSensorException(received_sensor_address)
setupMessage = bytes() setupMessage = bytes()
null = 0
null = null.to_bytes(1, byteorder='big')
for sk, sv in sensors.items(): for sk, sv in sensors.items():
logger.debug(f"{sk=}, {sv=}") logger.debug(f"{sk=}, {sv=}")
setupMessage += struct.pack('<Q', sk) + sv[0].to_bytes(1, byteorder='big') + bytes(sv[1], 'ASCII') setupMessage += struct.pack('<Q', sk) + sv[0].to_bytes(1, byteorder='big') + bytes(sv[1], 'ASCII') + null
setupMessage = base64.b64encode(setupMessage).decode('ASCII') setupMessage = base64.b64encode(setupMessage).decode('ASCII')
logger.debug(f"about to send setup message {setupMessage}") logger.debug(f"about to send setup message {setupMessage}")
setupTopic = f"v3/{config['APPLICATION_TENANT']}/devices/{device_id}/down/push" setupTopic = f"v3/{config['APPLICATION_TENANT']}/devices/{device_id}/down/push"