diff --git a/main/ZactuatorFASTLED.ino b/main/ZactuatorFASTLED.ino index aa3b56fc..8de92124 100644 --- a/main/ZactuatorFASTLED.ino +++ b/main/ZactuatorFASTLED.ino @@ -132,7 +132,7 @@ void MQTTtoFASTLEDJSON(char *topicOri, JsonObject& jsonData) - if (strstr(topicOri,catToMainTopic(subjectMQTTtoFASTLEDsetled)) != NULL) + if (strstr(topicOri,(char *)catToMainTopic(subjectMQTTtoFASTLEDsetled).c_str()) != NULL) { trc(F("JSON parsed")); int ledNr = jsonData["led"]; @@ -160,7 +160,7 @@ void MQTTtoFASTLED(char *topicOri, char *datacallback) currentLEDState = GENERAL; long number = 0; trc(topicOri); - if (strstr(topicOri,catToMainTopic(subjectMQTTtoFASTLED)) != NULL) + if (strstr(topicOri,(char *)catToMainTopic(subjectMQTTtoFASTLED).c_str()) != NULL) { number = (long)strtol(&datacallback[1], NULL, 16); trc(number); @@ -170,14 +170,14 @@ void MQTTtoFASTLED(char *topicOri, char *datacallback) } FastLED.show(); } - else if (strstr(topicOri,catToMainTopic(subjectMQTTtoFASTLEDsetbrightness)) != NULL) + else if (strstr(topicOri,(char *)catToMainTopic(subjectMQTTtoFASTLEDsetbrightness).c_str()) != NULL) { number = (long)strtol(&datacallback[1], NULL, 16); trc(number); FastLED.setBrightness(number); FastLED.show(); } - else if (strstr(topicOri,catToMainTopic(subjectMQTTtoFASTLEDsetanimation)) != NULL) + else if (strstr(topicOri,(char *)catToMainTopic(subjectMQTTtoFASTLEDsetanimation).c_str()) != NULL) { String payload = datacallback; trc(payload); diff --git a/main/ZactuatorONOFF.ino b/main/ZactuatorONOFF.ino index 80d6796e..c8637ed0 100644 --- a/main/ZactuatorONOFF.ino +++ b/main/ZactuatorONOFF.ino @@ -33,7 +33,7 @@ #ifdef jsonReceiving void MQTTtoONOFF(char * topicOri, JsonObject& ONOFFdata){ - if (strstr(topicOri,catToMainTopic(subjectMQTTtoONOFF)) != NULL){ + if (strstr(topicOri,(char *)catToMainTopic(subjectMQTTtoONOFF).c_str()) != NULL){ trc(F("MQTTtoONOFF json data analysis")); int boolSWITCHTYPE = ONOFFdata["state"] | 99; int pin = ONOFFdata["pin"] | ACTUATOR_ONOFF_PIN; @@ -55,7 +55,7 @@ void MQTTtoONOFF(char * topicOri, JsonObject& ONOFFdata){ #ifdef simpleReceiving void MQTTtoONOFF(char * topicOri, char * datacallback) { - if ((strstr(topicOri,catToMainTopic(subjectMQTTtoONOFF)) != NULL) ){ + if ((strstr(topicOri,(char *)catToMainTopic(subjectMQTTtoONOFF).c_str()) != NULL) ){ trc(F("MQTTtoONOFF")); int pin = strtol(datacallback, NULL, 10); // we will not be able to pass values > 4294967295 diff --git a/main/Zgateway2G.ino b/main/Zgateway2G.ino index 6bdc26c1..da5b6020 100644 --- a/main/Zgateway2G.ino +++ b/main/Zgateway2G.ino @@ -107,7 +107,7 @@ bool _2GtoMQTT(){ String data = datacallback; String topic = topicOri; - if (strstr(topicOri,catToMainTopic(subjectMQTTto2G)) != NULL) { + if (strstr(topicOri,(char *)catToMainTopic(subjectMQTTto2G).c_str()) != NULL) { trc(F("MQTTto2G data analysis")); // 2G DATA ANALYSIS String phone_number = ""; @@ -138,7 +138,7 @@ bool _2GtoMQTT(){ #ifdef jsonReceiving void MQTTto2G(char * topicOri, JsonObject& SMSdata) { - if (strstr(topicOri,catToMainTopic(subjectMQTTto2G)) != NULL){ + if (strstr(topicOri,(char *)catToMainTopic(subjectMQTTto2G).c_str()) != NULL){ const char * sms = SMSdata["message"]; const char * phone = SMSdata["phone"]; trc(F("MQTTto2G json data analysis")); diff --git a/main/ZgatewayBT.ino b/main/ZgatewayBT.ino index 52800d79..5c150aa3 100644 --- a/main/ZgatewayBT.ino +++ b/main/ZgatewayBT.ino @@ -1044,7 +1044,7 @@ void haRoomPresence(JsonObject& HomePresence){ #endif void MQTTtoBT(char * topicOri, JsonObject& BTdata) { // json object decoding - if (strstr(topicOri,catToMainTopic(subjectMQTTtoBTset)) != NULL){ + if (strstr(topicOri,(char *)catToMainTopic(subjectMQTTtoBTset).c_str()) != NULL){ trc(F("MQTTtoBT json set")); // Black list & white list set diff --git a/main/ZgatewayIR.ino b/main/ZgatewayIR.ino index 44550465..f667bb96 100644 --- a/main/ZgatewayIR.ino +++ b/main/ZgatewayIR.ino @@ -274,7 +274,7 @@ void IRtoMQTT(){ #ifdef jsonReceiving void MQTTtoIR(char * topicOri, JsonObject& IRdata) { - if (strstr(topicOri,catToMainTopic(subjectMQTTtoIR)) != NULL){ + if (strstr(topicOri,(char *)catToMainTopic(subjectMQTTtoIR).c_str()) != NULL){ trc(F("MQTTtoIR json")); uint64_t data = IRdata["value"]; const char * raw = IRdata["raw"]; diff --git a/main/ZgatewayLORA.ino b/main/ZgatewayLORA.ino index ac26e6ff..d299c7dd 100644 --- a/main/ZgatewayLORA.ino +++ b/main/ZgatewayLORA.ino @@ -87,7 +87,7 @@ void LORAtoMQTT(){ #ifdef jsonReceiving void MQTTtoLORA(char * topicOri, JsonObject& LORAdata) { // json object decoding - if (strstr(topicOri,catToMainTopic(subjectMQTTtoLORA)) != NULL){ + if (strstr(topicOri,(char *)catToMainTopic(subjectMQTTtoLORA).c_str()) != NULL){ trc(F("MQTTtoLORA json")); const char * message = LORAdata["message"]; int txPower = LORAdata["txpower"]|LORA_TX_POWER; @@ -120,7 +120,7 @@ void LORAtoMQTT(){ #endif #ifdef simpleReceiving void MQTTtoLORA(char * topicOri, char * LORAdata) { // json object decoding - if (strstr(topicOri,catToMainTopic(subjectMQTTtoLORA)) != NULL){ + if (strstr(topicOri,(char *)catToMainTopic(subjectMQTTtoLORA).c_str()) != NULL){ LoRa.beginPacket(); LoRa.print(LORAdata); LoRa.endPacket(); diff --git a/main/ZgatewayPilight.ino b/main/ZgatewayPilight.ino index 60d418a6..6ffcf9fa 100644 --- a/main/ZgatewayPilight.ino +++ b/main/ZgatewayPilight.ino @@ -74,7 +74,7 @@ void MQTTtoPilight(char * topicOri, JsonObject& Pilightdata) { int result = 0; - if (strstr(topicOri,catToMainTopic(subjectMQTTtoPilight)) != NULL){ + if (strstr(topicOri,(char *)catToMainTopic(subjectMQTTtoPilight).c_str()) != NULL){ trc(F("MQTTtoPilight json data analysis")); const char * message = Pilightdata["message"]; const char * protocol = Pilightdata["protocol"]; diff --git a/main/ZgatewayRF.ino b/main/ZgatewayRF.ino index 5ad6b9e7..efd5245e 100644 --- a/main/ZgatewayRF.ino +++ b/main/ZgatewayRF.ino @@ -132,7 +132,7 @@ void MQTTtoRF(char * topicOri, char * datacallback) { trc(valueBITS); } - if ((strstr(topicOri,catToMainTopic(subjectMQTTtoRF)) != NULL) && (valuePRT == 0) && (valuePLSL == 0) && (valueBITS == 0)){ + if ((strstr(topicOri,(char *)catToMainTopic(subjectMQTTtoRF).c_str()) != NULL) && (valuePRT == 0) && (valuePLSL == 0) && (valueBITS == 0)){ trc(F("MQTTtoRF dflt")); mySwitch.setProtocol(1,350); mySwitch.send(data, 24); @@ -156,7 +156,7 @@ void MQTTtoRF(char * topicOri, char * datacallback) { #ifdef jsonReceiving void MQTTtoRF(char * topicOri, JsonObject& RFdata) { // json object decoding - if (strstr(topicOri,catToMainTopic(subjectMQTTtoRF)) != NULL){ + if (strstr(topicOri,(char *)catToMainTopic(subjectMQTTtoRF).c_str()) != NULL){ trc(F("MQTTtoRF json")); unsigned long data = RFdata["value"]; if (data != 0) { diff --git a/main/ZgatewayRF2.ino b/main/ZgatewayRF2.ino index 42e1d969..ae647886 100644 --- a/main/ZgatewayRF2.ino +++ b/main/ZgatewayRF2.ino @@ -215,7 +215,7 @@ void rf2Callback(unsigned int period, unsigned long address, unsigned long group #ifdef jsonReceiving void MQTTtoRF2(char * topicOri, JsonObject& RF2data) { // json object decoding - if (strstr(topicOri,catToMainTopic(subjectMQTTtoRF2)) != NULL){ + if (strstr(topicOri,(char *)catToMainTopic(subjectMQTTtoRF2).c_str()) != NULL){ trc(F("MQTTtoRF2 json")); int boolSWITCHTYPE = RF2data["switchType"] | 99; if (boolSWITCHTYPE != 99) { diff --git a/main/ZgatewayRFM69.ino b/main/ZgatewayRFM69.ino index 15b0b308..992b1c51 100644 --- a/main/ZgatewayRFM69.ino +++ b/main/ZgatewayRFM69.ino @@ -184,7 +184,7 @@ bool RFM69toMQTT(void) { #ifdef simpleReceiving void MQTTtoRFM69(char * topicOri, char * datacallback) { - if(strstr(topicOri,catToMainTopic(subjectMQTTtoRFM69)) != NULL){ + if(strstr(topicOri,(char *)catToMainTopic(subjectMQTTtoRFM69).c_str()) != NULL){ trc(F("MQTTtoRFM69 data analysis")); char data[RF69_MAX_DATA_LEN+1]; memcpy(data, (void *)datacallback, RF69_MAX_DATA_LEN); @@ -215,7 +215,7 @@ bool RFM69toMQTT(void) { #ifdef jsonReceiving void MQTTtoRFM69(char * topicOri, JsonObject& RFM69data) { - if (strstr(topicOri,catToMainTopic(subjectMQTTtoRFM69)) != NULL){ + if (strstr(topicOri,(char *)catToMainTopic(subjectMQTTtoRFM69).c_str()) != NULL){ const char * data = RFM69data["data"]; trc(F("MQTTtoRFM69 json data analysis")); if(data){ diff --git a/main/ZgatewaySRFB.ino b/main/ZgatewaySRFB.ino index c7b134c6..bb4f6a32 100644 --- a/main/ZgatewaySRFB.ino +++ b/main/ZgatewaySRFB.ino @@ -280,7 +280,7 @@ bool _rfbToChar(byte * in, char * out) { // RF DATA ANALYSIS const char * raw = SRFBdata["raw"]; int valueRPT = SRFBdata["repeat"]|1; - if (strstr(topicOri,catToMainTopic(subjectMQTTtoSRFB)) != NULL){ + if (strstr(topicOri,(char *)catToMainTopic(subjectMQTTtoSRFB).c_str()) != NULL){ trc(F("MQTTtoSRFB json")); if (raw){ // send raw in priority when defined in the json trc(F("MQTTtoSRFB raw ok")); diff --git a/main/main.ino b/main/main.ino index 92675f00..74af11c9 100644 --- a/main/main.ino +++ b/main/main.ino @@ -428,9 +428,9 @@ void pubMQTT(String topic, unsigned long payload){ client.publish((char *)topic.c_str(),val); } -char * catToMainTopic(char * toAdd){ +String catToMainTopic(char * toAdd){ String resultTopic = String(mqtt_topic) + String(toAdd); - return (char *)resultTopic.c_str(); + return resultTopic; } void reconnect() { @@ -452,7 +452,7 @@ void reconnect() { // publish version pub(version_Topic,OMG_VERSION,will_Retain); //Subscribing to topic - if (client.subscribe(catToMainTopic(subjectMQTTtoX))) { + if (client.subscribe((char *)catToMainTopic(subjectMQTTtoX).c_str())) { #ifdef ZgatewayRF client.subscribe(subjectMultiGTWRF); // subject on which other OMG will publish, this OMG will store these msg and by the way don't republish them if they have been already published #endif @@ -1320,7 +1320,7 @@ digitalWrite(led_send, HIGH); } void MQTTtoSYS(char * topicOri, JsonObject& SYSdata) { // json object decoding - if (strstr(topicOri,catToMainTopic(subjectMQTTtoSYSset)) != NULL){ + if (strstr(topicOri,(char *)catToMainTopic(subjectMQTTtoSYSset).c_str()) != NULL){ trc(F("MQTTtoSYS json set")); #if defined(ESP8266) || defined(ESP32) if (SYSdata.containsKey("cmd")){