21static const char *
const TAG =
"api";
36 uint32_t hash = 88491486UL;
42 ESP_LOGD(TAG,
"Loaded saved Noise PSK");
55 ESP_LOGW(TAG,
"Could not create socket");
60 int err = this->
socket_->setsockopt(SOL_SOCKET, SO_REUSEADDR, &enable,
sizeof(
int));
62 ESP_LOGW(TAG,
"Socket unable to set reuseaddr: errno %d", err);
65 err = this->
socket_->setblocking(
false);
67 ESP_LOGW(TAG,
"Socket unable to set nonblocking mode: errno %d", err);
76 ESP_LOGW(TAG,
"Socket unable to set sockaddr: errno %d", errno);
83 ESP_LOGW(TAG,
"Socket unable to bind: errno %d", errno);
90 ESP_LOGW(TAG,
"Socket unable to listen: errno %d", errno);
98 [
this](
int level,
const char *tag,
const char *message,
size_t message_len) {
106 if (!c->flags_.remove && c->get_log_subscription_level() >= level)
107 c->try_send_log_message(level, tag, message, message_len);
117 if (!c->flags_.remove)
118 c->set_camera_state(image);
129 ESP_LOGE(TAG,
"No clients; rebooting");
140 socklen_t addr_len =
sizeof(source_addr);
141 auto sock = this->
socket_->accept_loop_monitored((
struct sockaddr *) &source_addr, &addr_len);
144 ESP_LOGD(TAG,
"Accept %s", sock->getpeername().c_str());
151 if (this->
clients_.size() == 1 && this->reboot_timeout_ != 0) {
166 for (
auto &client : this->
clients_) {
167 client->on_fatal_error();
168 ESP_LOGW(TAG,
"%s: Network down; disconnect", client->get_client_combined_info().c_str());
173 size_t client_index = 0;
174 while (client_index < this->
clients_.size()) {
175 auto &client = this->
clients_[client_index];
177 if (!client->flags_.remove) {
185#ifdef USE_API_CLIENT_DISCONNECTED_TRIGGER
188 ESP_LOGV(TAG,
"Remove connection %s", client->client_info_.name.c_str());
191 if (client_index < this->
clients_.size() - 1) {
197 if (this->
clients_.empty() && this->reboot_timeout_ != 0) {
210 ESP_LOGCONFIG(TAG,
" Noise encryption: %s", YESNO(this->
noise_ctx_->has_psk()));
212 ESP_LOGCONFIG(TAG,
" Supports encryption: YES");
215 ESP_LOGCONFIG(TAG,
" Noise encryption: NO");
219#ifdef USE_API_PASSWORD
223 uint32_t len_a = this->
password_.length();
224 const char *b = password.c_str();
225 uint32_t len_b = password.length();
228 volatile uint32_t
length = len_b;
229 volatile const char *left =
nullptr;
230 volatile const char *right = b;
234 left = *((
volatile const char **) &a);
242 for (
size_t i = 0; i <
length; i++) {
243 result |= *left++ ^ *right++;
253#define API_DISPATCH_UPDATE(entity_type, entity_name) \
254 void APIServer::on_##entity_name##_update(entity_type *obj) { \
255 if (obj->is_internal()) \
257 for (auto &c : this->clients_) \
258 c->send_##entity_name##_state(obj); \
262#define API_DISPATCH_UPDATE_IGNORE_PARAMS(entity_type, entity_name, ...) \
263 void APIServer::on_##entity_name##_update(entity_type *obj, __VA_ARGS__) { \
264 if (obj->is_internal()) \
266 for (auto &c : this->clients_) \
267 c->send_##entity_name##_state(obj); \
270#ifdef USE_BINARY_SENSOR
294#ifdef USE_TEXT_SENSOR
306#ifdef USE_DATETIME_DATE
310#ifdef USE_DATETIME_TIME
314#ifdef USE_DATETIME_DATETIME
319API_DISPATCH_UPDATE_IGNORE_PARAMS(
text::Text, text,
const std::string &
state)
323API_DISPATCH_UPDATE_IGNORE_PARAMS(
select::Select, select,
const std::string &
state,
size_t index)
334#ifdef USE_MEDIA_PLAYER
344 c->send_event(obj, event_type);
354 c->send_update_state(obj);
358#ifdef USE_ALARM_CONTROL_PANEL
366#ifdef USE_API_PASSWORD
372#ifdef USE_API_HOMEASSISTANT_SERVICES
374 for (
auto &client : this->
clients_) {
375 client->send_homeassistant_service_call(
call);
380#ifdef USE_API_HOMEASSISTANT_STATES
382 std::function<
void(std::string)> f) {
384 .entity_id = std::move(entity_id),
385 .attribute = std::move(attribute),
386 .callback = std::move(f),
392 std::function<
void(std::string)> f) {
394 .entity_id = std::move(entity_id),
395 .attribute = std::move(attribute),
396 .callback = std::move(f),
413 if (std::equal(old_psk.begin(), old_psk.end(), psk.begin())) {
414 ESP_LOGW(TAG,
"New PSK matches old");
420 ESP_LOGW(TAG,
"Failed to save Noise PSK");
425 ESP_LOGW(TAG,
"Failed to sync preferences");
428 ESP_LOGD(TAG,
"Noise PSK saved");
431 ESP_LOGW(TAG,
"Disconnecting all clients to reset PSK");
443#ifdef USE_HOMEASSISTANT_TIME
445 for (
auto &client : this->
clients_) {
446 if (!client->flags_.remove && client->is_authenticated())
447 client->send_time_request();
virtual void mark_failed()
Mark this component as failed.
void status_set_warning(const char *message=nullptr)
bool cancel_timeout(const std::string &name)
Cancel a timeout function.
void status_clear_warning()
void set_timeout(const std::string &name, uint32_t timeout, std::function< void()> &&f)
Set a timeout function with a unique name.
void setup_controller(bool include_internal=false)
virtual bool sync()=0
Commit pending writes to flash.
virtual ESPPreferenceObject make_preference(size_t length, uint32_t type, bool in_flash)=0
void trigger(Ts... x)
Inform the parent automation that the event has triggered.
static uint16_t try_send_disconnect_request(EntityBase *entity, APIConnection *conn, uint32_t remaining_size, bool is_single)
std::vector< std::unique_ptr< APIConnection > > clients_
void send_homeassistant_service_call(const HomeassistantServiceResponse &call)
void set_password(const std::string &password)
void set_port(uint16_t port)
void dump_config() override
void handle_disconnect(APIConnection *conn)
void schedule_reboot_timeout_()
void set_batch_delay(uint16_t batch_delay)
void set_reboot_timeout(uint32_t reboot_timeout)
bool save_noise_psk(psk_t psk, bool make_active=true)
bool is_connected() const
void on_update(update::UpdateEntity *obj) override
bool check_password(const std::string &password) const
void get_home_assistant_state(std::string entity_id, optional< std::string > attribute, std::function< void(std::string)> f)
const std::vector< HomeAssistantStateSubscription > & get_state_subs() const
std::shared_ptr< APINoiseContext > noise_ctx_
Trigger< std::string, std::string > * client_disconnected_trigger_
std::vector< uint8_t > shared_write_buffer_
void subscribe_home_assistant_state(std::string entity_id, optional< std::string > attribute, std::function< void(std::string)> f)
ESPPreferenceObject noise_pref_
std::vector< HomeAssistantStateSubscription > state_subs_
uint16_t get_port() const
void set_noise_psk(psk_t psk)
void on_event(event::Event *obj, const std::string &event_type) override
float get_setup_priority() const override
std::unique_ptr< socket::Socket > socket_
void on_shutdown() override
static constexpr uint8_t MESSAGE_TYPE
static constexpr uint8_t ESTIMATED_SIZE
Base class for all binary_sensor-type classes.
static Camera * instance()
The singleton instance of the camera implementation.
virtual void add_image_callback(std::function< void(std::shared_ptr< CameraImage >)> &&callback)=0
ClimateDevice - This is the base class for all climate integrations.
Base class for all cover devices.
This class represents the communication layer between the front-end MQTT layer and the hardware outpu...
Base class for all locks.
void add_on_log_callback(std::function< void(uint8_t, const char *, const char *, size_t)> &&callback)
Register a callback that will be called for every log message sent.
Base-class for all numbers.
Base-class for all selects.
Base-class for all sensors.
Base class for all switches.
Base-class for all text inputs.
Base class for all valve devices.
APIServer * global_api_server
API_DISPATCH_UPDATE(binary_sensor::BinarySensor, binary_sensor) API_DISPATCH_UPDATE(cover
std::array< uint8_t, 32 > psk_t
std::string get_use_address()
Get the active network hostname.
bool is_connected()
Return whether the node is connected to the network (through wifi, eth, ...)
const float AFTER_WIFI
For components that should be initialized after WiFi is connected.
std::unique_ptr< Socket > socket_ip_loop_monitored(int type, int protocol)
socklen_t set_sockaddr_any(struct sockaddr *addr, socklen_t addrlen, uint16_t port)
Set a sockaddr to the any address and specified port for the IP version used by socket_ip().
ESPPreferences * global_preferences
Application App
Global storage of Application pointer - only one Application can exist.