[pull] mega from letscontrolit:mega

docs/source/Plugin/P000_commands.repl

@@ -469,10 +469,16 @@
     "
     Publish","
     :green:`Rules`","
-    Send command using MQTT broker service. Uses the first enabled MQTT Controller.
+    Send command using MQTT broker service. The 'Will Retain' option as configured in the MQTT Controller settings is used. Uses the first enabled MQTT Controller.
 
     ``Publish,<topic>[,<payload>]``"
     "
+    PublishR","
+    :green:`Rules`","
+    Send command using MQTT broker service, with the MQTT 'Will Retain' flag enabled. Uses the first enabled MQTT Controller.
+
+    ``PublishR,<topic>[,<payload>]``"
+    "
     PutToHTTP","
     :green:`Rules`","
     *Syntax format 1:*

docs/source/Rules/Rules.rst

@@ -2020,14 +2020,14 @@ Added 2024/02/05
 
 * Examples:
 
-  Single channel: ``"sendtohttp,api.thingspeak.com,80,channels/1637928/fields/1.csv?end=2024-01-01%2023:59:00&results=1``
-    => gets the value of field 1 at (or the last entry before) 23:59:00 of the channel 1637928
+  Single channel: ``SendToHTTP,api.thingspeak.com,80,channels/143789/fields/1.csv?end=2024-01-01%2023:59:00&results=1``
+    => gets the value of field 1 at (or the last entry before) 23:59:00 of the channel 143789
 
-  All channels: ``"sendtohttp,api.thingspeak.com,80,channels/1637928/feeds.csv?end=2024-01-01%2023:59:00&results=1``
-    => gets the value of each field of the channel 1637928 at (or the last entry before) 23:59:00 
+  All channels: ``SendToHTTP,api.thingspeak.com,80,channels/143789/feeds.csv?end=2024-01-01%2023:59:00&results=1``
+    => gets the value of each field of the channel 143789 at (or the last entry before) 23:59:00 
 
   .. note::
-    ``csv`` and ``result=1`` are mandatory!
+    ``csv`` and ``results=1`` are mandatory!
 
 Convert curl POST command to PostToHTTP
 ---------------------------------------

src/src/Commands/InternalCommands.cpp

@@ -383,6 +383,7 @@ bool InternalCommands::executeInternalCommand()
     case ESPEasy_cmd_e::pulse:                      COMMAND_CASE_A(Command_GPIO_Pulse,        3);                 // GPIO.h
 #if FEATURE_MQTT
     case ESPEasy_cmd_e::publish:                    COMMAND_CASE_A(Command_MQTT_Publish,     -1);                 // MQTT.h
+    case ESPEasy_cmd_e::publishr:                   COMMAND_CASE_A(Command_MQTT_PublishR,    -1);                 // MQTT.h
 #endif // if FEATURE_MQTT
 #if FEATURE_PUT_TO_HTTP
     case ESPEasy_cmd_e::puttohttp:                  COMMAND_CASE_A(Command_HTTP_PutToHTTP,  -1);                  // HTTP.h

src/src/Commands/InternalCommands_decoder.cpp

@@ -175,6 +175,7 @@ const char Internal_commands_p[] PROGMEM =
   "pulse|"
 #if FEATURE_MQTT
   "publish|"
+  "publishr|"
 #endif // #if FEATURE_MQTT
 #if FEATURE_PUT_TO_HTTP
   "puttohttp|"

src/src/Commands/InternalCommands_decoder.h

@@ -143,6 +143,7 @@ enum class ESPEasy_cmd_e : uint8_t {
   pulse,
 #if FEATURE_MQTT
   publish,
+  publishr,
 #endif // #if FEATURE_MQTT
 #if FEATURE_PUT_TO_HTTP
   puttohttp,

src/src/Commands/MQTT.cpp

@@ -21,7 +21,15 @@
 #include "../Helpers/StringConverter.h"
 
 
-const __FlashStringHelper * Command_MQTT_Publish(struct EventStruct *event, const char *Line)
+const __FlashStringHelper* Command_MQTT_Publish(struct EventStruct *event, const char *Line) {
+  return Command_MQTT_Publish_handler(event, Line, false);
+}
+
+const __FlashStringHelper* Command_MQTT_PublishR(struct EventStruct *event, const char *Line) {
+  return Command_MQTT_Publish_handler(event, Line, true);
+}
+
+const __FlashStringHelper* Command_MQTT_Publish_handler(struct EventStruct *event, const char *Line, const bool forceRetain)
 {
   // ToDo TD-er: Not sure about this function, but at least it sends to an existing MQTTclient
   controllerIndex_t enabledMqttController = firstEnabledMQTT_ControllerIndex();
@@ -34,13 +42,13 @@ const __FlashStringHelper * Command_MQTT_Publish(struct EventStruct *event, cons
   const String topic = parseStringKeepCase(Line, 2);
   const String value = tolerantParseStringKeepCase(Line, 3);
   # ifndef BUILD_NO_DEBUG
-  addLog(LOG_LEVEL_DEBUG, concat(F("Publish: "), topic) + value);
-  #endif
+  addLog(LOG_LEVEL_DEBUG, strformat(F("Publish%c: %s:%s"), forceRetain ? 'R' : ' ', topic.c_str(), value.c_str()));
+  # endif
 
   if (!topic.isEmpty()) {
 
-    bool mqtt_retainFlag;
-    {
+    bool mqtt_retainFlag = forceRetain;
+    if (!forceRetain) {
       // Place the ControllerSettings in a scope to free the memory as soon as we got all relevant information.
       MakeControllerSettings(ControllerSettings); //-V522
       if (!AllocatedControllerSettings()) {

src/src/Commands/MQTT.h

@@ -5,11 +5,16 @@
 
 #if FEATURE_MQTT
 
-const __FlashStringHelper * Command_MQTT_Publish(struct EventStruct *event,
-                            const char         *Line);
+const __FlashStringHelper* Command_MQTT_Publish(struct EventStruct *event,
+                                                const char         *Line);
+const __FlashStringHelper* Command_MQTT_PublishR(struct EventStruct *event,
+                                                 const char         *Line);
+const __FlashStringHelper* Command_MQTT_Publish_handler(struct EventStruct *event,
+                                                        const char         *Line,
+                                                        const bool          forceRetain);
 
-const __FlashStringHelper * Command_MQTT_Subscribe(struct EventStruct *event,
-                              const char* Line);
+const __FlashStringHelper* Command_MQTT_Subscribe(struct EventStruct *event,
+                                                  const char         *Line);
 
 #endif // if FEATURE_MQTT