Skip to content

Commit 510a226

Browse files
committed
Use new JSON command payload format.
1 parent e881df4 commit 510a226

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

myDevices/cloud/cayennemqtt.py

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -159,10 +159,11 @@ def message_callback(self, client, userdata, msg):
159159
"""
160160
try:
161161
message = {}
162-
if msg.topic[-len(COMMAND_JSON_TOPIC):] == COMMAND_JSON_TOPIC:
163-
message['payload'] = loads(msg.payload.decode())
164-
message['cmdId'] = message['payload']['cmdId']
165-
channel = message['payload']['channel'].split('/')[-1].split(';')
162+
if msg.topic[-len(COMMAND_JSON_TOPIC):] == COMMAND_JSON_TOPIC:
163+
payload = loads(msg.payload.decode())
164+
message['payload'] = payload['value']
165+
message['cmdId'] = payload['cmdId']
166+
channel = payload['channel'].split('/')[-1].split(';')
166167
else:
167168
payload = msg.payload.decode().split(',')
168169
if len(payload) > 1:

0 commit comments

Comments
 (0)