From 90d03ca77f73ad85d4fbdb2e55e9ec2e3df54ee0 Mon Sep 17 00:00:00 2001
From: Gunnar Skjold <gunnar@origin.no>
Date: Tue, 16 Mar 2021 11:44:01 +0100
Subject: [PATCH] Retain flag for prices

---
 src/mqtt/RawMqttHandler.cpp | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git a/src/mqtt/RawMqttHandler.cpp b/src/mqtt/RawMqttHandler.cpp
index 69d9902f..b4a289c6 100644
--- a/src/mqtt/RawMqttHandler.cpp
+++ b/src/mqtt/RawMqttHandler.cpp
@@ -155,29 +155,29 @@ bool RawMqttHandler::publishPrices(EntsoeApi* eapi) {
     for(int i = 0; i < 24; i++) {
         float val = values[i];
         if(val == ENTSOE_NO_VALUE) {
-            mqtt->publish(topic + "/price/" + String(i), "");
+            mqtt->publish(topic + "/price/" + String(i), "", true, 0);
             break;
         } else {
-            mqtt->publish(topic + "/price/" + String(i), String(val, 4));
+            mqtt->publish(topic + "/price/" + String(i), String(val, 4), true, 0);
         }
         mqtt->loop();
         delay(10);
     }
     if(min != INT16_MAX) {
-        mqtt->publish(topic + "/price/min", String(min, 4));
+        mqtt->publish(topic + "/price/min", String(min, 4), true, 0);
     }
     if(max != INT16_MIN) {
-        mqtt->publish(topic + "/price/max", String(max, 4));
+        mqtt->publish(topic + "/price/max", String(max, 4), true, 0);
     }
 
     if(min1hrIdx != -1) {
-        mqtt->publish(topic + "/price/cheapest/1hr", String(ts1hr));
+        mqtt->publish(topic + "/price/cheapest/1hr", String(ts1hr), true, 0);
     }
     if(min3hrIdx != -1) {
-        mqtt->publish(topic + "/price/cheapest/3hr", String(ts3hr));
+        mqtt->publish(topic + "/price/cheapest/3hr", String(ts3hr), true, 0);
     }
     if(min6hrIdx != -1) {
-        mqtt->publish(topic + "/price/cheapest/6hr", String(ts6hr));
+        mqtt->publish(topic + "/price/cheapest/6hr", String(ts6hr), true, 0);
     }
     return true;
 }
@@ -186,7 +186,7 @@ bool RawMqttHandler::publishSystem(HwTools* hw) {
 	if(topic.isEmpty() || !mqtt->connected())
 		return false;
 
-	mqtt->publish(topic + "/id", WiFi.macAddress());
+	mqtt->publish(topic + "/id", WiFi.macAddress(), true, 0);
 	mqtt->publish(topic + "/uptime", String((unsigned long) millis64()/1000));
 	float vcc = hw->getVcc();
 	if(vcc > 0) {