15 static const char *
const TAG =
"mqtt.component";
29 if (topic_prefix.empty()) {
64 if (discovery_info.
clean) {
65 ESP_LOGV(TAG,
"'%s': Cleaning discovery...", this->
friendly_name().c_str());
69 ESP_LOGV(TAG,
"'%s': Sending discovery...", this->
friendly_name().c_str());
73 [
this](JsonObject root) {
91 switch (this->
get_entity()->get_entity_category()) {
127 if (!unique_id.empty()) {
131 char friendly_name_hash[9];
133 friendly_name_hash[8] = 0;
147 if (node_friendly_name.empty()) {
148 node_friendly_name = node_name;
152 JsonObject device_info = root.createNestedObject(
MQTT_DEVICE);
156 #ifdef ESPHOME_PROJECT_NAME 158 const char *model = std::strchr(ESPHOME_PROJECT_NAME,
'.');
159 if (model ==
nullptr) {
169 #if defined(USE_ESP8266) || defined(USE_ESP32) 171 #elif defined(USE_RP2040) 173 #elif defined(USE_BK72XX) 175 #elif defined(USE_RTL87XX) 177 #elif defined(USE_HOST) 181 if (!node_area.empty()) {
226 std::string payload_not_available) {
229 this->
availability_->payload_available = std::move(payload_available);
230 this->
availability_->payload_not_available = std::move(payload_not_available);
float get_setup_priority() const override
MQTT_COMPONENT setup priority.
const Availability & get_availability()
bool is_discovery_enabled() const
std::string str_snake_case(const std::string &str)
Convert the string to snake case (lowercase with underscores).
virtual void loop()
This method will be called repeatedly.
std::string get_default_topic_for_(const std::string &suffix) const
Get this components state/command/...
constexpr const char *const MQTT_DEVICE_SW_VERSION
const float AFTER_CONNECTION
For components that should be initialized after a data connection (API/MQTT) is connected.
bool has_custom_state_topic_
constexpr const char *const MQTT_DEVICE_MODEL
bool is_connected_() const
constexpr const char *const MQTT_NAME
std::string topic
Empty means disabled.
MQTTDiscoveryUniqueIdGenerator unique_id_generator
Internal struct for MQTT Home Assistant discovery.
std::function< void(const std::string &, const std::string &)> mqtt_callback_t
Callback for MQTT subscriptions.
bool state_topic
If the state topic should be included. Defaults to true.
constexpr const char *const MQTT_PAYLOAD_AVAILABLE
StringRef is a reference to a string owned by something else.
StringRef custom_state_topic_
constexpr const char *const MQTT_ENTITY_CATEGORY
const std::string & get_area() const
Get the area of this Application set by pre_setup().
const std::string & get_friendly_name() const
Get the friendly name of this Application set by pre_setup().
void set_custom_state_topic(const char *custom_state_topic)
Set a custom state topic. Set to "" for default behavior.
constexpr const char *const MQTT_PAYLOAD_NOT_AVAILABLE
std::string payload_available
void disable_discovery()
Disable discovery. Sets friendly name to "".
constexpr const char *const MQTT_DEVICE_IDENTIFIERS
std::string prefix
The Home Assistant discovery prefix. Empty means disabled.
bool publish_json(const std::string &topic, const json::json_build_t &f)
Construct and send a JSON MQTT message.
const std::string & get_topic_prefix() const
Get the topic prefix of this device, using default if necessary.
virtual void dump_config()
void subscribe_json(const std::string &topic, const mqtt_json_callback_t &callback, uint8_t qos=0)
Subscribe to a MQTT topic and automatically parse JSON payload.
constexpr const char *const MQTT_DEVICE_SUGGESTED_AREA
bool command_topic
If the command topic should be included. Default to true.
bool publish(const std::string &topic, const std::string &payload)
Send a MQTT message.
virtual bool is_internal()
virtual void send_discovery(JsonObject root, SendDiscoveryConfig &config)=0
Send discovery info the Home Assistant, override this.
void disable_availability()
MQTTClientComponent * global_mqtt_client
std::string get_icon() const
void set_custom_command_topic(const char *custom_command_topic)
Set a custom command topic. Set to "" for default behavior.
constexpr const char *const MQTT_STATE_TOPIC
void subscribe(const std::string &topic, mqtt_callback_t callback, uint8_t qos=0)
Subscribe to a MQTT topic.
void set_retain(bool retain)
Set whether state message should be retained.
constexpr const char *const MQTT_DEVICE_NAME
void set_availability(std::string topic, std::string payload_available, std::string payload_not_available)
Set the Home Assistant availability data.
virtual void setup()
Where the component's initialization should happen.
virtual const EntityBase * get_entity() const =0
Gets the Entity served by this MQTT component.
virtual std::string component_type() const =0
Override this method to return the component type (e.g. "light", "sensor", ...)
void register_mqtt_component(MQTTComponent *component)
bool publish(const MQTTMessage &message)
Publish a MQTTMessage.
std::string get_mac_address()
Get the device MAC address as a string, in lowercase hex notation.
constexpr const char *const MQTT_COMMAND_TOPIC
Simple Helper struct used for Home Assistant MQTT send_discovery().
virtual bool send_initial_state()=0
std::function< void(JsonObject)> json_build_t
Callback function typedef for building JsonObjects.
Application App
Global storage of Application pointer - only one Application can exist.
void call_dump_config() override
StringRef custom_command_topic_
const std::string & get_name() const
Get the name of this Application set by pre_setup().
constexpr const char *const MQTT_DEVICE_MANUFACTURER
bool is_discovery_enabled() const
bool publish_json(const std::string &topic, const json::json_build_t &f, uint8_t qos=0, bool retain=false)
Construct and send a JSON MQTT message.
constexpr const char *const MQTT_COMMAND_RETAIN
const MQTTDiscoveryInfo & get_discovery_info() const
Get Home Assistant discovery info.
void call_setup() override
Override setup_ so that we can call send_discovery() when needed.
std::string str_sanitize(const std::string &str)
Sanitizes the input string by removing all characters but alphanumerics, dashes and underscores...
void set_qos(uint8_t qos)
Set QOS for state messages.
MQTTComponent()
Constructs a MQTTComponent.
uint32_t fnv1_hash(const std::string &str)
Calculate a FNV-1 hash of str.
virtual std::string get_icon() const
Get the icon field of this component.
virtual bool is_disabled_by_default() const
Get whether the underlying Entity is disabled by default.
constexpr const char *const MQTT_ICON
std::unique_ptr< Availability > availability_
void call_loop() override
virtual std::string friendly_name() const
Get the friendly name of this MQTT component.
constexpr const char *const MQTT_OBJECT_ID
Implementation of SPI Controller mode.
std::string payload_not_available
MQTTDiscoveryObjectIdGenerator object_id_generator
void subscribe_json(const std::string &topic, const mqtt_json_callback_t &callback, uint8_t qos=0)
Subscribe to a MQTT topic and automatically parse JSON payload.
constexpr const char *const MQTT_ENABLED_BY_DEFAULT
constexpr const char *const MQTT_UNIQUE_ID
constexpr const char *const MQTT_AVAILABILITY_TOPIC
std::string get_state_topic_() const
Get the MQTT topic that new states will be shared to.
bool has_custom_command_topic_
virtual std::string unique_id()
A unique ID for this MQTT component, empty for no unique id.
void set_command_retain(bool command_retain)
Set whether command message should be retained.
std::string get_compilation_time() const
std::string get_default_object_id_() const
Generate the Home Assistant MQTT discovery object id by automatically transforming the friendly name...
std::string get_command_topic_() const
Get the MQTT topic for listening to commands.
bool is_disabled_by_default() const
void subscribe(const std::string &topic, mqtt_callback_t callback, uint8_t qos=0)
Subscribe to an MQTT topic and call callback when a message is received.
constexpr const char *const MQTT_DEVICE
const StringRef & get_name() const
std::string get_discovery_topic_(const MQTTDiscoveryInfo &discovery_info) const
Helper method to get the discovery topic for this component.
constexpr const char *const MQTT_DEVICE_CONNECTIONS
bool retain
Whether to retain discovery messages.
bool send_discovery_()
Internal method to start sending discovery info, this will call send_discovery(). ...
std::function< void(const std::string &, JsonObject)> mqtt_json_callback_t
void schedule_resend_state()
Internal method for the MQTT client base to schedule a resend of the state on reconnect.