fixed light subscription

This commit is contained in:
Sebastian 2020-07-06 12:41:14 +02:00
parent 5fb882c59a
commit 62bf9a17c5

View File

@ -10,7 +10,7 @@ extern "C" {
#define MQTT_VALVE_COMMAND MQTT_TOPIC_BASE_SUB "/" MQTT_DEVICE_ID "/valve"
#define MQTT_SOIL_PROPERTIES MQTT_TOPIC_BASE_SUB "/" MQTT_DEVICE_ID "/soil"
#define MQTT_LIGHT_COMMAND MQTT_TOPIC_BASE_SUB "/" MQTT_DEVICE_ID "/light"
#define MQTT_LIGHT_PROPERTIES MQTT_TOPIC_BASE_SUB "/" MQTT_DEVICE_ID "/light"
TimerHandle_t mqttReconnectTimer;
TimerHandle_t wifiReconnectTimer;
@ -102,13 +102,9 @@ void onMqttMessage(char *topic, byte *payload, unsigned int payload_length) {
}
Serial.println();
if (strcmp(topic, MQTT_LIGHT_COMMAND) == 0) {
if (strcmp(topic, MQTT_LIGHT_PROPERTIES) == 0) {
Serial.println("receiving light treshold...");
Serial.println(topic);
}
if (strcmp(topic, MQTT_VALVE_COMMAND) == 0) {
Serial.println("toggling valve...");
Serial.println(topic);
StaticJsonDocument<1024> doc;
DeserializationError err = deserializeJson(doc, payload);
if (err == DeserializationError::Ok) {
@ -118,6 +114,11 @@ Serial.println("receiving light treshold...");
Serial.println(err.c_str());
}
}
if (strcmp(topic, MQTT_VALVE_COMMAND) == 0) {
Serial.println("toggling valve...");
Serial.println(topic);
toggleValve();
}
if (strcmp(topic, MQTT_SOIL_PROPERTIES) == 0) {
Serial.println("receiving soil thresholds...");
Serial.println(topic);