Mercurial > mbsePi-apps / file diff

--- a/thermferm/mqtt.c	Thu Feb 07 14:59:47 2019 +0100
+++ b/thermferm/mqtt.c	Wed Feb 27 17:38:06 2019 +0100
@@ -371,6 +371,16 @@
 					    syslog(LOG_NOTICE, "DCMD change fermenter %s: product_uuid to `%s'", message_alias, unit->product_uuid);
 					}
 				    }
+				    if (json_object_object_get_ex(setpoint, "yeast_lo", &val)) {
+					unit->yeast_lo = json_object_get_double(val);
+					unit->mqtt_flag |= MQTT_FLAG_DATA;
+					syslog(LOG_NOTICE, "DCMD change fermenter %s: yeast_lo to `%.1f'", message_alias, unit->yeast_lo);
+				    }
+				    if (json_object_object_get_ex(setpoint, "yeast_hi", &val)) {
+					unit->yeast_hi = json_object_get_double(val);
+					unit->mqtt_flag |= MQTT_FLAG_DATA;
+					syslog(LOG_NOTICE, "DCMD change fermenter %s: yeast_lo to `%.1f'", message_alias, unit->yeast_hi);
+				    }
 				}
 
 				if (json_object_object_get_ex(metric, "profile", &profile)) {
@@ -687,6 +697,12 @@
 	    payload = xstrcat(payload, unit->product_name);
 	    payload = xstrcat(payload, (char *)"\"");
 	}
+	sprintf(buf, "%.1f", unit->yeast_lo);
+	payload = xstrcat(payload, (char *)",\"yeast_lo\":");
+	payload = xstrcat(payload, buf);
+	sprintf(buf, "%.1f", unit->yeast_hi);
+	payload = xstrcat(payload, (char *)",\"yeast_hi\":");
+	payload = xstrcat(payload, buf);
     	payload = xstrcat(payload, (char *)"}");
     }