74 lines
1.8 KiB
C++
74 lines
1.8 KiB
C++
char * Concatenate(char *first, char *second) {
|
|
static char buf[30];
|
|
strcpy(buf,first);
|
|
strcat(buf,second);
|
|
return buf;
|
|
}
|
|
|
|
void ConnectMQTT() {
|
|
Serial.println("connecting MQTT...");
|
|
while (!mqtt_client.connect("brewhouse", MQTT_USER, MQTT_PASSWORD)) {
|
|
Serial.print(".");
|
|
delay(1000);
|
|
}
|
|
|
|
Serial.println("\nconnected!");
|
|
|
|
mqtt_client.subscribe(Concatenate(TOPIC_PREFIX, BK_SETPOINT_TOPIC));
|
|
}
|
|
|
|
void MessageReceived(String &topic, String &payload) {
|
|
Serial.println("incoming: " + topic + " - " + payload);
|
|
|
|
/** JSON Parser Setup */
|
|
StaticJsonDocument<200> doc;
|
|
|
|
// Deserialize the JSON document
|
|
DeserializationError error = deserializeJson(doc, payload);
|
|
|
|
// Test if parsing succeeds.
|
|
if (error) {
|
|
Serial.print(F("deserializeJson() failed: "));
|
|
Serial.println(error.f_str());
|
|
return;
|
|
}
|
|
|
|
if (topic == Concatenate(TOPIC_PREFIX, BK_SETPOINT_TOPIC)) {
|
|
// Update PWM setpoint.
|
|
String name = doc["entity"];
|
|
String setting = doc["setpoint"];
|
|
|
|
KettleDuty = setting.toInt();
|
|
String unit = doc["units"];
|
|
|
|
Serial.println("Updating setpoint for " + name + " to " + setting + " " + unit);
|
|
}
|
|
}
|
|
|
|
void SetupMQTT(char *broker) {
|
|
// Note: Local domain names (e.g. "Computer.local" on OSX) are not supported
|
|
// by Arduino. You need to set the IP address directly.
|
|
Serial.println("Setup MQTT client.");
|
|
mqtt_client.begin(broker, net);
|
|
mqtt_client.onMessage(MessageReceived);
|
|
|
|
ConnectMQTT();
|
|
}
|
|
|
|
static void SendSensorData() {
|
|
Serial.println("Sending data...");
|
|
|
|
// NOTE: max message length is 250 bytes.
|
|
StaticJsonDocument<200> doc;
|
|
|
|
doc["entity"] = "boil_kettle";
|
|
doc["setpoint"] = KettleDuty;
|
|
doc["units"] = "%";
|
|
|
|
String jstr;
|
|
serializeJson(doc, jstr);
|
|
|
|
mqtt_client.publish(Concatenate(TOPIC_PREFIX, BK_ACTUAL_TOPIC), jstr);
|
|
|
|
}
|