2018-10-10 21:21:44 +01:00
/*
2019-10-27 10:13:24 +00:00
xdrv_02_mqtt . ino - mqtt support for Tasmota
2018-10-10 21:21:44 +01:00
2021-01-01 12:44:04 +00:00
Copyright ( C ) 2021 Theo Arends
2018-10-10 21:21:44 +01:00
This program is free software : you can redistribute it and / or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation , either version 3 of the License , or
( at your option ) any later version .
This program is distributed in the hope that it will be useful ,
but WITHOUT ANY WARRANTY ; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE . See the
GNU General Public License for more details .
You should have received a copy of the GNU General Public License
along with this program . If not , see < http : //www.gnu.org/licenses/>.
*/
2020-11-17 16:15:29 +00:00
# define XDRV_02 2
# ifndef MQTT_WIFI_CLIENT_TIMEOUT
# define MQTT_WIFI_CLIENT_TIMEOUT 200 // Wifi TCP connection timeout (default is 5000 mSec)
# endif
2018-10-10 21:21:44 +01:00
2019-08-04 18:42:21 +01:00
// #define DEBUG_DUMP_TLS // allow dumping of TLS Flash keys
2018-11-20 14:00:24 +00:00
# ifdef USE_MQTT_TLS
2019-06-05 10:44:52 +01:00
# include "WiFiClientSecureLightBearSSL.h"
2019-06-10 11:06:03 +01:00
BearSSL : : WiFiClientSecure_light * tlsClient ;
2018-11-20 14:00:24 +00:00
# endif
2020-08-12 16:20:37 +01:00
WiFiClient EspClient ; // Wifi Client - non-TLS
2018-11-20 14:00:24 +00:00
2019-08-11 17:12:18 +01:00
const char kMqttCommands [ ] PROGMEM = " | " // No prefix
2021-01-28 08:04:42 +00:00
// SetOption synonyms
2021-02-28 11:50:02 +00:00
D_SO_MQTTJSONONLY " | "
2021-01-28 08:04:42 +00:00
# ifdef USE_MQTT_TLS
D_SO_MQTTTLS " | "
# endif
D_SO_MQTTNORETAIN " | " D_SO_MQTTDETACHRELAY " | "
// regular commands
2019-07-28 16:14:20 +01:00
# if defined(USE_MQTT_TLS) && !defined(USE_MQTT_TLS_CA_CERT)
D_CMND_MQTTFINGERPRINT " | "
# endif
D_CMND_MQTTUSER " | " D_CMND_MQTTPASSWORD " | "
2019-08-04 18:42:21 +01:00
# if defined(USE_MQTT_TLS) && defined(USE_MQTT_AWS_IOT)
D_CMND_TLSKEY " | "
2019-07-28 16:14:20 +01:00
# endif
D_CMND_MQTTHOST " | " D_CMND_MQTTPORT " | " D_CMND_MQTTRETRY " | " D_CMND_STATETEXT " | " D_CMND_MQTTCLIENT " | "
2019-09-27 17:13:00 +01:00
D_CMND_FULLTOPIC " | " D_CMND_PREFIX " | " D_CMND_GROUPTOPIC " | " D_CMND_TOPIC " | " D_CMND_PUBLISH " | " D_CMND_MQTTLOG " | "
2021-02-22 08:11:36 +00:00
D_CMND_BUTTONTOPIC " | " D_CMND_SWITCHTOPIC " | " D_CMND_BUTTONRETAIN " | " D_CMND_SWITCHRETAIN " | " D_CMND_POWERRETAIN " | "
D_CMND_SENSORRETAIN " | " D_CMND_INFORETAIN " | " D_CMND_STATERETAIN ;
2019-08-01 14:46:12 +01:00
2021-01-28 08:04:42 +00:00
SO_SYNONYMS ( kMqttSynonyms ,
90 ,
# ifdef USE_MQTT_TLS
103 ,
# endif
104 , 114
) ;
// const uint8_t kMqttSynonyms[] PROGMEM = {
// 4, // number of synonyms
// 90, 103, 104, 114,
// };
2019-07-28 16:14:20 +01:00
void ( * const MqttCommand [ ] ) ( void ) PROGMEM = {
# if defined(USE_MQTT_TLS) && !defined(USE_MQTT_TLS_CA_CERT)
& CmndMqttFingerprint ,
# endif
& CmndMqttUser , & CmndMqttPassword ,
2019-08-04 18:42:21 +01:00
# if defined(USE_MQTT_TLS) && defined(USE_MQTT_AWS_IOT)
& CmndTlsKey ,
2019-07-28 16:14:20 +01:00
# endif
& CmndMqttHost , & CmndMqttPort , & CmndMqttRetry , & CmndStateText , & CmndMqttClient ,
2019-09-27 17:13:00 +01:00
& CmndFullTopic , & CmndPrefix , & CmndGroupTopic , & CmndTopic , & CmndPublish , & CmndMqttlog ,
2021-02-22 08:11:36 +00:00
& CmndButtonTopic , & CmndSwitchTopic , & CmndButtonRetain , & CmndSwitchRetain , & CmndPowerRetain , & CmndSensorRetain ,
& CmndInfoRetain , & CmndStateRetain } ;
2018-10-10 21:21:44 +01:00
2019-08-15 12:50:28 +01:00
struct MQTT {
uint16_t connect_count = 0 ; // MQTT re-connect count
uint16_t retry_counter = 1 ; // MQTT connection retry counter
2020-11-22 11:26:05 +00:00
uint16_t retry_counter_delay = 1 ; // MQTT retry counter multiplier
2019-08-15 12:50:28 +01:00
uint8_t initial_connection_state = 2 ; // MQTT connection messages state
bool connected = false ; // MQTT virtual connection status
bool allowed = false ; // MQTT enabled and parameters valid
2020-09-14 20:48:32 +01:00
bool mqtt_tls = false ; // MQTT TLS is enabled
2019-08-15 12:50:28 +01:00
} Mqtt ;
2018-10-10 21:21:44 +01:00
2019-06-10 11:06:03 +01:00
# ifdef USE_MQTT_TLS
2019-06-05 10:44:52 +01:00
2020-08-12 16:20:37 +01:00
// This part of code is necessary to store Private Key and Cert in Flash
2019-08-10 12:31:05 +01:00
# ifdef USE_MQTT_AWS_IOT
2019-08-04 18:42:21 +01:00
# include <base64.hpp>
const br_ec_private_key * AWS_IoT_Private_Key = nullptr ;
const br_x509_certificate * AWS_IoT_Client_Certificate = nullptr ;
class tls_entry_t {
public :
uint32_t name ; // simple 4 letters name. Currently 'skey', 'crt ', 'crt1', 'crt2'
uint16_t start ; // start offset
uint16_t len ; // len of object
} ; // 8 bytes
const static uint32_t TLS_NAME_SKEY = 0x2079656B ; // 'key ' little endian
const static uint32_t TLS_NAME_CRT = 0x20747263 ; // 'crt ' little endian
class tls_dir_t {
public :
tls_entry_t entry [ 4 ] ; // 4 entries max, only 4 used today, for future use
} ; // 4*8 = 64 bytes
tls_dir_t tls_dir ; // memory copy of tls_dir from flash
2019-08-10 12:31:05 +01:00
# endif // USE_MQTT_AWS_IOT
2019-06-05 10:44:52 +01:00
// check whether the fingerprint is filled with a single value
// Filled with 0x00 = accept any fingerprint and learn it for next time
// Filled with 0xFF = accept any fingerpring forever
bool is_fingerprint_mono_value ( uint8_t finger [ 20 ] , uint8_t value ) {
for ( uint32_t i = 0 ; i < 20 ; i + + ) {
if ( finger [ i ] ! = value ) {
return false ;
}
}
return true ;
}
2019-06-10 11:06:03 +01:00
# endif // USE_MQTT_TLS
2019-06-05 10:44:52 +01:00
2020-12-26 11:18:16 +00:00
void MakeValidMqtt ( uint32_t option , char * str ) {
2019-07-28 16:14:20 +01:00
// option 0 = replace by underscore
// option 1 = delete character
uint32_t i = 0 ;
while ( str [ i ] > 0 ) {
// if ((str[i] == '/') || (str[i] == '+') || (str[i] == '#') || (str[i] == ' ')) {
if ( ( str [ i ] = = ' + ' ) | | ( str [ i ] = = ' # ' ) | | ( str [ i ] = = ' ' ) ) {
if ( option ) {
uint32_t j = i ;
while ( str [ j ] > 0 ) {
str [ j ] = str [ j + 1 ] ;
j + + ;
}
i - - ;
} else {
str [ i ] = ' _ ' ;
}
}
i + + ;
}
}
2018-10-10 21:21:44 +01:00
/*********************************************************************************************\
* MQTT driver specific code need to provide the following functions :
*
* bool MqttIsConnected ( )
* void MqttDisconnect ( )
* void MqttSubscribeLib ( char * topic )
2019-01-28 13:08:33 +00:00
* bool MqttPublishLib ( const char * topic , bool retained )
2018-10-10 21:21:44 +01:00
\ * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
# include <PubSubClient.h>
// Max message size calculated by PubSubClient is (MQTT_MAX_PACKET_SIZE < 5 + 2 + strlen(topic) + plength)
# if (MQTT_MAX_PACKET_SIZE -TOPSZ -7) < MIN_MESSZ // If the max message size is too small, throw an error at compile time. See PubSubClient.cpp line 359
2020-02-12 17:00:53 +00:00
# error "MQTT_MAX_PACKET_SIZE is too small in libraries / PubSubClient / src / PubSubClient.h, increase it to at least 1200"
2018-10-10 21:21:44 +01:00
# endif
2019-06-05 10:44:52 +01:00
PubSubClient MqttClient ;
2020-12-26 11:18:16 +00:00
void MqttInit ( void ) {
2019-06-10 11:06:03 +01:00
# ifdef USE_MQTT_TLS
2020-08-12 16:20:37 +01:00
if ( ( 8883 = = Settings . mqtt_port ) | | ( 8884 = = Settings . mqtt_port ) ) {
// Turn on TLS for port 8883 (TLS) and 8884 (TLS, client certificate)
Settings . flag4 . mqtt_tls = true ;
}
2020-09-14 20:48:32 +01:00
Mqtt . mqtt_tls = Settings . flag4 . mqtt_tls ; // this flag should not change even if we change the SetOption (until reboot)
2020-08-12 16:20:37 +01:00
// Detect AWS IoT and set default parameters
String host = String ( SettingsText ( SET_MQTT_HOST ) ) ;
2021-01-18 20:48:04 +00:00
if ( host . indexOf ( F ( " .iot. " ) ) & & host . endsWith ( F ( " .amazonaws.com " ) ) ) { // look for ".iot." and ".amazonaws.com" in the domain name
2020-08-12 16:20:37 +01:00
Settings . flag4 . mqtt_no_retain = true ;
}
2020-09-14 20:48:32 +01:00
if ( Mqtt . mqtt_tls ) {
2020-08-12 16:20:37 +01:00
tlsClient = new BearSSL : : WiFiClientSecure_light ( 1024 , 1024 ) ;
2019-06-10 11:06:03 +01:00
2019-06-05 10:44:52 +01:00
# ifdef USE_MQTT_AWS_IOT
2020-08-12 16:20:37 +01:00
loadTlsDir ( ) ; // load key and certificate data from Flash
2020-09-14 20:48:32 +01:00
if ( ( nullptr ! = AWS_IoT_Private_Key ) & & ( nullptr ! = AWS_IoT_Client_Certificate ) ) {
tlsClient - > setClientECCert ( AWS_IoT_Client_Certificate ,
AWS_IoT_Private_Key ,
0xFFFF /* all usages, don't care */ , 0 ) ;
}
2019-06-10 11:06:03 +01:00
# endif
2019-06-05 10:44:52 +01:00
2019-06-10 18:58:57 +01:00
# ifdef USE_MQTT_TLS_CA_CERT
2021-02-28 11:50:02 +00:00
tlsClient - > setTrustAnchor ( Tasmota_TA , nitems ( Tasmota_TA ) ) ;
2019-06-10 18:58:57 +01:00
# endif // USE_MQTT_TLS_CA_CERT
2020-08-12 16:20:37 +01:00
MqttClient . setClient ( * tlsClient ) ;
} else {
MqttClient . setClient ( EspClient ) ; // non-TLS
}
# else // USE_MQTT_TLS
MqttClient . setClient ( EspClient ) ;
2019-06-30 17:50:42 +01:00
# endif // USE_MQTT_TLS
2019-06-05 10:44:52 +01:00
}
2020-12-26 11:18:16 +00:00
bool MqttIsConnected ( void ) {
2018-10-10 21:21:44 +01:00
return MqttClient . connected ( ) ;
}
2020-12-26 11:18:16 +00:00
void MqttDisconnect ( void ) {
2018-10-10 21:21:44 +01:00
MqttClient . disconnect ( ) ;
}
2020-12-26 11:18:16 +00:00
void MqttSubscribeLib ( const char * topic ) {
2018-10-10 21:21:44 +01:00
MqttClient . subscribe ( topic ) ;
MqttClient . loop ( ) ; // Solve LmacRxBlk:1 messages
}
2020-12-26 11:18:16 +00:00
void MqttUnsubscribeLib ( const char * topic ) {
Rules: Trigger Event with MQTT Subscriptions
Support subscribe/unsubscribe MQTT topics and trigger specified event with the subscribed MQTT topic.
You can subscribe a MQTT topic and assign an event name. Once we received subscribed MQTT message, an event will be automatically triggered. So you can set up a rule with "ON EVENT#<event_name> DO ..." to do whatever you want based on this MQTT message. The payload is passed as a parameter once the event been triggered. If the payload is in JSON format, you are able to get the value of specified key as parameter.
For example, if you have a Tasmota based thermostat and multiple temperature sensors in different place, usually you have to set up a centre home automation system like Domoticz to control the thermostat. Right now, with this new feature, you can write a rule to do this.
Two new commands in Rules:
1. Subscribe
Subscribe a MQTT topic (with or without key) and assign an event name to it.
Command format:
Subscribe [<event_name>, <topic> [, <key>]]
This command will subscribe a <topic> and give it an event name <event_name>.
The optional parameter <key> is for parse the specified key/value from MQTT message
payload with JSON format.
In order to parse value from two level JSON data, you can use one dot (".") to split the key into two section.
Subscribe command without any parameter will list all topics currently subscribed.
2. Unsubscribe
Unsubscribe specified MQTT event.
Command format:
Unsubscribe [<event_name>]
Unsubscribe a topic subscribed by specify the event name.
If no event specified, Unsubscribe all topics subscribed.
Examples:
1.
Subscribe BkLight, Tasmota/BackyardLight/stat/POWER
And define a rule like:
Rule1 on event#BkLight=ON do ruletimer4 60 endon
2.
Subscribe DnTemp, Tasmota/RoomSensor1/stat/SENSOR, DS18B20.Temperature
Define a rule to deal with the MQTT message like {"Time":"2017-02-16T10:13:52", "DS18B20":{"Temperature":20.6}}
Rule1 ON EVENT#DnTemp>=21 DO ... ENDON
2019-02-24 03:33:09 +00:00
MqttClient . unsubscribe ( topic ) ;
MqttClient . loop ( ) ; // Solve LmacRxBlk:1 messages
}
2020-12-26 11:18:16 +00:00
bool MqttPublishLib ( const char * topic , bool retained ) {
2020-01-18 14:34:01 +00:00
// If Prefix1 equals Prefix2 disable next MQTT subscription to prevent loop
if ( ! strcmp ( SettingsText ( SET_MQTTPREFIX1 ) , SettingsText ( SET_MQTTPREFIX2 ) ) ) {
char * str = strstr ( topic , SettingsText ( SET_MQTTPREFIX1 ) ) ;
if ( str = = topic ) {
2020-10-29 12:58:50 +00:00
TasmotaGlobal . mqtt_cmnd_blocked_reset = 4 ; // Allow up to four seconds before resetting residual cmnd blocks
TasmotaGlobal . mqtt_cmnd_blocked + + ;
2020-01-18 14:34:01 +00:00
}
}
2020-10-30 11:29:48 +00:00
bool result = MqttClient . publish ( topic , TasmotaGlobal . mqtt_data , retained ) ;
2018-10-10 21:21:44 +01:00
yield ( ) ; // #3313
return result ;
}
2021-01-02 13:59:02 +00:00
# ifdef DEBUG_TASMOTA_CORE
2020-10-19 11:39:27 +01:00
void MqttDumpData ( char * topic , char * data , uint32_t data_len ) {
char dump_data [ data_len + 1 ] ;
2020-10-19 11:46:57 +01:00
memcpy ( dump_data , data , sizeof ( dump_data ) ) ; // Make another copy for removing optional control characters
2021-01-02 13:59:02 +00:00
DEBUG_CORE_LOG ( PSTR ( D_LOG_MQTT " Size %d, \" %s %s \" " ) , data_len , topic , RemoveControlCharacter ( dump_data ) ) ;
2020-10-19 11:39:27 +01:00
}
2021-01-02 13:59:02 +00:00
# endif
2020-10-19 11:39:27 +01:00
2020-12-26 11:18:16 +00:00
void MqttDataHandler ( char * mqtt_topic , uint8_t * mqtt_data , unsigned int data_len ) {
2019-07-26 08:52:14 +01:00
# ifdef USE_DEBUG_DRIVER
ShowFreeMem ( PSTR ( " MqttDataHandler " ) ) ;
# endif
// Do not allow more data than would be feasable within stack space
if ( data_len > = MQTT_MAX_PACKET_SIZE ) { return ; }
// Do not execute multiple times if Prefix1 equals Prefix2
2019-12-16 14:13:57 +00:00
if ( ! strcmp ( SettingsText ( SET_MQTTPREFIX1 ) , SettingsText ( SET_MQTTPREFIX2 ) ) ) {
char * str = strstr ( mqtt_topic , SettingsText ( SET_MQTTPREFIX1 ) ) ;
2020-10-29 12:58:50 +00:00
if ( ( str = = mqtt_topic ) & & TasmotaGlobal . mqtt_cmnd_blocked ) {
TasmotaGlobal . mqtt_cmnd_blocked - - ;
2019-07-26 08:52:14 +01:00
return ;
}
}
2019-10-02 15:45:53 +01:00
// Save MQTT data ASAP as it's data is discarded by PubSubClient with next publish as used in MQTTlog
char topic [ TOPSZ ] ;
strlcpy ( topic , mqtt_topic , sizeof ( topic ) ) ;
mqtt_data [ data_len ] = 0 ;
char data [ data_len + 1 ] ;
2020-10-10 15:44:35 +01:00
memcpy ( data , mqtt_data , sizeof ( data ) ) ;
2019-07-26 08:52:14 +01:00
2021-01-02 13:59:02 +00:00
# ifdef DEBUG_TASMOTA_CORE
2020-10-19 11:39:27 +01:00
MqttDumpData ( topic , data , data_len ) ; // Use a function to save stack space used by dump_data
2021-01-02 13:59:02 +00:00
# endif
2020-10-10 15:44:35 +01:00
2019-07-26 08:52:14 +01:00
// MQTT pre-processing
2019-10-02 11:51:37 +01:00
XdrvMailbox . index = strlen ( topic ) ;
XdrvMailbox . data_len = data_len ;
XdrvMailbox . topic = topic ;
XdrvMailbox . data = ( char * ) data ;
if ( XdrvCall ( FUNC_MQTT_DATA ) ) { return ; }
2019-07-26 08:52:14 +01:00
ShowSource ( SRC_MQTT ) ;
CommandHandler ( topic , data , data_len ) ;
}
2018-10-10 21:21:44 +01:00
/*********************************************************************************************/
2020-12-26 11:18:16 +00:00
void MqttRetryCounter ( uint8_t value ) {
2019-08-15 12:50:28 +01:00
Mqtt . retry_counter = value ;
2018-10-10 21:21:44 +01:00
}
2020-12-26 11:18:16 +00:00
void MqttSubscribe ( const char * topic ) {
2021-01-23 15:26:23 +00:00
AddLog ( LOG_LEVEL_DEBUG , PSTR ( D_LOG_MQTT D_SUBSCRIBE_TO " %s " ) , topic ) ;
2018-10-10 21:21:44 +01:00
MqttSubscribeLib ( topic ) ;
}
2020-12-26 11:18:16 +00:00
void MqttUnsubscribe ( const char * topic ) {
2021-01-23 15:26:23 +00:00
AddLog ( LOG_LEVEL_DEBUG , PSTR ( D_LOG_MQTT D_UNSUBSCRIBE_FROM " %s " ) , topic ) ;
Rules: Trigger Event with MQTT Subscriptions
Support subscribe/unsubscribe MQTT topics and trigger specified event with the subscribed MQTT topic.
You can subscribe a MQTT topic and assign an event name. Once we received subscribed MQTT message, an event will be automatically triggered. So you can set up a rule with "ON EVENT#<event_name> DO ..." to do whatever you want based on this MQTT message. The payload is passed as a parameter once the event been triggered. If the payload is in JSON format, you are able to get the value of specified key as parameter.
For example, if you have a Tasmota based thermostat and multiple temperature sensors in different place, usually you have to set up a centre home automation system like Domoticz to control the thermostat. Right now, with this new feature, you can write a rule to do this.
Two new commands in Rules:
1. Subscribe
Subscribe a MQTT topic (with or without key) and assign an event name to it.
Command format:
Subscribe [<event_name>, <topic> [, <key>]]
This command will subscribe a <topic> and give it an event name <event_name>.
The optional parameter <key> is for parse the specified key/value from MQTT message
payload with JSON format.
In order to parse value from two level JSON data, you can use one dot (".") to split the key into two section.
Subscribe command without any parameter will list all topics currently subscribed.
2. Unsubscribe
Unsubscribe specified MQTT event.
Command format:
Unsubscribe [<event_name>]
Unsubscribe a topic subscribed by specify the event name.
If no event specified, Unsubscribe all topics subscribed.
Examples:
1.
Subscribe BkLight, Tasmota/BackyardLight/stat/POWER
And define a rule like:
Rule1 on event#BkLight=ON do ruletimer4 60 endon
2.
Subscribe DnTemp, Tasmota/RoomSensor1/stat/SENSOR, DS18B20.Temperature
Define a rule to deal with the MQTT message like {"Time":"2017-02-16T10:13:52", "DS18B20":{"Temperature":20.6}}
Rule1 ON EVENT#DnTemp>=21 DO ... ENDON
2019-02-24 03:33:09 +00:00
MqttUnsubscribeLib ( topic ) ;
}
2020-12-22 14:26:07 +00:00
void MqttPublishLoggingAsync ( bool refresh ) {
2020-12-19 16:29:14 +00:00
static uint32_t index = 1 ;
2020-12-23 09:56:21 +00:00
if ( ! Settings . mqttlog_level | | ! Settings . flag . mqtt_enabled ) { return ; } // SetOption3 - Enable MQTT
2020-12-22 14:26:07 +00:00
if ( refresh & & ! NeedLogRefresh ( Settings . mqttlog_level , index ) ) { return ; }
2020-12-19 16:29:14 +00:00
char * line ;
size_t len ;
while ( GetLog ( Settings . mqttlog_level , & index , & line , & len ) ) {
strlcpy ( TasmotaGlobal . mqtt_data , line , len ) ; // No JSON and ugly!!
char stopic [ TOPSZ ] ;
GetTopic_P ( stopic , STAT , TasmotaGlobal . mqtt_topic , PSTR ( " LOGGING " ) ) ;
MqttPublishLib ( stopic , false ) ;
}
2019-09-27 17:13:00 +01:00
}
2020-12-26 11:18:16 +00:00
void MqttPublish ( const char * topic , bool retained ) {
2019-03-11 09:38:41 +00:00
# ifdef USE_DEBUG_DRIVER
2020-01-18 14:34:01 +00:00
ShowFreeMem ( PSTR ( " MqttPublish " ) ) ;
# endif
2020-08-12 16:20:37 +01:00
if ( Settings . flag4 . mqtt_no_retain ) {
retained = false ; // Some brokers don't support retained, they will disconnect if received
}
2018-10-10 21:21:44 +01:00
2020-01-18 14:34:01 +00:00
char sretained [ CMDSZ ] ;
2018-10-10 21:21:44 +01:00
sretained [ 0 ] = ' \0 ' ;
2020-01-18 14:34:01 +00:00
char slog_type [ 20 ] ;
2018-10-10 21:21:44 +01:00
snprintf_P ( slog_type , sizeof ( slog_type ) , PSTR ( D_LOG_RESULT ) ) ;
2019-11-03 11:33:36 +00:00
if ( Settings . flag . mqtt_enabled ) { // SetOption3 - Enable MQTT
2020-01-19 13:12:25 +00:00
if ( MqttPublishLib ( topic , retained ) ) {
snprintf_P ( slog_type , sizeof ( slog_type ) , PSTR ( D_LOG_MQTT ) ) ;
if ( retained ) {
snprintf_P ( sretained , sizeof ( sretained ) , PSTR ( " ( " D_RETAINED " ) " ) ) ;
2018-10-10 21:21:44 +01:00
}
}
}
2021-01-02 15:20:15 +00:00
char log_data [ MAX_LOGSZ ] ;
2020-12-23 17:00:59 +00:00
snprintf_P ( log_data , sizeof ( log_data ) , PSTR ( " %s%s = %s " ) , slog_type , ( Settings . flag . mqtt_enabled ) ? topic : strrchr ( topic , ' / ' ) + 1 , TasmotaGlobal . mqtt_data ) ; // SetOption3 - Enable MQTT
if ( strlen ( log_data ) > = ( sizeof ( log_data ) - strlen ( sretained ) - 1 ) ) {
log_data [ sizeof ( log_data ) - strlen ( sretained ) - 5 ] = ' \0 ' ;
snprintf_P ( log_data , sizeof ( log_data ) , PSTR ( " %s ... " ) , log_data ) ;
2018-10-10 21:21:44 +01:00
}
2020-12-23 17:00:59 +00:00
snprintf_P ( log_data , sizeof ( log_data ) , PSTR ( " %s%s " ) , log_data , sretained ) ;
AddLogData ( LOG_LEVEL_INFO , log_data ) ;
2019-03-08 14:15:42 +00:00
2018-10-10 21:21:44 +01:00
if ( Settings . ledstate & 0x04 ) {
2020-10-29 11:39:44 +00:00
TasmotaGlobal . blinks + + ;
2018-10-10 21:21:44 +01:00
}
}
2020-12-26 11:18:16 +00:00
void MqttPublish ( const char * topic ) {
2018-10-10 21:21:44 +01:00
MqttPublish ( topic , false ) ;
}
2020-12-26 11:18:16 +00:00
void MqttPublishPrefixTopic_P ( uint32_t prefix , const char * subtopic , bool retained ) {
2018-10-10 21:21:44 +01:00
/* prefix 0 = cmnd using subtopic
* prefix 1 = stat using subtopic
* prefix 2 = tele using subtopic
* prefix 4 = cmnd using subtopic or RESULT
* prefix 5 = stat using subtopic or RESULT
* prefix 6 = tele using subtopic or RESULT
*/
2020-01-26 22:08:52 +00:00
char romram [ 64 ] ;
2019-11-03 11:33:36 +00:00
snprintf_P ( romram , sizeof ( romram ) , ( ( prefix > 3 ) & & ! Settings . flag . mqtt_response ) ? S_RSLT_RESULT : subtopic ) ; // SetOption4 - Switch between MQTT RESULT or COMMAND
2020-11-03 15:24:49 +00:00
UpperCase ( romram , romram ) ;
2018-10-10 21:21:44 +01:00
prefix & = 3 ;
2020-11-03 15:24:49 +00:00
char stopic [ TOPSZ ] ;
2020-10-30 11:29:48 +00:00
GetTopic_P ( stopic , prefix , TasmotaGlobal . mqtt_topic , romram ) ;
2018-10-10 21:21:44 +01:00
MqttPublish ( stopic , retained ) ;
2020-01-26 22:08:52 +00:00
2020-09-08 20:22:52 +01:00
# if defined(USE_MQTT_AWS_IOT) || defined(USE_MQTT_AWS_IOT_LIGHT)
2020-04-13 10:40:07 +01:00
if ( ( prefix > 0 ) & & ( Settings . flag4 . awsiot_shadow ) & & ( Mqtt . connected ) ) { // placeholder for SetOptionXX
2020-01-26 22:08:52 +00:00
// compute the target topic
char * topic = SettingsText ( SET_MQTT_TOPIC ) ;
char topic2 [ strlen ( topic ) + 1 ] ; // save buffer onto stack
strcpy ( topic2 , topic ) ;
// replace any '/' with '_'
char * s = topic2 ;
while ( * s ) {
if ( ' / ' = = * s ) {
* s = ' _ ' ;
}
s + + ;
}
// update topic is "$aws/things/<topic>/shadow/update"
snprintf_P ( romram , sizeof ( romram ) , PSTR ( " $aws/things/%s/shadow/update " ) , topic2 ) ;
2020-01-27 16:38:32 +00:00
2020-01-26 22:08:52 +00:00
// copy buffer
2020-10-30 11:29:48 +00:00
char * mqtt_save = ( char * ) malloc ( strlen ( TasmotaGlobal . mqtt_data ) + 1 ) ;
2020-01-26 22:08:52 +00:00
if ( ! mqtt_save ) { return ; } // abort
2020-10-30 11:29:48 +00:00
strcpy ( mqtt_save , TasmotaGlobal . mqtt_data ) ;
snprintf_P ( TasmotaGlobal . mqtt_data , sizeof ( TasmotaGlobal . mqtt_data ) , PSTR ( " { \" state \" :{ \" reported \" :%s}} " ) , mqtt_save ) ;
2020-01-26 22:08:52 +00:00
free ( mqtt_save ) ;
2020-10-30 11:29:48 +00:00
bool result = MqttClient . publish ( romram , TasmotaGlobal . mqtt_data , false ) ;
2021-01-23 15:26:23 +00:00
AddLog ( LOG_LEVEL_DEBUG , PSTR ( D_LOG_MQTT " Updated shadow: %s " ) , romram ) ;
2020-01-26 22:08:52 +00:00
yield ( ) ; // #3313
}
# endif // USE_MQTT_AWS_IOT
2018-10-10 21:21:44 +01:00
}
2020-12-26 11:18:16 +00:00
void MqttPublishPrefixTopic_P ( uint32_t prefix , const char * subtopic ) {
2018-10-10 21:21:44 +01:00
MqttPublishPrefixTopic_P ( prefix , subtopic , false ) ;
}
2020-12-26 11:18:16 +00:00
void MqttPublishPrefixTopicRulesProcess_P ( uint32_t prefix , const char * subtopic , bool retained ) {
2020-07-20 16:24:51 +01:00
MqttPublishPrefixTopic_P ( prefix , subtopic , retained ) ;
2019-11-10 16:40:37 +00:00
XdrvRulesProcess ( ) ;
2019-11-10 16:02:02 +00:00
}
2020-12-26 11:18:16 +00:00
void MqttPublishPrefixTopicRulesProcess_P ( uint32_t prefix , const char * subtopic ) {
2020-07-20 16:24:51 +01:00
MqttPublishPrefixTopicRulesProcess_P ( prefix , subtopic , false ) ;
}
2020-12-26 11:18:16 +00:00
void MqttPublishTeleSensor ( void ) {
2020-07-20 16:24:51 +01:00
MqttPublishPrefixTopicRulesProcess_P ( TELE , PSTR ( D_RSLT_SENSOR ) , Settings . flag . mqtt_sensor_retain ) ; // CMND_SENSORRETAIN
}
2020-12-26 11:18:16 +00:00
void MqttPublishPowerState ( uint32_t device ) {
2018-10-10 21:21:44 +01:00
char stopic [ TOPSZ ] ;
char scommand [ 33 ] ;
2020-10-30 11:29:48 +00:00
if ( ( device < 1 ) | | ( device > TasmotaGlobal . devices_present ) ) { device = 1 ; }
2018-10-10 21:21:44 +01:00
2019-07-14 21:08:19 +01:00
# ifdef USE_SONOFF_IFAN
2019-07-14 14:23:02 +01:00
if ( IsModuleIfan ( ) & & ( device > 1 ) ) {
if ( GetFanspeed ( ) < MaxFanspeed ( ) ) { // 4 occurs when fanspeed is 3 and RC button 2 is pressed
2018-12-06 14:03:42 +00:00
# ifdef USE_DOMOTICZ
DomoticzUpdateFanState ( ) ; // RC Button feedback
# endif // USE_DOMOTICZ
2018-10-10 21:21:44 +01:00
snprintf_P ( scommand , sizeof ( scommand ) , PSTR ( D_CMND_FANSPEED ) ) ;
2020-10-30 11:29:48 +00:00
GetTopic_P ( stopic , STAT , TasmotaGlobal . mqtt_topic , ( Settings . flag . mqtt_response ) ? scommand : S_RSLT_RESULT ) ; // SetOption4 - Switch between MQTT RESULT or COMMAND
2019-03-23 16:00:59 +00:00
Response_P ( S_JSON_COMMAND_NVALUE , scommand , GetFanspeed ( ) ) ;
2018-10-10 21:21:44 +01:00
MqttPublish ( stopic ) ;
}
} else {
2019-07-14 21:08:19 +01:00
# endif // USE_SONOFF_IFAN
2019-11-03 11:33:36 +00:00
GetPowerDevice ( scommand , device , sizeof ( scommand ) , Settings . flag . device_index_enable ) ; // SetOption26 - Switch between POWER or POWER1
2020-10-30 11:29:48 +00:00
GetTopic_P ( stopic , STAT , TasmotaGlobal . mqtt_topic , ( Settings . flag . mqtt_response ) ? scommand : S_RSLT_RESULT ) ; // SetOption4 - Switch between MQTT RESULT or COMMAND
2020-10-28 18:03:39 +00:00
Response_P ( S_JSON_COMMAND_SVALUE , scommand , GetStateText ( bitRead ( TasmotaGlobal . power , device - 1 ) ) ) ;
2018-10-10 21:21:44 +01:00
MqttPublish ( stopic ) ;
2020-04-01 13:05:30 +01:00
if ( ! Settings . flag4 . only_json_message ) { // SetOption90 - Disable non-json MQTT response
2020-10-30 11:29:48 +00:00
GetTopic_P ( stopic , STAT , TasmotaGlobal . mqtt_topic , scommand ) ;
2020-10-28 18:03:39 +00:00
Response_P ( GetStateText ( bitRead ( TasmotaGlobal . power , device - 1 ) ) ) ;
2020-04-01 13:05:30 +01:00
MqttPublish ( stopic , Settings . flag . mqtt_power_retain ) ; // CMND_POWERRETAIN
}
2019-07-14 21:08:19 +01:00
# ifdef USE_SONOFF_IFAN
2018-10-10 21:21:44 +01:00
}
2019-07-14 21:08:19 +01:00
# endif // USE_SONOFF_IFAN
2018-10-10 21:21:44 +01:00
}
2020-12-26 11:18:16 +00:00
void MqttPublishAllPowerState ( void ) {
2020-10-30 11:29:48 +00:00
for ( uint32_t i = 1 ; i < = TasmotaGlobal . devices_present ; i + + ) {
2019-04-15 17:12:42 +01:00
MqttPublishPowerState ( i ) ;
2019-07-14 21:08:19 +01:00
# ifdef USE_SONOFF_IFAN
2019-07-14 14:23:02 +01:00
if ( IsModuleIfan ( ) ) { break ; } // Report status of light relay only
2019-07-14 21:08:19 +01:00
# endif // USE_SONOFF_IFAN
2019-04-15 17:12:42 +01:00
}
}
2020-12-26 11:18:16 +00:00
void MqttPublishPowerBlinkState ( uint32_t device ) {
2018-10-10 21:21:44 +01:00
char scommand [ 33 ] ;
2020-10-30 11:29:48 +00:00
if ( ( device < 1 ) | | ( device > TasmotaGlobal . devices_present ) ) {
2018-10-10 21:21:44 +01:00
device = 1 ;
}
2019-03-23 16:00:59 +00:00
Response_P ( PSTR ( " { \" %s \" : \" " D_JSON_BLINK " %s \" } " ) ,
2020-10-28 18:03:39 +00:00
GetPowerDevice ( scommand , device , sizeof ( scommand ) , Settings . flag . device_index_enable ) , GetStateText ( bitRead ( TasmotaGlobal . blink_mask , device - 1 ) ) ) ; // SetOption26 - Switch between POWER or POWER1
2018-10-10 21:21:44 +01:00
MqttPublishPrefixTopic_P ( RESULT_OR_STAT , S_RSLT_POWER ) ;
}
/*********************************************************************************************/
2020-12-26 11:18:16 +00:00
uint16_t MqttConnectCount ( void ) {
2019-08-15 12:50:28 +01:00
return Mqtt . connect_count ;
2019-02-18 16:05:25 +00:00
}
2020-12-26 11:18:16 +00:00
void MqttDisconnected ( int state ) {
2019-08-15 12:50:28 +01:00
Mqtt . connected = false ;
2020-11-17 15:44:00 +00:00
2020-11-22 11:26:05 +00:00
Mqtt . retry_counter = Settings . mqtt_retry * Mqtt . retry_counter_delay ;
2020-11-17 15:44:00 +00:00
if ( ( Settings . mqtt_retry * Mqtt . retry_counter_delay ) < 120 ) {
Mqtt . retry_counter_delay + + ;
}
2018-10-10 21:21:44 +01:00
2019-06-07 17:03:34 +01:00
MqttClient . disconnect ( ) ;
2021-01-23 15:26:23 +00:00
AddLog ( LOG_LEVEL_INFO , PSTR ( D_LOG_MQTT D_CONNECT_FAILED_TO " %s:%d, rc %d. " D_RETRY_IN " %d " D_UNIT_SECOND ) , SettingsText ( SET_MQTT_HOST ) , Settings . mqtt_port , state , Mqtt . retry_counter ) ;
2020-10-29 12:58:50 +00:00
TasmotaGlobal . rules_flag . mqtt_disconnected = 1 ;
2018-10-10 21:21:44 +01:00
}
2020-12-26 11:18:16 +00:00
void MqttConnected ( void ) {
2018-10-10 21:21:44 +01:00
char stopic [ TOPSZ ] ;
2019-08-15 12:50:28 +01:00
if ( Mqtt . allowed ) {
2021-01-23 15:26:23 +00:00
AddLog ( LOG_LEVEL_INFO , PSTR ( D_LOG_MQTT D_CONNECTED ) ) ;
2019-08-15 12:50:28 +01:00
Mqtt . connected = true ;
Mqtt . retry_counter = 0 ;
2020-11-22 11:26:05 +00:00
Mqtt . retry_counter_delay = 1 ;
2019-08-15 12:50:28 +01:00
Mqtt . connect_count + + ;
2018-10-10 21:21:44 +01:00
2020-10-30 11:29:48 +00:00
GetTopic_P ( stopic , TELE , TasmotaGlobal . mqtt_topic , S_LWT ) ;
2020-09-27 11:51:50 +01:00
Response_P ( PSTR ( MQTT_LWT_ONLINE ) ) ;
2018-10-10 21:21:44 +01:00
MqttPublish ( stopic , true ) ;
2020-04-01 13:05:30 +01:00
if ( ! Settings . flag4 . only_json_message ) { // SetOption90 - Disable non-json MQTT response
// Satisfy iobroker (#299)
2020-10-30 11:29:48 +00:00
ResponseClear ( ) ;
2020-04-01 13:05:30 +01:00
MqttPublishPrefixTopic_P ( CMND , S_RSLT_POWER ) ;
}
2018-10-10 21:21:44 +01:00
2020-10-30 11:29:48 +00:00
GetTopic_P ( stopic , CMND , TasmotaGlobal . mqtt_topic , PSTR ( " # " ) ) ;
2018-10-10 21:21:44 +01:00
MqttSubscribe ( stopic ) ;
2019-12-16 14:13:57 +00:00
if ( strstr_P ( SettingsText ( SET_MQTT_FULLTOPIC ) , MQTT_TOKEN_TOPIC ) ! = nullptr ) {
2020-03-28 15:48:36 +00:00
uint32_t real_index = SET_MQTT_GRP_TOPIC ;
for ( uint32_t i = 0 ; i < MAX_GROUP_TOPICS ; i + + ) {
if ( 1 = = i ) { real_index = SET_MQTT_GRP_TOPIC2 - 1 ; }
if ( strlen ( SettingsText ( real_index + i ) ) ) {
GetGroupTopic_P ( stopic , PSTR ( " # " ) , real_index + i ) ; // SetOption75 0: %prefix%/nothing/%topic% = cmnd/nothing/<grouptopic>/# or SetOption75 1: cmnd/<grouptopic>
2020-03-28 10:13:01 +00:00
MqttSubscribe ( stopic ) ;
}
}
2019-10-31 16:24:06 +00:00
GetFallbackTopic_P ( stopic , PSTR ( " # " ) ) ;
2018-10-10 21:21:44 +01:00
MqttSubscribe ( stopic ) ;
}
XdrvCall ( FUNC_MQTT_SUBSCRIBE ) ;
}
2019-08-15 12:50:28 +01:00
if ( Mqtt . initial_connection_state ) {
2020-04-01 13:05:30 +01:00
if ( ResetReason ( ) ! = REASON_DEEP_SLEEP_AWAKE ) {
char stopic2 [ TOPSZ ] ;
Response_P ( PSTR ( " { \" " D_CMND_MODULE " \" : \" %s \" , \" " D_JSON_VERSION " \" : \" %s%s \" , \" " D_JSON_FALLBACKTOPIC " \" : \" %s \" , \" " D_CMND_GROUPTOPIC " \" : \" %s \" } " ) ,
2020-10-30 11:29:48 +00:00
ModuleName ( ) . c_str ( ) , TasmotaGlobal . version , TasmotaGlobal . image_name , GetFallbackTopic_P ( stopic , " " ) , GetGroupTopic_P ( stopic2 , " " , SET_MQTT_GRP_TOPIC ) ) ;
2021-02-22 08:11:36 +00:00
MqttPublishPrefixTopic_P ( TELE , PSTR ( D_RSLT_INFO " 1 " ) , Settings . flag5 . mqtt_info_retain ) ;
2018-10-10 21:21:44 +01:00
# ifdef USE_WEBSERVER
2020-04-01 13:05:30 +01:00
if ( Settings . webserver ) {
2019-12-11 14:53:19 +00:00
# if LWIP_IPV6
2020-04-01 13:05:30 +01:00
Response_P ( PSTR ( " { \" " D_JSON_WEBSERVER_MODE " \" : \" %s \" , \" " D_CMND_HOSTNAME " \" : \" %s \" , \" " D_CMND_IPADDRESS " \" : \" %s \" , \" IPv6Address \" : \" %s \" } " ) ,
2021-02-22 08:11:36 +00:00
( 2 = = Settings . webserver ) ? PSTR ( D_ADMIN ) : PSTR ( D_USER ) , NetworkHostname ( ) , NetworkAddress ( ) . toString ( ) . c_str ( ) , WifiGetIPv6 ( ) . c_str ( ) , Settings . flag5 . mqtt_info_retain ) ;
2019-12-11 14:53:19 +00:00
# else
2020-04-01 13:05:30 +01:00
Response_P ( PSTR ( " { \" " D_JSON_WEBSERVER_MODE " \" : \" %s \" , \" " D_CMND_HOSTNAME " \" : \" %s \" , \" " D_CMND_IPADDRESS " \" : \" %s \" } " ) ,
2021-02-22 08:11:36 +00:00
( 2 = = Settings . webserver ) ? PSTR ( D_ADMIN ) : PSTR ( D_USER ) , NetworkHostname ( ) , NetworkAddress ( ) . toString ( ) . c_str ( ) , Settings . flag5 . mqtt_info_retain ) ;
2019-12-11 14:53:19 +00:00
# endif // LWIP_IPV6 = 1
2021-02-22 08:11:36 +00:00
MqttPublishPrefixTopic_P ( TELE , PSTR ( D_RSLT_INFO " 2 " ) , Settings . flag5 . mqtt_info_retain ) ;
2020-04-01 13:05:30 +01:00
}
2018-10-10 21:21:44 +01:00
# endif // USE_WEBSERVER
2020-04-01 13:05:30 +01:00
Response_P ( PSTR ( " { \" " D_JSON_RESTARTREASON " \" : " ) ) ;
if ( CrashFlag ( ) ) {
CrashDump ( ) ;
} else {
ResponseAppend_P ( PSTR ( " \" %s \" " ) , GetResetReason ( ) . c_str ( ) ) ;
}
ResponseJsonEnd ( ) ;
2021-02-22 08:11:36 +00:00
MqttPublishPrefixTopic_P ( TELE , PSTR ( D_RSLT_INFO " 3 " ) , Settings . flag5 . mqtt_info_retain ) ;
2019-12-09 14:29:22 +00:00
}
2020-04-01 13:05:30 +01:00
2019-04-15 17:12:42 +01:00
MqttPublishAllPowerState ( ) ;
2019-11-12 21:30:44 +00:00
if ( Settings . tele_period ) {
2020-10-29 12:37:09 +00:00
TasmotaGlobal . tele_period = Settings . tele_period - 5 ; // Enable TelePeriod in 5 seconds
2019-11-12 21:30:44 +00:00
}
2020-10-29 12:58:50 +00:00
TasmotaGlobal . rules_flag . system_boot = 1 ;
2018-10-10 21:21:44 +01:00
XdrvCall ( FUNC_MQTT_INIT ) ;
}
2019-08-15 12:50:28 +01:00
Mqtt . initial_connection_state = 0 ;
2018-10-25 13:16:46 +01:00
2020-10-30 11:29:48 +00:00
TasmotaGlobal . global_state . mqtt_down = 0 ;
2019-11-03 11:33:36 +00:00
if ( Settings . flag . mqtt_enabled ) { // SetOption3 - Enable MQTT
2020-10-29 12:58:50 +00:00
TasmotaGlobal . rules_flag . mqtt_connected = 1 ;
2018-10-25 13:16:46 +01:00
}
2018-10-10 21:21:44 +01:00
}
2020-12-26 11:18:16 +00:00
void MqttReconnect ( void ) {
2018-10-10 21:21:44 +01:00
char stopic [ TOPSZ ] ;
2019-11-03 11:33:36 +00:00
Mqtt . allowed = Settings . flag . mqtt_enabled ; // SetOption3 - Enable MQTT
2019-08-15 12:50:28 +01:00
if ( Mqtt . allowed ) {
2019-01-20 15:57:07 +00:00
# ifdef USE_DISCOVERY
# ifdef MQTT_HOST_DISCOVERY
MqttDiscoverServer ( ) ;
# endif // MQTT_HOST_DISCOVERY
# endif // USE_DISCOVERY
2019-12-16 14:13:57 +00:00
if ( ! strlen ( SettingsText ( SET_MQTT_HOST ) ) | | ! Settings . mqtt_port ) {
2019-08-15 12:50:28 +01:00
Mqtt . allowed = false ;
2019-01-20 15:57:07 +00:00
}
2019-08-04 18:42:21 +01:00
# if defined(USE_MQTT_TLS) && defined(USE_MQTT_AWS_IOT)
// don't enable MQTT for AWS IoT if Private Key or Certificate are not set
2020-09-14 20:48:32 +01:00
if ( Mqtt . mqtt_tls ) {
2020-09-27 11:51:50 +01:00
if ( 0 = = strlen ( SettingsText ( SET_MQTT_PWD ) ) ) { // we anticipate that an empty password does not make sense with TLS. This avoids failed connections
2020-08-12 16:20:37 +01:00
Mqtt . allowed = false ;
}
2019-08-04 18:42:21 +01:00
}
# endif
2019-01-20 15:57:07 +00:00
}
2019-08-15 12:50:28 +01:00
if ( ! Mqtt . allowed ) {
2018-10-10 21:21:44 +01:00
MqttConnected ( ) ;
return ;
}
2019-05-20 14:09:42 +01:00
# ifdef USE_EMULATION
2018-10-10 21:21:44 +01:00
UdpDisconnect ( ) ;
# endif // USE_EMULATION
2019-08-15 12:50:28 +01:00
Mqtt . connected = false ;
2020-11-17 15:44:00 +00:00
Mqtt . retry_counter = Settings . mqtt_retry * Mqtt . retry_counter_delay ;
2020-10-30 11:29:48 +00:00
TasmotaGlobal . global_state . mqtt_down = 1 ;
2018-10-10 21:21:44 +01:00
2020-10-30 15:29:36 +00:00
# ifdef FIRMWARE_MINIMAL
2020-10-30 15:46:57 +00:00
# ifndef USE_MQTT_TLS
2020-10-30 15:29:36 +00:00
// Don't try to connect if MQTT requires TLS but TLS is not supported
if ( Settings . flag4 . mqtt_tls ) {
return ;
}
2020-10-30 15:46:57 +00:00
# endif
2020-10-30 15:29:36 +00:00
# endif
2021-01-23 15:26:23 +00:00
AddLog ( LOG_LEVEL_INFO , PSTR ( D_LOG_MQTT D_ATTEMPTING_CONNECTION ) ) ;
2020-10-30 15:29:36 +00:00
2019-03-26 17:26:50 +00:00
char * mqtt_user = nullptr ;
char * mqtt_pwd = nullptr ;
2019-12-16 14:13:57 +00:00
if ( strlen ( SettingsText ( SET_MQTT_USER ) ) ) {
mqtt_user = SettingsText ( SET_MQTT_USER ) ;
}
if ( strlen ( SettingsText ( SET_MQTT_PWD ) ) ) {
mqtt_pwd = SettingsText ( SET_MQTT_PWD ) ;
}
2018-10-10 21:21:44 +01:00
2020-10-30 11:29:48 +00:00
GetTopic_P ( stopic , TELE , TasmotaGlobal . mqtt_topic , S_LWT ) ;
2020-09-27 11:51:50 +01:00
Response_P ( S_LWT_OFFLINE ) ;
2018-10-10 21:21:44 +01:00
2019-06-07 17:03:34 +01:00
if ( MqttClient . connected ( ) ) { MqttClient . disconnect ( ) ; }
2020-11-17 16:15:29 +00:00
EspClient . setTimeout ( MQTT_WIFI_CLIENT_TIMEOUT ) ;
2018-10-10 21:21:44 +01:00
# ifdef USE_MQTT_TLS
2020-09-14 20:48:32 +01:00
if ( Mqtt . mqtt_tls ) {
2020-08-12 16:20:37 +01:00
tlsClient - > stop ( ) ;
} else {
2020-11-17 15:44:00 +00:00
// EspClient = WiFiClient(); // Wifi Client reconnect issue 4497 (https://github.com/esp8266/Arduino/issues/4497)
2020-08-12 16:20:37 +01:00
MqttClient . setClient ( EspClient ) ;
}
2018-10-10 21:21:44 +01:00
# else
2020-11-17 15:44:00 +00:00
// EspClient = WiFiClient(); // Wifi Client reconnect issue 4497 (https://github.com/esp8266/Arduino/issues/4497)
2019-06-07 17:03:34 +01:00
MqttClient . setClient ( EspClient ) ;
2018-10-10 21:21:44 +01:00
# endif
2019-08-15 12:50:28 +01:00
if ( 2 = = Mqtt . initial_connection_state ) { // Executed once just after power on and wifi is connected
Mqtt . initial_connection_state = 1 ;
2018-10-10 21:21:44 +01:00
}
2019-07-26 08:52:14 +01:00
MqttClient . setCallback ( MqttDataHandler ) ;
2019-06-30 17:50:42 +01:00
# if defined(USE_MQTT_TLS) && defined(USE_MQTT_AWS_IOT)
2019-08-04 18:42:21 +01:00
// re-assign private keys in case it was updated in between
2020-09-14 20:48:32 +01:00
if ( Mqtt . mqtt_tls ) {
if ( ( nullptr ! = AWS_IoT_Private_Key ) & & ( nullptr ! = AWS_IoT_Client_Certificate ) ) {
tlsClient - > setClientECCert ( AWS_IoT_Client_Certificate ,
AWS_IoT_Private_Key ,
0xFFFF /* all usages, don't care */ , 0 ) ;
}
2020-08-12 16:20:37 +01:00
}
2019-06-05 10:44:52 +01:00
# endif
2019-12-16 14:13:57 +00:00
MqttClient . setServer ( SettingsText ( SET_MQTT_HOST ) , Settings . mqtt_port ) ;
2019-06-10 11:06:03 +01:00
uint32_t mqtt_connect_time = millis ( ) ;
2019-06-10 18:58:57 +01:00
# if defined(USE_MQTT_TLS) && !defined(USE_MQTT_TLS_CA_CERT)
2020-08-12 16:20:37 +01:00
bool allow_all_fingerprints ;
bool learn_fingerprint1 ;
bool learn_fingerprint2 ;
2020-09-14 20:48:32 +01:00
if ( Mqtt . mqtt_tls ) {
2020-08-12 16:20:37 +01:00
allow_all_fingerprints = false ;
learn_fingerprint1 = is_fingerprint_mono_value ( Settings . mqtt_fingerprint [ 0 ] , 0x00 ) ;
learn_fingerprint2 = is_fingerprint_mono_value ( Settings . mqtt_fingerprint [ 1 ] , 0x00 ) ;
allow_all_fingerprints | = is_fingerprint_mono_value ( Settings . mqtt_fingerprint [ 0 ] , 0xff ) ;
allow_all_fingerprints | = is_fingerprint_mono_value ( Settings . mqtt_fingerprint [ 1 ] , 0xff ) ;
allow_all_fingerprints | = learn_fingerprint1 ;
allow_all_fingerprints | = learn_fingerprint2 ;
tlsClient - > setPubKeyFingerprint ( Settings . mqtt_fingerprint [ 0 ] , Settings . mqtt_fingerprint [ 1 ] , allow_all_fingerprints ) ;
}
2019-06-10 11:06:03 +01:00
# endif
2020-08-12 16:20:37 +01:00
bool lwt_retain = Settings . flag4 . mqtt_no_retain ? false : true ; // no retained last will if "no_retain"
2019-06-30 17:50:42 +01:00
# if defined(USE_MQTT_TLS) && defined(USE_MQTT_AWS_IOT)
2020-09-14 20:48:32 +01:00
if ( Mqtt . mqtt_tls ) {
if ( ( nullptr ! = AWS_IoT_Private_Key ) & & ( nullptr ! = AWS_IoT_Client_Certificate ) ) {
// if private key is there, we remove user/pwd
mqtt_user = nullptr ;
mqtt_pwd = nullptr ;
}
2020-08-12 16:20:37 +01:00
}
2019-06-05 10:44:52 +01:00
# endif
2020-08-12 16:20:37 +01:00
2020-10-30 11:29:48 +00:00
if ( MqttClient . connect ( TasmotaGlobal . mqtt_client , mqtt_user , mqtt_pwd , stopic , 1 , lwt_retain , TasmotaGlobal . mqtt_data , MQTT_CLEAN_SESSION ) ) {
2019-06-10 11:06:03 +01:00
# ifdef USE_MQTT_TLS
2020-09-14 20:48:32 +01:00
if ( Mqtt . mqtt_tls ) {
2021-01-15 17:23:05 +00:00
# ifdef ESP8266
2021-01-23 15:26:23 +00:00
AddLog ( LOG_LEVEL_INFO , PSTR ( D_LOG_MQTT " TLS connected in %d ms, max ThunkStack used %d " ) ,
2020-08-12 16:20:37 +01:00
millis ( ) - mqtt_connect_time , tlsClient - > getMaxThunkStackUse ( ) ) ;
2021-01-15 17:23:05 +00:00
# elif defined(ESP32)
2021-01-23 15:26:23 +00:00
AddLog ( LOG_LEVEL_INFO , PSTR ( D_LOG_MQTT " TLS connected in %d ms, stack low mark %d " ) ,
2021-01-15 17:23:05 +00:00
millis ( ) - mqtt_connect_time , uxTaskGetStackHighWaterMark ( nullptr ) ) ;
# endif
2020-08-12 16:20:37 +01:00
if ( ! tlsClient - > getMFLNStatus ( ) ) {
2021-01-23 15:26:23 +00:00
AddLog ( LOG_LEVEL_INFO , PSTR ( D_LOG_MQTT " MFLN not supported by TLS server " ) ) ;
2020-08-12 16:20:37 +01:00
}
2019-06-10 18:58:57 +01:00
# ifndef USE_MQTT_TLS_CA_CERT // don't bother with fingerprints if using CA validation
2020-08-12 16:20:37 +01:00
const uint8_t * recv_fingerprint = tlsClient - > getRecvPubKeyFingerprint ( ) ;
// create a printable version of the fingerprint received
char buf_fingerprint [ 64 ] ;
ToHex_P ( recv_fingerprint , 20 , buf_fingerprint , sizeof ( buf_fingerprint ) , ' ' ) ;
2021-01-23 15:26:23 +00:00
AddLog ( LOG_LEVEL_DEBUG , PSTR ( D_LOG_MQTT " Server fingerprint: %s " ) , buf_fingerprint ) ;
2020-08-12 16:20:37 +01:00
bool learned = false ;
// If the fingerprint slot is marked for update, we'll do so.
// Otherwise, if the fingerprint slot had the magic trust-on-first-use
// value, we will save the current fingerprint there, but only if the other fingerprint slot
// *didn't* match it.
if ( recv_fingerprint [ 20 ] & 0x1 | | ( learn_fingerprint1 & & 0 ! = memcmp ( recv_fingerprint , Settings . mqtt_fingerprint [ 1 ] , 20 ) ) ) {
memcpy ( Settings . mqtt_fingerprint [ 0 ] , recv_fingerprint , 20 ) ;
learned = true ;
}
// As above, but for the other slot.
if ( recv_fingerprint [ 20 ] & 0x2 | | ( learn_fingerprint2 & & 0 ! = memcmp ( recv_fingerprint , Settings . mqtt_fingerprint [ 0 ] , 20 ) ) ) {
memcpy ( Settings . mqtt_fingerprint [ 1 ] , recv_fingerprint , 20 ) ;
learned = true ;
}
2020-07-16 15:46:30 +01:00
2020-08-12 16:20:37 +01:00
if ( learned ) {
2021-01-23 15:26:23 +00:00
AddLog ( LOG_LEVEL_INFO , PSTR ( D_LOG_MQTT " Fingerprint learned: %s " ) , buf_fingerprint ) ;
2020-07-16 15:46:30 +01:00
2020-08-12 16:20:37 +01:00
SettingsSaveAll ( ) ; // save settings
}
2019-06-10 18:58:57 +01:00
# endif // !USE_MQTT_TLS_CA_CERT
2020-08-12 16:20:37 +01:00
}
2019-06-10 11:06:03 +01:00
# endif // USE_MQTT_TLS
2018-10-10 21:21:44 +01:00
MqttConnected ( ) ;
} else {
2019-06-10 11:06:03 +01:00
# ifdef USE_MQTT_TLS
2020-09-14 20:48:32 +01:00
if ( Mqtt . mqtt_tls ) {
2021-01-23 15:26:23 +00:00
AddLog ( LOG_LEVEL_INFO , PSTR ( D_LOG_MQTT " TLS connection error: %d " ) , tlsClient - > getLastError ( ) ) ;
2020-08-12 16:20:37 +01:00
}
2019-06-05 10:44:52 +01:00
# endif
2018-10-10 21:21:44 +01:00
MqttDisconnected ( MqttClient . state ( ) ) ; // status codes are documented here http://pubsubclient.knolleary.net/api.html#state
}
}
2020-12-26 11:18:16 +00:00
void MqttCheck ( void ) {
2019-11-03 11:33:36 +00:00
if ( Settings . flag . mqtt_enabled ) { // SetOption3 - Enable MQTT
2018-10-10 21:21:44 +01:00
if ( ! MqttIsConnected ( ) ) {
2020-10-30 11:29:48 +00:00
TasmotaGlobal . global_state . mqtt_down = 1 ;
2019-08-15 12:50:28 +01:00
if ( ! Mqtt . retry_counter ) {
2018-10-10 21:21:44 +01:00
MqttReconnect ( ) ;
} else {
2019-08-15 12:50:28 +01:00
Mqtt . retry_counter - - ;
2018-10-10 21:21:44 +01:00
}
} else {
2020-10-30 11:29:48 +00:00
TasmotaGlobal . global_state . mqtt_down = 0 ;
2018-10-10 21:21:44 +01:00
}
} else {
2020-10-30 11:29:48 +00:00
TasmotaGlobal . global_state . mqtt_down = 0 ;
2020-01-25 12:45:26 +00:00
if ( Mqtt . initial_connection_state ) {
MqttReconnect ( ) ;
}
2018-10-10 21:21:44 +01:00
}
}
2020-12-26 11:18:16 +00:00
bool KeyTopicActive ( uint32_t key ) {
2020-03-12 11:11:33 +00:00
// key = 0 - Button topic
// key = 1 - Switch topic
key & = 1 ;
char key_topic [ TOPSZ ] ;
Format ( key_topic , SettingsText ( SET_MQTT_BUTTON_TOPIC + key ) , sizeof ( key_topic ) ) ;
return ( ( strlen ( key_topic ) ! = 0 ) & & strcmp ( key_topic , " 0 " ) ) ;
}
2019-07-28 16:14:20 +01:00
/*********************************************************************************************\
* Commands
\ * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
2018-10-10 21:21:44 +01:00
2019-06-10 18:58:57 +01:00
# if defined(USE_MQTT_TLS) && !defined(USE_MQTT_TLS_CA_CERT)
2020-12-26 11:18:16 +00:00
void CmndMqttFingerprint ( void ) {
2019-07-28 16:14:20 +01:00
if ( ( XdrvMailbox . index > 0 ) & & ( XdrvMailbox . index < = 2 ) ) {
2018-10-10 21:21:44 +01:00
char fingerprint [ 60 ] ;
2019-07-28 16:14:20 +01:00
if ( ( XdrvMailbox . data_len > 0 ) & & ( XdrvMailbox . data_len < sizeof ( fingerprint ) ) ) {
2020-10-21 10:19:59 +01:00
if ( SC_DEFAULT = = Shortcut ( ) ) {
memcpy_P ( Settings . mqtt_fingerprint [ XdrvMailbox . index - 1 ] , ( 1 = = XdrvMailbox . index ) ? default_fingerprint1 : default_fingerprint2 , sizeof ( default_fingerprint1 ) ) ;
} else {
strlcpy ( fingerprint , ( SC_CLEAR = = Shortcut ( ) ) ? " " : XdrvMailbox . data , sizeof ( fingerprint ) ) ;
char * p = fingerprint ;
for ( uint32_t i = 0 ; i < 20 ; i + + ) {
Settings . mqtt_fingerprint [ XdrvMailbox . index - 1 ] [ i ] = strtol ( p , & p , 16 ) ;
}
2018-10-10 21:21:44 +01:00
}
2020-10-29 11:21:24 +00:00
TasmotaGlobal . restart_flag = 2 ;
2018-10-10 21:21:44 +01:00
}
2019-08-13 18:53:12 +01:00
ResponseCmndIdxChar ( ToHex_P ( ( unsigned char * ) Settings . mqtt_fingerprint [ XdrvMailbox . index - 1 ] , 20 , fingerprint , sizeof ( fingerprint ) , ' ' ) ) ;
2018-10-10 21:21:44 +01:00
}
2019-07-28 16:14:20 +01:00
}
2018-10-10 21:21:44 +01:00
# endif
2019-07-28 16:14:20 +01:00
2020-12-26 11:18:16 +00:00
void CmndMqttUser ( void ) {
2019-12-16 14:13:57 +00:00
if ( XdrvMailbox . data_len > 0 ) {
2021-01-18 20:48:04 +00:00
SettingsUpdateText ( SET_MQTT_USER , ( SC_CLEAR = = Shortcut ( ) ) ? " " : ( SC_DEFAULT = = Shortcut ( ) ) ? PSTR ( MQTT_USER ) : XdrvMailbox . data ) ;
2020-10-29 11:21:24 +00:00
TasmotaGlobal . restart_flag = 2 ;
2018-10-10 21:21:44 +01:00
}
2019-12-16 14:13:57 +00:00
ResponseCmndChar ( SettingsText ( SET_MQTT_USER ) ) ;
2019-07-28 16:14:20 +01:00
}
2020-12-26 11:18:16 +00:00
void CmndMqttPassword ( void ) {
2019-12-16 14:13:57 +00:00
if ( XdrvMailbox . data_len > 0 ) {
2021-01-18 20:48:04 +00:00
SettingsUpdateText ( SET_MQTT_PWD , ( SC_CLEAR = = Shortcut ( ) ) ? " " : ( SC_DEFAULT = = Shortcut ( ) ) ? PSTR ( MQTT_PASS ) : XdrvMailbox . data ) ;
2019-12-16 14:13:57 +00:00
ResponseCmndChar ( SettingsText ( SET_MQTT_PWD ) ) ;
2020-10-29 11:21:24 +00:00
TasmotaGlobal . restart_flag = 2 ;
2019-07-28 16:14:20 +01:00
} else {
Response_P ( S_JSON_COMMAND_ASTERISK , XdrvMailbox . command ) ;
2018-10-10 21:21:44 +01:00
}
2019-07-28 16:14:20 +01:00
}
2020-12-26 11:18:16 +00:00
void CmndMqttlog ( void ) {
2019-10-24 07:55:00 +01:00
if ( ( XdrvMailbox . payload > = LOG_LEVEL_NONE ) & & ( XdrvMailbox . payload < = LOG_LEVEL_DEBUG_MORE ) ) {
2019-09-27 17:13:00 +01:00
Settings . mqttlog_level = XdrvMailbox . payload ;
}
ResponseCmndNumber ( Settings . mqttlog_level ) ;
}
2020-12-26 11:18:16 +00:00
void CmndMqttHost ( void ) {
2019-12-16 14:13:57 +00:00
if ( XdrvMailbox . data_len > 0 ) {
SettingsUpdateText ( SET_MQTT_HOST , ( SC_CLEAR = = Shortcut ( ) ) ? " " : ( SC_DEFAULT = = Shortcut ( ) ) ? MQTT_HOST : XdrvMailbox . data ) ;
2020-10-29 11:21:24 +00:00
TasmotaGlobal . restart_flag = 2 ;
2019-07-28 16:14:20 +01:00
}
2019-12-16 14:13:57 +00:00
ResponseCmndChar ( SettingsText ( SET_MQTT_HOST ) ) ;
2019-07-28 16:14:20 +01:00
}
2020-12-26 11:18:16 +00:00
void CmndMqttPort ( void ) {
2019-07-28 16:14:20 +01:00
if ( ( XdrvMailbox . payload > 0 ) & & ( XdrvMailbox . payload < 65536 ) ) {
Settings . mqtt_port = ( 1 = = XdrvMailbox . payload ) ? MQTT_PORT : XdrvMailbox . payload ;
2020-10-29 11:21:24 +00:00
TasmotaGlobal . restart_flag = 2 ;
2019-07-28 16:14:20 +01:00
}
2019-08-03 12:01:34 +01:00
ResponseCmndNumber ( Settings . mqtt_port ) ;
2019-07-28 16:14:20 +01:00
}
2020-12-26 11:18:16 +00:00
void CmndMqttRetry ( void ) {
2019-07-28 16:14:20 +01:00
if ( ( XdrvMailbox . payload > = MQTT_RETRY_SECS ) & & ( XdrvMailbox . payload < 32001 ) ) {
Settings . mqtt_retry = XdrvMailbox . payload ;
2019-08-15 12:50:28 +01:00
Mqtt . retry_counter = Settings . mqtt_retry ;
2019-07-28 16:14:20 +01:00
}
2019-08-03 12:01:34 +01:00
ResponseCmndNumber ( Settings . mqtt_retry ) ;
2019-07-28 16:14:20 +01:00
}
2020-12-26 11:18:16 +00:00
void CmndStateText ( void ) {
2020-01-12 12:10:21 +00:00
if ( ( XdrvMailbox . index > 0 ) & & ( XdrvMailbox . index < = MAX_STATE_TEXT ) ) {
if ( ! XdrvMailbox . usridx ) {
ResponseCmndAll ( SET_STATE_TXT1 , MAX_STATE_TEXT ) ;
} else {
if ( XdrvMailbox . data_len > 0 ) {
for ( uint32_t i = 0 ; i < = XdrvMailbox . data_len ; i + + ) {
if ( XdrvMailbox . data [ i ] = = ' ' ) XdrvMailbox . data [ i ] = ' _ ' ;
}
SettingsUpdateText ( SET_STATE_TXT1 + XdrvMailbox . index - 1 , XdrvMailbox . data ) ;
2018-10-10 21:21:44 +01:00
}
2020-01-12 12:10:21 +00:00
ResponseCmndIdxChar ( GetStateText ( XdrvMailbox . index - 1 ) ) ;
2019-07-28 16:14:20 +01:00
}
}
}
2020-12-26 11:18:16 +00:00
void CmndMqttClient ( void ) {
2019-12-16 14:13:57 +00:00
if ( ! XdrvMailbox . grpflg & & ( XdrvMailbox . data_len > 0 ) ) {
2021-01-18 20:48:04 +00:00
SettingsUpdateText ( SET_MQTT_CLIENT , ( SC_DEFAULT = = Shortcut ( ) ) ? PSTR ( MQTT_CLIENT_ID ) : XdrvMailbox . data ) ;
2020-10-29 11:21:24 +00:00
TasmotaGlobal . restart_flag = 2 ;
2019-07-28 16:14:20 +01:00
}
2019-12-16 14:13:57 +00:00
ResponseCmndChar ( SettingsText ( SET_MQTT_CLIENT ) ) ;
2019-07-28 16:14:20 +01:00
}
2020-12-26 11:18:16 +00:00
void CmndFullTopic ( void ) {
2019-12-16 14:13:57 +00:00
if ( XdrvMailbox . data_len > 0 ) {
2019-07-28 16:14:20 +01:00
MakeValidMqtt ( 1 , XdrvMailbox . data ) ;
2020-10-30 11:29:48 +00:00
if ( ! strcmp ( XdrvMailbox . data , TasmotaGlobal . mqtt_client ) ) { SetShortcutDefault ( ) ; }
2019-07-28 16:14:20 +01:00
char stemp1 [ TOPSZ ] ;
strlcpy ( stemp1 , ( SC_DEFAULT = = Shortcut ( ) ) ? MQTT_FULLTOPIC : XdrvMailbox . data , sizeof ( stemp1 ) ) ;
2019-12-16 14:13:57 +00:00
if ( strcmp ( stemp1 , SettingsText ( SET_MQTT_FULLTOPIC ) ) ) {
2020-09-27 11:51:50 +01:00
Response_P ( ( Settings . flag . mqtt_offline ) ? S_LWT_OFFLINE : " " ) ; // SetOption10 - Control MQTT LWT message format
MqttPublishPrefixTopic_P ( TELE , S_LWT , true ) ; // Offline or remove previous retained topic
2019-12-16 14:13:57 +00:00
SettingsUpdateText ( SET_MQTT_FULLTOPIC , stemp1 ) ;
2020-10-29 11:21:24 +00:00
TasmotaGlobal . restart_flag = 2 ;
2018-10-10 21:21:44 +01:00
}
}
2019-12-16 14:13:57 +00:00
ResponseCmndChar ( SettingsText ( SET_MQTT_FULLTOPIC ) ) ;
2019-07-28 16:14:20 +01:00
}
2020-12-26 11:18:16 +00:00
void CmndPrefix ( void ) {
2020-01-12 12:10:21 +00:00
if ( ( XdrvMailbox . index > 0 ) & & ( XdrvMailbox . index < = MAX_MQTT_PREFIXES ) ) {
if ( ! XdrvMailbox . usridx ) {
ResponseCmndAll ( SET_MQTTPREFIX1 , MAX_MQTT_PREFIXES ) ;
} else {
if ( XdrvMailbox . data_len > 0 ) {
MakeValidMqtt ( 0 , XdrvMailbox . data ) ;
SettingsUpdateText ( SET_MQTTPREFIX1 + XdrvMailbox . index - 1 ,
2021-01-18 20:48:04 +00:00
( SC_DEFAULT = = Shortcut ( ) ) ? ( 1 = = XdrvMailbox . index ) ? PSTR ( SUB_PREFIX ) : ( 2 = = XdrvMailbox . index ) ? PSTR ( PUB_PREFIX ) : PSTR ( PUB_PREFIX2 ) : XdrvMailbox . data ) ;
2020-10-29 11:21:24 +00:00
TasmotaGlobal . restart_flag = 2 ;
2020-01-12 12:10:21 +00:00
}
ResponseCmndIdxChar ( SettingsText ( SET_MQTTPREFIX1 + XdrvMailbox . index - 1 ) ) ;
2018-10-10 21:21:44 +01:00
}
}
2019-07-28 16:14:20 +01:00
}
2020-12-26 11:18:16 +00:00
void CmndPublish ( void ) {
// Allow wildcard character "#" as space replacement in topic (#10258)
// publish cmnd/theo#arends/power 2 ==> publish cmnd/theo arends/power 2
2019-07-28 16:14:20 +01:00
if ( XdrvMailbox . data_len > 0 ) {
2020-01-27 16:38:32 +00:00
char * payload_part ;
char * mqtt_part = strtok_r ( XdrvMailbox . data , " " , & payload_part ) ;
2019-07-28 16:14:20 +01:00
if ( mqtt_part ) {
char stemp1 [ TOPSZ ] ;
strlcpy ( stemp1 , mqtt_part , sizeof ( stemp1 ) ) ;
2020-12-26 11:18:16 +00:00
ReplaceChar ( stemp1 , ' # ' , ' ' ) ;
2020-01-27 16:38:32 +00:00
if ( ( payload_part ! = nullptr ) & & strlen ( payload_part ) ) {
2020-10-30 11:29:48 +00:00
strlcpy ( TasmotaGlobal . mqtt_data , payload_part , sizeof ( TasmotaGlobal . mqtt_data ) ) ;
2019-07-28 16:14:20 +01:00
} else {
2020-10-30 11:29:48 +00:00
ResponseClear ( ) ;
2018-10-10 21:21:44 +01:00
}
2020-01-18 14:34:01 +00:00
MqttPublish ( stemp1 , ( XdrvMailbox . index = = 2 ) ) ;
2019-08-03 12:01:34 +01:00
// ResponseCmndDone();
2020-10-30 11:29:48 +00:00
ResponseClear ( ) ;
2018-10-10 21:21:44 +01:00
}
}
2019-07-28 16:14:20 +01:00
}
2020-12-26 11:18:16 +00:00
void CmndGroupTopic ( void ) {
2020-03-28 15:48:36 +00:00
if ( ( XdrvMailbox . index > 0 ) & & ( XdrvMailbox . index < = MAX_GROUP_TOPICS ) ) {
if ( XdrvMailbox . data_len > 0 ) {
uint32_t settings_text_index = ( 1 = = XdrvMailbox . index ) ? SET_MQTT_GRP_TOPIC : SET_MQTT_GRP_TOPIC2 + XdrvMailbox . index - 2 ;
MakeValidMqtt ( 0 , XdrvMailbox . data ) ;
2020-10-30 11:29:48 +00:00
if ( ! strcmp ( XdrvMailbox . data , TasmotaGlobal . mqtt_client ) ) { SetShortcutDefault ( ) ; }
2021-01-18 20:48:04 +00:00
SettingsUpdateText ( settings_text_index , ( SC_CLEAR = = Shortcut ( ) ) ? " " : ( SC_DEFAULT = = Shortcut ( ) ) ? PSTR ( MQTT_GRPTOPIC ) : XdrvMailbox . data ) ;
2020-03-28 15:48:36 +00:00
// Eliminate duplicates, have at least one and fill from index 1
char stemp [ MAX_GROUP_TOPICS ] [ TOPSZ ] ;
uint32_t read_index = 0 ;
uint32_t real_index = SET_MQTT_GRP_TOPIC ;
for ( uint32_t i = 0 ; i < MAX_GROUP_TOPICS ; i + + ) {
if ( 1 = = i ) { real_index = SET_MQTT_GRP_TOPIC2 - 1 ; }
if ( strlen ( SettingsText ( real_index + i ) ) ) {
bool not_equal = true ;
for ( uint32_t j = 0 ; j < read_index ; j + + ) {
if ( ! strcmp ( SettingsText ( real_index + i ) , stemp [ j ] ) ) { // Topics are case-sensitive
not_equal = false ;
}
}
if ( not_equal ) {
strncpy ( stemp [ read_index ] , SettingsText ( real_index + i ) , sizeof ( stemp [ read_index ] ) ) ;
read_index + + ;
}
}
}
if ( 0 = = read_index ) {
2021-01-18 20:48:04 +00:00
SettingsUpdateText ( SET_MQTT_GRP_TOPIC , PSTR ( MQTT_GRPTOPIC ) ) ;
2020-03-28 15:48:36 +00:00
} else {
uint32_t write_index = 0 ;
uint32_t real_index = SET_MQTT_GRP_TOPIC ;
for ( uint32_t i = 0 ; i < MAX_GROUP_TOPICS ; i + + ) {
if ( 1 = = i ) { real_index = SET_MQTT_GRP_TOPIC2 - 1 ; }
if ( write_index < read_index ) {
SettingsUpdateText ( real_index + i , stemp [ write_index ] ) ;
write_index + + ;
} else {
SettingsUpdateText ( real_index + i , " " ) ;
}
}
}
2020-10-29 11:21:24 +00:00
TasmotaGlobal . restart_flag = 2 ;
2020-03-28 15:48:36 +00:00
}
ResponseCmndAll ( SET_MQTT_GRP_TOPIC , MAX_GROUP_TOPICS ) ;
2020-03-16 22:06:41 +00:00
}
2019-07-28 16:14:20 +01:00
}
2020-12-26 11:18:16 +00:00
void CmndTopic ( void ) {
2019-12-16 14:13:57 +00:00
if ( ! XdrvMailbox . grpflg & & ( XdrvMailbox . data_len > 0 ) ) {
2019-07-28 16:14:20 +01:00
MakeValidMqtt ( 0 , XdrvMailbox . data ) ;
2020-10-30 11:29:48 +00:00
if ( ! strcmp ( XdrvMailbox . data , TasmotaGlobal . mqtt_client ) ) { SetShortcutDefault ( ) ; }
2019-07-28 16:14:20 +01:00
char stemp1 [ TOPSZ ] ;
strlcpy ( stemp1 , ( SC_DEFAULT = = Shortcut ( ) ) ? MQTT_TOPIC : XdrvMailbox . data , sizeof ( stemp1 ) ) ;
2019-12-16 14:13:57 +00:00
if ( strcmp ( stemp1 , SettingsText ( SET_MQTT_TOPIC ) ) ) {
2020-09-27 11:51:50 +01:00
Response_P ( ( Settings . flag . mqtt_offline ) ? S_LWT_OFFLINE : " " ) ; // SetOption10 - Control MQTT LWT message format
MqttPublishPrefixTopic_P ( TELE , S_LWT , true ) ; // Offline or remove previous retained topic
2019-12-16 14:13:57 +00:00
SettingsUpdateText ( SET_MQTT_TOPIC , stemp1 ) ;
2020-10-29 11:21:24 +00:00
TasmotaGlobal . restart_flag = 2 ;
2018-10-10 21:21:44 +01:00
}
2019-07-28 16:14:20 +01:00
}
2019-12-16 14:13:57 +00:00
ResponseCmndChar ( SettingsText ( SET_MQTT_TOPIC ) ) ;
2019-07-28 16:14:20 +01:00
}
2020-12-26 11:18:16 +00:00
void CmndButtonTopic ( void ) {
2019-12-16 14:13:57 +00:00
if ( ! XdrvMailbox . grpflg & & ( XdrvMailbox . data_len > 0 ) ) {
2019-07-28 16:14:20 +01:00
MakeValidMqtt ( 0 , XdrvMailbox . data ) ;
2020-10-30 11:29:48 +00:00
if ( ! strcmp ( XdrvMailbox . data , TasmotaGlobal . mqtt_client ) ) { SetShortcutDefault ( ) ; }
2019-07-28 16:14:20 +01:00
switch ( Shortcut ( ) ) {
2019-12-16 14:13:57 +00:00
case SC_CLEAR : SettingsUpdateText ( SET_MQTT_BUTTON_TOPIC , " " ) ; break ;
2020-10-30 11:29:48 +00:00
case SC_DEFAULT : SettingsUpdateText ( SET_MQTT_BUTTON_TOPIC , TasmotaGlobal . mqtt_topic ) ; break ;
2019-12-16 14:13:57 +00:00
case SC_USER : SettingsUpdateText ( SET_MQTT_BUTTON_TOPIC , MQTT_BUTTON_TOPIC ) ; break ;
default : SettingsUpdateText ( SET_MQTT_BUTTON_TOPIC , XdrvMailbox . data ) ;
2018-10-10 21:21:44 +01:00
}
}
2019-12-16 14:13:57 +00:00
ResponseCmndChar ( SettingsText ( SET_MQTT_BUTTON_TOPIC ) ) ;
2019-07-28 16:14:20 +01:00
}
2020-12-26 11:18:16 +00:00
void CmndSwitchTopic ( void ) {
2019-12-16 14:13:57 +00:00
if ( ! XdrvMailbox . grpflg & & ( XdrvMailbox . data_len > 0 ) ) {
2019-07-28 16:14:20 +01:00
MakeValidMqtt ( 0 , XdrvMailbox . data ) ;
2020-10-30 11:29:48 +00:00
if ( ! strcmp ( XdrvMailbox . data , TasmotaGlobal . mqtt_client ) ) { SetShortcutDefault ( ) ; }
2019-07-28 16:14:20 +01:00
switch ( Shortcut ( ) ) {
2019-12-16 14:13:57 +00:00
case SC_CLEAR : SettingsUpdateText ( SET_MQTT_SWITCH_TOPIC , " " ) ; break ;
2020-10-30 11:29:48 +00:00
case SC_DEFAULT : SettingsUpdateText ( SET_MQTT_SWITCH_TOPIC , TasmotaGlobal . mqtt_topic ) ; break ;
2021-01-18 20:48:04 +00:00
case SC_USER : SettingsUpdateText ( SET_MQTT_SWITCH_TOPIC , PSTR ( MQTT_SWITCH_TOPIC ) ) ; break ;
2019-12-16 14:13:57 +00:00
default : SettingsUpdateText ( SET_MQTT_SWITCH_TOPIC , XdrvMailbox . data ) ;
2018-10-10 21:21:44 +01:00
}
}
2019-12-16 14:13:57 +00:00
ResponseCmndChar ( SettingsText ( SET_MQTT_SWITCH_TOPIC ) ) ;
2019-07-28 16:14:20 +01:00
}
2020-12-26 11:18:16 +00:00
void CmndButtonRetain ( void ) {
2019-07-28 16:14:20 +01:00
if ( ( XdrvMailbox . payload > = 0 ) & & ( XdrvMailbox . payload < = 1 ) ) {
if ( ! XdrvMailbox . payload ) {
for ( uint32_t i = 1 ; i < = MAX_KEYS ; i + + ) {
2019-09-04 11:20:04 +01:00
SendKey ( KEY_BUTTON , i , CLEAR_RETAIN ) ; // Clear MQTT retain in broker
2018-10-10 21:21:44 +01:00
}
}
2019-11-03 11:33:36 +00:00
Settings . flag . mqtt_button_retain = XdrvMailbox . payload ; // CMND_BUTTONRETAIN
2019-07-28 16:14:20 +01:00
}
2019-11-03 11:33:36 +00:00
ResponseCmndStateText ( Settings . flag . mqtt_button_retain ) ; // CMND_BUTTONRETAIN
2019-07-28 16:14:20 +01:00
}
2020-12-26 11:18:16 +00:00
void CmndSwitchRetain ( void ) {
2019-07-28 16:14:20 +01:00
if ( ( XdrvMailbox . payload > = 0 ) & & ( XdrvMailbox . payload < = 1 ) ) {
if ( ! XdrvMailbox . payload ) {
for ( uint32_t i = 1 ; i < = MAX_SWITCHES ; i + + ) {
2019-09-04 11:20:04 +01:00
SendKey ( KEY_SWITCH , i , CLEAR_RETAIN ) ; // Clear MQTT retain in broker
2018-10-10 21:21:44 +01:00
}
}
2019-11-03 11:33:36 +00:00
Settings . flag . mqtt_switch_retain = XdrvMailbox . payload ; // CMND_SWITCHRETAIN
2018-10-10 21:21:44 +01:00
}
2019-11-03 11:33:36 +00:00
ResponseCmndStateText ( Settings . flag . mqtt_switch_retain ) ; // CMND_SWITCHRETAIN
2019-07-28 16:14:20 +01:00
}
2020-12-26 11:18:16 +00:00
void CmndPowerRetain ( void ) {
2019-07-28 16:14:20 +01:00
if ( ( XdrvMailbox . payload > = 0 ) & & ( XdrvMailbox . payload < = 1 ) ) {
if ( ! XdrvMailbox . payload ) {
char stemp1 [ TOPSZ ] ;
char scommand [ CMDSZ ] ;
2020-10-30 11:29:48 +00:00
for ( uint32_t i = 1 ; i < = TasmotaGlobal . devices_present ; i + + ) { // Clear MQTT retain in broker
GetTopic_P ( stemp1 , STAT , TasmotaGlobal . mqtt_topic , GetPowerDevice ( scommand , i , sizeof ( scommand ) , Settings . flag . device_index_enable ) ) ; // SetOption26 - Switch between POWER or POWER1
ResponseClear ( ) ;
2019-11-03 11:33:36 +00:00
MqttPublish ( stemp1 , Settings . flag . mqtt_power_retain ) ; // CMND_POWERRETAIN
2018-10-10 21:21:44 +01:00
}
}
2019-11-03 11:33:36 +00:00
Settings . flag . mqtt_power_retain = XdrvMailbox . payload ; // CMND_POWERRETAIN
2020-04-18 15:30:36 +01:00
if ( Settings . flag . mqtt_power_retain ) {
Settings . flag4 . only_json_message = 0 ; // SetOption90 - Disable non-json MQTT response
}
2018-10-10 21:21:44 +01:00
}
2019-11-03 11:33:36 +00:00
ResponseCmndStateText ( Settings . flag . mqtt_power_retain ) ; // CMND_POWERRETAIN
2019-07-28 16:14:20 +01:00
}
2018-10-10 21:21:44 +01:00
2020-12-26 11:18:16 +00:00
void CmndSensorRetain ( void ) {
2019-07-28 16:14:20 +01:00
if ( ( XdrvMailbox . payload > = 0 ) & & ( XdrvMailbox . payload < = 1 ) ) {
if ( ! XdrvMailbox . payload ) {
2020-10-30 11:29:48 +00:00
ResponseClear ( ) ;
2019-11-03 11:33:36 +00:00
MqttPublishPrefixTopic_P ( TELE , PSTR ( D_RSLT_SENSOR ) , Settings . flag . mqtt_sensor_retain ) ; // CMND_SENSORRETAIN
MqttPublishPrefixTopic_P ( TELE , PSTR ( D_RSLT_ENERGY ) , Settings . flag . mqtt_sensor_retain ) ; // CMND_SENSORRETAIN
2019-07-28 16:14:20 +01:00
}
2019-11-03 11:33:36 +00:00
Settings . flag . mqtt_sensor_retain = XdrvMailbox . payload ; // CMND_SENSORRETAIN
2019-07-28 16:14:20 +01:00
}
2019-11-03 11:33:36 +00:00
ResponseCmndStateText ( Settings . flag . mqtt_sensor_retain ) ; // CMND_SENSORRETAIN
2018-10-10 21:21:44 +01:00
}
2021-02-22 08:11:36 +00:00
void CmndInfoRetain ( void ) {
if ( ( XdrvMailbox . payload > = 0 ) & & ( XdrvMailbox . payload < = 1 ) ) {
if ( ! XdrvMailbox . payload ) {
ResponseClear ( ) ;
MqttPublishPrefixTopic_P ( TELE , PSTR ( D_RSLT_INFO ) , Settings . flag5 . mqtt_info_retain ) ; // CMND_INFORETAIN
}
Settings . flag5 . mqtt_info_retain = XdrvMailbox . payload ; // CMND_INFORETAIN
}
ResponseCmndStateText ( Settings . flag5 . mqtt_info_retain ) ; // CMND_INFORETAIN
}
void CmndStateRetain ( void ) {
if ( ( XdrvMailbox . payload > = 0 ) & & ( XdrvMailbox . payload < = 1 ) ) {
if ( ! XdrvMailbox . payload ) {
ResponseClear ( ) ;
MqttPublishPrefixTopic_P ( STAT , PSTR ( D_RSLT_STATE ) , Settings . flag5 . mqtt_state_retain ) ; // CMND_STATERETAIN
}
Settings . flag5 . mqtt_state_retain = XdrvMailbox . payload ; // CMND_STATERETAIN
}
ResponseCmndStateText ( Settings . flag5 . mqtt_state_retain ) ; // CMND_STATERETAIN
}
2019-08-04 18:42:21 +01:00
/*********************************************************************************************\
* TLS private key and certificate - store into Flash
\ * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
# if defined(USE_MQTT_TLS) && defined(USE_MQTT_AWS_IOT)
2021-01-22 10:54:15 +00:00
// const static uint16_t tls_spi_start_sector = EEPROM_LOCATION + 4; // 0xXXFF
2020-01-17 23:02:01 +00:00
// const static uint8_t* tls_spi_start = (uint8_t*) ((tls_spi_start_sector * SPI_FLASH_SEC_SIZE) + 0x40200000); // 0x40XFF000
const static uint16_t tls_spi_start_sector = 0xFF ; // Force last bank of first MB
const static uint8_t * tls_spi_start = ( uint8_t * ) 0x402FF000 ; // 0x402FF000
2019-08-04 18:42:21 +01:00
const static size_t tls_spi_len = 0x1000 ; // 4kb blocs
const static size_t tls_block_offset = 0x0400 ;
const static size_t tls_block_len = 0x0400 ; // 1kb
const static size_t tls_obj_store_offset = tls_block_offset + sizeof ( tls_dir_t ) ;
inline void TlsEraseBuffer ( uint8_t * buffer ) {
memset ( buffer + tls_block_offset , 0xFF , tls_block_len ) ;
}
// static data structures for Private Key and Certificate, only the pointer
// to binary data will change to a region in SPI Flash
static br_ec_private_key EC = {
23 ,
nullptr , 0
} ;
static br_x509_certificate CHAIN [ ] = {
{ nullptr , 0 }
} ;
// load a copy of the tls_dir from flash into ram
// and calculate the appropriate data structures for AWS_IoT_Private_Key and AWS_IoT_Client_Certificate
void loadTlsDir ( void ) {
memcpy_P ( & tls_dir , tls_spi_start + tls_block_offset , sizeof ( tls_dir ) ) ;
// calculate the addresses for Key and Cert in Flash
if ( ( TLS_NAME_SKEY = = tls_dir . entry [ 0 ] . name ) & & ( tls_dir . entry [ 0 ] . len > 0 ) ) {
EC . x = ( unsigned char * ) ( tls_spi_start + tls_obj_store_offset + tls_dir . entry [ 0 ] . start ) ;
EC . xlen = tls_dir . entry [ 0 ] . len ;
AWS_IoT_Private_Key = & EC ;
} else {
AWS_IoT_Private_Key = nullptr ;
}
if ( ( TLS_NAME_CRT = = tls_dir . entry [ 1 ] . name ) & & ( tls_dir . entry [ 1 ] . len > 0 ) ) {
CHAIN [ 0 ] . data = ( unsigned char * ) ( tls_spi_start + tls_obj_store_offset + tls_dir . entry [ 1 ] . start ) ;
CHAIN [ 0 ] . data_len = tls_dir . entry [ 1 ] . len ;
AWS_IoT_Client_Certificate = CHAIN ;
} else {
AWS_IoT_Client_Certificate = nullptr ;
}
//Serial.printf("AWS_IoT_Private_Key = %x, AWS_IoT_Client_Certificate = %x\n", AWS_IoT_Private_Key, AWS_IoT_Client_Certificate);
}
const char ALLOCATE_ERROR [ ] PROGMEM = " TLSKey " D_JSON_ERROR " : cannot allocate buffer. " ;
void CmndTlsKey ( void ) {
# ifdef DEBUG_DUMP_TLS
if ( 0 = = XdrvMailbox . index ) {
CmndTlsDump ( ) ;
}
# endif // DEBUG_DUMP_TLS
if ( ( XdrvMailbox . index > = 1 ) & & ( XdrvMailbox . index < = 2 ) ) {
tls_dir_t * tls_dir_write ;
if ( XdrvMailbox . data_len > 0 ) { // write new value
// first copy SPI buffer into ram
uint8_t * spi_buffer = ( uint8_t * ) malloc ( tls_spi_len ) ;
if ( ! spi_buffer ) {
2021-01-23 15:26:23 +00:00
AddLog ( LOG_LEVEL_ERROR , ALLOCATE_ERROR ) ;
2019-08-04 18:42:21 +01:00
return ;
}
memcpy_P ( spi_buffer , tls_spi_start , tls_spi_len ) ;
2019-12-07 14:01:39 +00:00
// remove any white space from the base64
2020-10-10 16:00:37 +01:00
RemoveSpace ( XdrvMailbox . data ) ;
2019-12-07 14:01:39 +00:00
2019-08-04 18:42:21 +01:00
// allocate buffer for decoded base64
uint32_t bin_len = decode_base64_length ( ( unsigned char * ) XdrvMailbox . data ) ;
uint8_t * bin_buf = nullptr ;
if ( bin_len > 0 ) {
bin_buf = ( uint8_t * ) malloc ( bin_len + 4 ) ;
if ( ! bin_buf ) {
2021-01-23 15:26:23 +00:00
AddLog ( LOG_LEVEL_ERROR , ALLOCATE_ERROR ) ;
2019-08-04 18:42:21 +01:00
free ( spi_buffer ) ;
return ;
}
}
// decode base64
if ( bin_len > 0 ) {
decode_base64 ( ( unsigned char * ) XdrvMailbox . data , bin_buf ) ;
}
// address of writable tls_dir in buffer
tls_dir_write = ( tls_dir_t * ) ( spi_buffer + tls_block_offset ) ;
if ( 1 = = XdrvMailbox . index ) {
// Try to write Private key
// Start by erasing all
TlsEraseBuffer ( spi_buffer ) ; // Erase any previously stored data
if ( bin_len > 0 ) {
if ( bin_len ! = 32 ) {
// no private key was previously stored, abort
2021-01-23 15:26:23 +00:00
AddLog ( LOG_LEVEL_INFO , PSTR ( " TLSKey: Certificate must be 32 bytes: %d. " ) , bin_len ) ;
2019-08-04 18:42:21 +01:00
free ( spi_buffer ) ;
free ( bin_buf ) ;
return ;
}
tls_entry_t * entry = & tls_dir_write - > entry [ 0 ] ;
entry - > name = TLS_NAME_SKEY ;
entry - > start = 0 ;
entry - > len = bin_len ;
memcpy ( spi_buffer + tls_obj_store_offset + entry - > start , bin_buf , entry - > len ) ;
} else {
// if lenght is zero, simply erase this SPI flash area
}
} else if ( 2 = = XdrvMailbox . index ) {
// Try to write Certificate
if ( TLS_NAME_SKEY ! = tls_dir . entry [ 0 ] . name ) {
// no private key was previously stored, abort
2021-01-23 15:26:23 +00:00
AddLog ( LOG_LEVEL_INFO , PSTR ( " TLSKey: cannot store Cert if no Key previously stored. " ) ) ;
2019-08-04 18:42:21 +01:00
free ( spi_buffer ) ;
free ( bin_buf ) ;
return ;
}
if ( bin_len < = 256 ) {
// Certificate lenght too short
2021-01-23 15:26:23 +00:00
AddLog ( LOG_LEVEL_INFO , PSTR ( " TLSKey: Certificate length too short: %d. " ) , bin_len ) ;
2019-08-04 18:42:21 +01:00
free ( spi_buffer ) ;
free ( bin_buf ) ;
return ;
}
tls_entry_t * entry = & tls_dir_write - > entry [ 1 ] ;
entry - > name = TLS_NAME_CRT ;
entry - > start = ( tls_dir_write - > entry [ 0 ] . start + tls_dir_write - > entry [ 0 ] . len + 3 ) & ~ 0x03 ; // align to 4 bytes boundary
entry - > len = bin_len ;
memcpy ( spi_buffer + tls_obj_store_offset + entry - > start , bin_buf , entry - > len ) ;
}
2019-11-21 10:08:30 +00:00
if ( ESP . flashEraseSector ( tls_spi_start_sector ) ) {
ESP . flashWrite ( tls_spi_start_sector * SPI_FLASH_SEC_SIZE , ( uint32_t * ) spi_buffer , SPI_FLASH_SEC_SIZE ) ;
}
2019-08-04 18:42:21 +01:00
free ( spi_buffer ) ;
free ( bin_buf ) ;
}
loadTlsDir ( ) ; // reload into memory any potential change
Response_P ( PSTR ( " { \" %s1 \" :%d, \" %s2 \" :%d} " ) ,
XdrvMailbox . command , AWS_IoT_Private_Key ? tls_dir . entry [ 0 ] . len : - 1 ,
XdrvMailbox . command , AWS_IoT_Client_Certificate ? tls_dir . entry [ 1 ] . len : - 1 ) ;
}
}
# ifdef DEBUG_DUMP_TLS
// Dump TLS Flash data - don't activate in production to protect your private keys
uint32_t bswap32 ( uint32_t x ) {
return ( ( x < < 24 ) & 0xff000000 ) |
( ( x < < 8 ) & 0x00ff0000 ) |
( ( x > > 8 ) & 0x0000ff00 ) |
( ( x > > 24 ) & 0x000000ff ) ;
}
void CmndTlsDump ( void ) {
2019-08-05 11:15:15 +01:00
uint32_t start = ( uint32_t ) tls_spi_start + tls_block_offset ;
uint32_t end = start + tls_block_len - 1 ;
2019-08-04 18:42:21 +01:00
for ( uint32_t pos = start ; pos < end ; pos + = 0x10 ) {
2020-01-26 13:16:44 +00:00
uint32_t * values = ( uint32_t * ) ( pos ) ;
Serial . printf_P ( PSTR ( " %08x: %08x %08x %08x %08x \n " ) , pos , bswap32 ( values [ 0 ] ) , bswap32 ( values [ 1 ] ) , bswap32 ( values [ 2 ] ) , bswap32 ( values [ 3 ] ) ) ;
2019-08-04 18:42:21 +01:00
}
}
# endif // DEBUG_DUMP_TLS
# endif
2018-10-10 21:21:44 +01:00
/*********************************************************************************************\
* Presentation
\ * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
# ifdef USE_WEBSERVER
# define WEB_HANDLE_MQTT "mq"
const char S_CONFIGURE_MQTT [ ] PROGMEM = D_CONFIGURE_MQTT ;
const char HTTP_BTN_MENU_MQTT [ ] PROGMEM =
2019-02-13 15:05:25 +00:00
" <p><form action=' " WEB_HANDLE_MQTT " ' method='get'><button> " D_CONFIGURE_MQTT " </button></form></p> " ;
2018-10-10 21:21:44 +01:00
2019-03-04 17:16:07 +00:00
const char HTTP_FORM_MQTT1 [ ] PROGMEM =
2019-02-13 15:05:25 +00:00
" <fieldset><legend><b> " D_MQTT_PARAMETERS " </b></legend> "
" <form method='get' action=' " WEB_HANDLE_MQTT " '> "
2020-05-21 16:49:59 +01:00
" <p><b> " D_HOST " </b> ( " MQTT_HOST " )<br><input id='mh' placeholder= \" " MQTT_HOST " \" value= \" %s \" ></p> "
2019-05-31 17:24:56 +01:00
" <p><b> " D_PORT " </b> ( " STR ( MQTT_PORT ) " )<br><input id='ml' placeholder=' " STR ( MQTT_PORT ) " ' value='%d'></p> "
2020-08-12 16:20:37 +01:00
# ifdef USE_MQTT_TLS
" <p><label><input id='b3' type='checkbox'%s><b> " D_MQTT_TLS_ENABLE " </b></label><br> "
# endif // USE_MQTT_TLS
2020-05-21 16:49:59 +01:00
" <p><b> " D_CLIENT " </b> (%s)<br><input id='mc' placeholder= \" %s \" value= \" %s \" ></p> " ;
2019-03-04 17:16:07 +00:00
const char HTTP_FORM_MQTT2 [ ] PROGMEM =
2020-05-21 16:49:59 +01:00
" <p><b> " D_USER " </b> ( " MQTT_USER " )<br><input id='mu' placeholder= \" " MQTT_USER " \" value= \" %s \" ></p> "
" <p><label><b> " D_PASSWORD " </b><input type='checkbox' onclick='sp( \" mp \" )'></label><br><input id='mp' type='password' placeholder= \" " D_PASSWORD " \" value= \" " D_ASTERISK_PWD " \" ></p> "
" <p><b> " D_TOPIC " </b> = %%topic%% (%s)<br><input id='mt' placeholder= \" %s \" value= \" %s \" ></p> "
" <p><b> " D_FULL_TOPIC " </b> (%s)<br><input id='mf' placeholder= \" %s \" value= \" %s \" ></p> " ;
2018-10-10 21:21:44 +01:00
2018-11-14 13:32:09 +00:00
void HandleMqttConfiguration ( void )
2018-10-10 21:21:44 +01:00
{
2019-01-10 11:57:42 +00:00
if ( ! HttpCheckPriviledgedAccess ( ) ) { return ; }
2021-01-23 15:26:23 +00:00
AddLog ( LOG_LEVEL_DEBUG , PSTR ( D_LOG_HTTP D_CONFIGURE_MQTT ) ) ;
2018-10-10 21:21:44 +01:00
2021-01-18 20:48:04 +00:00
if ( Webserver - > hasArg ( F ( " save " ) ) ) {
2018-10-10 21:21:44 +01:00
MqttSaveSettings ( ) ;
2018-10-12 10:42:52 +01:00
WebRestart ( 1 ) ;
2018-10-10 21:21:44 +01:00
return ;
}
2019-12-22 14:23:52 +00:00
char str [ TOPSZ ] ;
2019-03-04 17:16:07 +00:00
2020-11-06 16:09:13 +00:00
WSContentStart_P ( PSTR ( D_CONFIGURE_MQTT ) ) ;
2019-03-04 17:16:07 +00:00
WSContentSendStyle ( ) ;
WSContentSend_P ( HTTP_FORM_MQTT1 ,
2019-12-16 14:13:57 +00:00
SettingsText ( SET_MQTT_HOST ) ,
2019-03-04 17:16:07 +00:00
Settings . mqtt_port ,
2020-08-12 16:20:37 +01:00
# ifdef USE_MQTT_TLS
2021-01-12 18:31:15 +00:00
Mqtt . mqtt_tls ? PSTR ( " checked " ) : " " , // SetOption102 - Enable MQTT TLS
2020-08-12 16:20:37 +01:00
# endif // USE_MQTT_TLS
2021-01-18 20:48:04 +00:00
Format ( str , PSTR ( MQTT_CLIENT_ID ) , sizeof ( str ) ) , PSTR ( MQTT_CLIENT_ID ) , SettingsText ( SET_MQTT_CLIENT ) ) ;
2019-03-04 17:16:07 +00:00
WSContentSend_P ( HTTP_FORM_MQTT2 ,
2019-12-16 14:13:57 +00:00
( ! strlen ( SettingsText ( SET_MQTT_USER ) ) ) ? " 0 " : SettingsText ( SET_MQTT_USER ) ,
2021-01-18 20:48:04 +00:00
Format ( str , PSTR ( MQTT_TOPIC ) , sizeof ( str ) ) , PSTR ( MQTT_TOPIC ) , SettingsText ( SET_MQTT_TOPIC ) ,
PSTR ( MQTT_FULLTOPIC ) , PSTR ( MQTT_FULLTOPIC ) , SettingsText ( SET_MQTT_FULLTOPIC ) ) ;
2019-03-10 14:36:34 +00:00
WSContentSend_P ( HTTP_FORM_END ) ;
2019-03-11 09:38:41 +00:00
WSContentSpaceButton ( BUTTON_CONFIGURATION ) ;
2019-03-16 15:23:41 +00:00
WSContentStop ( ) ;
2018-10-10 21:21:44 +01:00
}
2018-11-14 13:32:09 +00:00
void MqttSaveSettings ( void )
2018-10-10 21:21:44 +01:00
{
2019-12-22 14:23:52 +00:00
char tmp [ TOPSZ ] ;
2018-10-10 21:21:44 +01:00
char stemp [ TOPSZ ] ;
char stemp2 [ TOPSZ ] ;
2021-01-18 20:48:04 +00:00
WebGetArg ( PSTR ( " mt " ) , tmp , sizeof ( tmp ) ) ;
2018-10-10 21:21:44 +01:00
strlcpy ( stemp , ( ! strlen ( tmp ) ) ? MQTT_TOPIC : tmp , sizeof ( stemp ) ) ;
MakeValidMqtt ( 0 , stemp ) ;
2021-01-18 20:48:04 +00:00
WebGetArg ( PSTR ( " mf " ) , tmp , sizeof ( tmp ) ) ;
2018-10-10 21:21:44 +01:00
strlcpy ( stemp2 , ( ! strlen ( tmp ) ) ? MQTT_FULLTOPIC : tmp , sizeof ( stemp2 ) ) ;
2019-07-28 16:14:20 +01:00
MakeValidMqtt ( 1 , stemp2 ) ;
2019-12-16 14:13:57 +00:00
if ( ( strcmp ( stemp , SettingsText ( SET_MQTT_TOPIC ) ) ) | | ( strcmp ( stemp2 , SettingsText ( SET_MQTT_FULLTOPIC ) ) ) ) {
2020-09-27 11:51:50 +01:00
Response_P ( ( Settings . flag . mqtt_offline ) ? S_LWT_OFFLINE : " " ) ; // SetOption10 - Control MQTT LWT message format
2019-11-03 11:33:36 +00:00
MqttPublishPrefixTopic_P ( TELE , S_LWT , true ) ; // Offline or remove previous retained topic
2018-10-10 21:21:44 +01:00
}
2019-12-16 14:13:57 +00:00
SettingsUpdateText ( SET_MQTT_TOPIC , stemp ) ;
SettingsUpdateText ( SET_MQTT_FULLTOPIC , stemp2 ) ;
2021-01-18 20:48:04 +00:00
WebGetArg ( PSTR ( " mh " ) , tmp , sizeof ( tmp ) ) ;
SettingsUpdateText ( SET_MQTT_HOST , ( ! strlen ( tmp ) ) ? PSTR ( MQTT_HOST ) : ( ! strcmp ( tmp , " 0 " ) ) ? " " : tmp ) ;
WebGetArg ( PSTR ( " ml " ) , tmp , sizeof ( tmp ) ) ;
2018-10-10 21:21:44 +01:00
Settings . mqtt_port = ( ! strlen ( tmp ) ) ? MQTT_PORT : atoi ( tmp ) ;
2020-08-12 16:20:37 +01:00
# ifdef USE_MQTT_TLS
2021-01-18 20:48:04 +00:00
Settings . flag4 . mqtt_tls = Webserver - > hasArg ( F ( " b3 " ) ) ; // SetOption102 - Enable MQTT TLS
2020-08-12 16:20:37 +01:00
# endif
2021-01-18 20:48:04 +00:00
WebGetArg ( PSTR ( " mc " ) , tmp , sizeof ( tmp ) ) ;
SettingsUpdateText ( SET_MQTT_CLIENT , ( ! strlen ( tmp ) ) ? PSTR ( MQTT_CLIENT_ID ) : tmp ) ;
WebGetArg ( PSTR ( " mu " ) , tmp , sizeof ( tmp ) ) ;
SettingsUpdateText ( SET_MQTT_USER , ( ! strlen ( tmp ) ) ? PSTR ( MQTT_USER ) : ( ! strcmp ( tmp , " 0 " ) ) ? " " : tmp ) ;
WebGetArg ( PSTR ( " mp " ) , tmp , sizeof ( tmp ) ) ;
2019-12-16 14:13:57 +00:00
SettingsUpdateText ( SET_MQTT_PWD , ( ! strlen ( tmp ) ) ? " " : ( ! strcmp ( tmp , D_ASTERISK_PWD ) ) ? SettingsText ( SET_MQTT_PWD ) : tmp ) ;
2020-11-06 16:09:13 +00:00
AddLog_P ( LOG_LEVEL_INFO , PSTR ( D_LOG_MQTT D_CMND_MQTTHOST " %s, " D_CMND_MQTTPORT " %d, " D_CMND_MQTTCLIENT " %s, " D_CMND_MQTTUSER " %s, " D_CMND_TOPIC " %s, " D_CMND_FULLTOPIC " %s " ) ,
2019-12-16 14:13:57 +00:00
SettingsText ( SET_MQTT_HOST ) , Settings . mqtt_port , SettingsText ( SET_MQTT_CLIENT ) , SettingsText ( SET_MQTT_USER ) , SettingsText ( SET_MQTT_TOPIC ) , SettingsText ( SET_MQTT_FULLTOPIC ) ) ;
2018-10-10 21:21:44 +01:00
}
# endif // USE_WEBSERVER
/*********************************************************************************************\
* Interface
\ * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
2019-01-28 13:08:33 +00:00
bool Xdrv02 ( uint8_t function )
2018-10-10 21:21:44 +01:00
{
2019-01-28 13:08:33 +00:00
bool result = false ;
2018-10-10 21:21:44 +01:00
2019-11-03 11:33:36 +00:00
if ( Settings . flag . mqtt_enabled ) { // SetOption3 - Enable MQTT
2018-10-10 21:21:44 +01:00
switch ( function ) {
2019-06-05 10:44:52 +01:00
case FUNC_PRE_INIT :
MqttInit ( ) ;
break ;
2019-04-06 14:22:25 +01:00
case FUNC_EVERY_50_MSECOND : // https://github.com/knolleary/pubsubclient/issues/556
MqttClient . loop ( ) ;
2019-03-30 12:03:45 +00:00
break ;
2018-10-10 21:21:44 +01:00
# ifdef USE_WEBSERVER
case FUNC_WEB_ADD_BUTTON :
2019-03-10 14:36:34 +00:00
WSContentSend_P ( HTTP_BTN_MENU_MQTT ) ;
2018-10-10 21:21:44 +01:00
break ;
case FUNC_WEB_ADD_HANDLER :
2020-10-20 17:56:18 +01:00
WebServer_on ( PSTR ( " / " WEB_HANDLE_MQTT ) , HandleMqttConfiguration ) ;
2018-10-10 21:21:44 +01:00
break ;
# endif // USE_WEBSERVER
case FUNC_COMMAND :
2021-01-28 08:04:42 +00:00
result = DecodeCommand ( kMqttCommands , MqttCommand , kMqttSynonyms ) ;
2018-10-10 21:21:44 +01:00
break ;
}
}
return result ;
}