diff -r d694abd9d809 -r 7032693272f1 thermferm/mqtt.c --- 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 *)"}"); }