From d85838f46bad7d54e02fa59fd2040fb71f7cc46a Mon Sep 17 00:00:00 2001 From: Jeeva Kandasamy Date: Thu, 10 Dec 2015 04:18:51 +0530 Subject: [PATCH] realigned to maintain code structure --- .../core/MyGatewayTransportMQTTClient.cpp | 21 +++++++++---------- 1 file changed, 10 insertions(+), 11 deletions(-) diff --git a/libraries/MySensors/core/MyGatewayTransportMQTTClient.cpp b/libraries/MySensors/core/MyGatewayTransportMQTTClient.cpp index 4eb74bd..b458051 100644 --- a/libraries/MySensors/core/MyGatewayTransportMQTTClient.cpp +++ b/libraries/MySensors/core/MyGatewayTransportMQTTClient.cpp @@ -93,7 +93,7 @@ void incomingMQTT(char* topic, byte* payload, } case 3: { // Command type - command = atoi(str); + command = atoi(str); mSetCommand(_mqttMsg, command); break; } @@ -105,9 +105,8 @@ void incomingMQTT(char* topic, byte* payload, case 5: { // Sub type _mqttMsg.type = atoi(str); - - // Add payload - if (command == C_STREAM) { + // Add payload + if (command == C_STREAM) { blen = 0; uint8_t val; while (*payload) { @@ -116,14 +115,14 @@ void incomingMQTT(char* topic, byte* payload, bvalue[blen] = val; blen++; } - _mqttMsg.set(bvalue, blen); + _mqttMsg.set(bvalue, blen); } else { - char* ca; - ca = (char *) payload; - ca += length; - *ca = '\0'; - _mqttMsg.set((const char*) payload); - } + char* ca; + ca = (char *) payload; + ca += length; + *ca = '\0'; + _mqttMsg.set((const char*) payload); + } _available = true; } }