mirror of
https://github.com/emsesp/EMS-ESP32.git
synced 2025-12-06 15:59:52 +03:00
139 lines
3.7 KiB
C++
139 lines
3.7 KiB
C++
#ifndef MqttSettingsService_h
|
|
#define MqttSettingsService_h
|
|
|
|
#include "StatefulService.h"
|
|
#include "HttpEndpoint.h"
|
|
#include "FSPersistence.h"
|
|
|
|
#include <espMqttClient.h>
|
|
|
|
#include <uuid/common.h>
|
|
|
|
#define MQTT_RECONNECTION_DELAY 2000 // 2 seconds
|
|
|
|
#define MQTT_SETTINGS_FILE "/config/mqttSettings.json"
|
|
#define MQTT_SETTINGS_SERVICE_PATH "/rest/mqttSettings"
|
|
|
|
#ifndef FACTORY_MQTT_ENABLED
|
|
#define FACTORY_MQTT_ENABLED false
|
|
#endif
|
|
|
|
#ifndef FACTORY_MQTT_HOST
|
|
#define FACTORY_MQTT_HOST "" // is blank
|
|
#endif
|
|
|
|
#ifndef FACTORY_MQTT_PORT
|
|
#define FACTORY_MQTT_PORT 1883
|
|
#endif
|
|
|
|
#ifndef FACTORY_MQTT_BASE
|
|
#define FACTORY_MQTT_BASE "ems-esp"
|
|
#endif
|
|
|
|
#ifndef FACTORY_MQTT_USERNAME
|
|
#define FACTORY_MQTT_USERNAME ""
|
|
#endif
|
|
|
|
#ifndef FACTORY_MQTT_PASSWORD
|
|
#define FACTORY_MQTT_PASSWORD ""
|
|
#endif
|
|
|
|
#ifndef FACTORY_MQTT_KEEP_ALIVE
|
|
#define FACTORY_MQTT_KEEP_ALIVE 16
|
|
#endif
|
|
|
|
#ifndef FACTORY_MQTT_CLEAN_SESSION
|
|
#define FACTORY_MQTT_CLEAN_SESSION false
|
|
#endif
|
|
|
|
#ifndef FACTORY_MQTT_MAX_TOPIC_LENGTH
|
|
#define FACTORY_MQTT_MAX_TOPIC_LENGTH 128
|
|
#endif
|
|
|
|
class MqttSettings {
|
|
public:
|
|
bool enabled;
|
|
String host;
|
|
uint16_t port;
|
|
String rootCA;
|
|
bool enableTLS;
|
|
String username;
|
|
String password;
|
|
String clientId;
|
|
uint16_t keepAlive;
|
|
bool cleanSession;
|
|
|
|
// EMS-ESP specific
|
|
String base;
|
|
uint16_t publish_time_boiler;
|
|
uint16_t publish_time_thermostat;
|
|
uint16_t publish_time_solar;
|
|
uint16_t publish_time_mixer;
|
|
uint16_t publish_time_other;
|
|
uint16_t publish_time_sensor;
|
|
uint16_t publish_time_heartbeat;
|
|
uint8_t mqtt_qos;
|
|
bool mqtt_retain;
|
|
bool ha_enabled;
|
|
uint8_t nested_format;
|
|
String discovery_prefix;
|
|
uint8_t discovery_type;
|
|
bool publish_single;
|
|
bool publish_single2cmd;
|
|
bool send_response;
|
|
uint8_t entity_format;
|
|
|
|
static void read(MqttSettings & settings, JsonObject root);
|
|
static StateUpdateResult update(JsonObject root, MqttSettings & settings);
|
|
};
|
|
|
|
class MqttSettingsService : public StatefulService<MqttSettings> {
|
|
public:
|
|
MqttSettingsService(AsyncWebServer * server, FS * fs, SecurityManager * securityManager);
|
|
~MqttSettingsService();
|
|
|
|
void begin();
|
|
void startClient();
|
|
void loop();
|
|
bool isEnabled();
|
|
bool isConnected();
|
|
const char * getClientId();
|
|
espMqttClientTypes::DisconnectReason getDisconnectReason();
|
|
MqttClient * getMqttClient();
|
|
void setWill(const char * topic);
|
|
|
|
protected:
|
|
void onConfigUpdated();
|
|
|
|
private:
|
|
HttpEndpoint<MqttSettings> _httpEndpoint;
|
|
FSPersistence<MqttSettings> _fsPersistence;
|
|
|
|
// Pointers to hold retained copies of the mqtt client connection strings.
|
|
// This is required as espMqttClient holds references to the supplied connection strings.
|
|
char * _retainedHost;
|
|
char * _retainedClientId;
|
|
char * _retainedUsername;
|
|
char * _retainedPassword;
|
|
char * _retainedRootCA;
|
|
|
|
// variable to help manage connection
|
|
bool _reconfigureMqtt;
|
|
unsigned long _disconnectedAt;
|
|
|
|
// connection status
|
|
espMqttClientTypes::DisconnectReason _disconnectReason;
|
|
|
|
// the MQTT client instance
|
|
MqttClient * _mqttClient;
|
|
|
|
void WiFiEvent(WiFiEvent_t event);
|
|
void onMqttConnect(bool sessionPresent);
|
|
void onMqttDisconnect(espMqttClientTypes::DisconnectReason reason);
|
|
void
|
|
onMqttMessage(const espMqttClientTypes::MessageProperties & properties, const char * topic, const uint8_t * payload, size_t len, size_t index, size_t total);
|
|
|
|
bool configureMqtt();
|
|
};
|
|
|
|
#endif |