channels abstraction changed

This commit is contained in:
2019-07-14 01:11:23 +03:00
parent 5540b6ae4d
commit 088a4b0397
5 changed files with 73 additions and 10 deletions

View File

@@ -31,14 +31,7 @@ int abstractIn::publish(char * value, char* subtopic)
aJsonObject *emit = aJson.getObjectItem(in->inputObj, "emit");
if (emit)
{
strncpy(addrstr,emit->valuestring,sizeof(addrstr));
if (!strchr(addrstr,'/')) setTopic(addrstr,sizeof(addrstr),T_OUT,emit->valuestring);
strncat(addrstr,subtopic,sizeof(addrstr));
if (mqttClient.connected() && lanStatus == OPERATION)
{
mqttClient.publish(addrstr, value, true);
return 1;
}
return publish(emit->valuestring,value,subtopic);
}
}
return 0;