nextion.cpp

Go to the documentation of this file.

#include "nextion.h"
 
#include <cinttypes>
#include <cstring>
#include <new>
 
#include "esphome/core/application.h"
#include "esphome/core/helpers.h"
#include "esphome/core/log.h"
#include "esphome/core/progmem.h"
#include "esphome/core/string_ref.h"
#include "esphome/core/util.h"
 
namespace esphome::nextion {
 
ESPHOME_LOG_TAG(TAG, "nextion");
 
// A user entity may be named sleep_wake too; only the internal NO_RESULT command clears the sleeping flag
static bool is_sleep_wake_command(const NextionComponentBase *component) {
  return component->get_queue_type() == NextionQueueType::NO_RESULT && component->get_variable_name() == "sleep_wake";
}
 
// The display answers a raw "get" with a value instead of 0x01. Its queue entry is named RAW_GET_NAME so that
// value removes it. An entity with this variable name would clash when it writes its state; none is expected.
static constexpr const char *RAW_GET_NAME = "raw_get";
 
static bool is_raw_get_command(const NextionComponentBase *component) {
  return component->get_queue_type() == NextionQueueType::NO_RESULT && component->get_variable_name() == RAW_GET_NAME;
}
 
static const char *raw_command_name(const char *command, const char *name) {
  return ESPHOME_strncmp_P(command, ESPHOME_PSTR("get "), 4) == 0 ? RAW_GET_NAME : name;
}
 
// Nextion command terminator: three consecutive 0xFF bytes (per Nextion Instruction Set v1.1).
static constexpr uint8_t COMMAND_DELIMITER[3] = {0xFF, 0xFF, 0xFF};
static constexpr size_t DELIMITER_SIZE = sizeof(COMMAND_DELIMITER);
 
void Nextion::setup() {
  this->is_setup_ = false;
  this->connection_state_.ignore_is_setup_ = true;
 
  // Wake up the nextion and ensure clean communication state
  this->send_command_("sleep=0");  // Exit sleep mode if sleeping
  this->send_command_("bkcmd=0");  // Disable return data during init sequence
 
  // Reset device for clean state - critical for reliable communication
  this->send_command_("rest");
 
  this->connection_state_.ignore_is_setup_ = false;
}
 
bool Nextion::send_command_(const std::string &command) {
  if (!this->connection_state_.ignore_is_setup_ && !this->is_setup()) {
    return false;
  }
 
#ifdef USE_NEXTION_COMMAND_SPACING
  const uint32_t now = App.get_loop_component_start_time();
  if (!this->connection_state_.ignore_is_setup_ && !this->command_pacer_.can_send(now)) {
    ESP_LOGN(TAG, "Command spacing: delaying '%s'", command.c_str());
    return false;
  }
#endif  // USE_NEXTION_COMMAND_SPACING
 
  ESP_LOGN(TAG, "cmd: %s", command.c_str());
 
  this->write_str(command.c_str());
  const uint8_t to_send[3] = {0xFF, 0xFF, 0xFF};
  this->write_array(to_send, sizeof(to_send));
 
#ifdef USE_NEXTION_COMMAND_SPACING
  // Mark sent immediately after writing to UART. The pacer enforces inter-command
  // spacing from the transmit side. Marking on ACK (0x01) would leave last_command_time_
  // at zero indefinitely, making can_send() always return true and spacing a no-op.
  // ignore_is_setup_ commands (setup/init sequence) bypass spacing intentionally.
  if (!this->connection_state_.ignore_is_setup_) {
    this->command_pacer_.mark_sent(now);
  }
#endif  // USE_NEXTION_COMMAND_SPACING
 
  return true;
}
 
bool Nextion::check_connect_() {
  if (this->connection_state_.is_connected_)
    return true;
 
#ifdef USE_NEXTION_CONFIG_SKIP_CONNECTION_HANDSHAKE
  ESP_LOGW(TAG, "Connected (no handshake)");     // Log the connection status without handshake
  this->connection_state_.is_connected_ = true;  // Set the connection status to true
  return true;                                   // Return true indicating the connection is set
#else                                            // USE_NEXTION_CONFIG_SKIP_CONNECTION_HANDSHAKE
  if (this->comok_sent_ == 0) {
    this->reset_(false);
 
    this->connection_state_.ignore_is_setup_ = true;
    this->send_command_("boguscommand=0");  // bogus command. needed sometimes after updating
#ifdef USE_NEXTION_CONFIG_EXIT_REPARSE_ON_START
    this->send_command_("DRAKJHSUYDGBNCJHGJKSHBDN");
#endif  // USE_NEXTION_CONFIG_EXIT_REPARSE_ON_START
    this->send_command_("connect");
 
    this->comok_sent_ = App.get_loop_component_start_time();
    this->connection_state_.ignore_is_setup_ = false;
 
    return false;
  }
 
  if (App.get_loop_component_start_time() - this->comok_sent_ <= 500)  // Wait 500 ms
    return false;
 
  std::string response;
 
  this->recv_ret_string_(response, 0, false);
  if (!response.empty() && response[0] == 0x1A) {
    // Swallow invalid variable name responses that may be caused by the above commands
    ESP_LOGV(TAG, "0x1A error ignored (setup)");
    return false;
  }
  if (response.empty() || response.find("comok") == std::string::npos) {
#ifdef NEXTION_PROTOCOL_LOG
    ESP_LOGN(TAG, "Bad connect: %s", response.c_str());
    for (size_t i = 0; i < response.length(); i++) {
      ESP_LOGN(TAG, "resp: %s %d %d %c", response.c_str(), i, response[i], response[i]);
    }
#endif  // NEXTION_PROTOCOL_LOG
 
    ESP_LOGW(TAG, "Not connected");
    this->comok_sent_ = 0;
    return false;
  }
 
  this->connection_state_.ignore_is_setup_ = true;
  ESP_LOGI(TAG, "Connected");
  this->connection_state_.is_connected_ = true;
 
  ESP_LOGN(TAG, "connect: %s", response.c_str());
 
  // Parse comok response fields directly
  // Format: comok <touch>,<reserved>,<model>,<fw>,<mcu_code>,<serial>,<flash>
  size_t field_count = 0;
  size_t start = 0;
  size_t end = 0;
  auto copy_field = [&](char *dst, size_t cap) {
    size_t len = (end == std::string::npos ? response.size() : end) - start;
    size_t n = len < cap ? len : cap;
    std::memcpy(dst, response.data() + start, n);
    dst[n] = '\0';
  };
  while ((start = response.find_first_not_of(',', end)) != std::string::npos) {
    end = response.find(',', start);
    switch (field_count) {
      case 2:
        copy_field(this->device_model_, this->NEXTION_MODEL_MAX);
        break;
      case 3:
        copy_field(this->firmware_version_, this->NEXTION_FW_MAX);
        break;
      case 5:
        copy_field(this->serial_number_, this->NEXTION_SERIAL_MAX);
        break;
      case 6:
        this->flash_size_ = static_cast<uint32_t>(std::strtoul(response.data() + start, nullptr, 10));
        break;
      default:
        break;
    }
    ++field_count;
  }
 
  this->is_detected_ = (field_count == 7);
  if (this->is_detected_) {
    ESP_LOGN(TAG, "Connect info: %zu fields", field_count);
  } else {
    ESP_LOGE(TAG, "Bad connect value: '%s'", response.c_str());
  }
 
  this->connection_state_.ignore_is_setup_ = false;
  this->dump_config();
  return true;
#endif  // USE_NEXTION_CONFIG_SKIP_CONNECTION_HANDSHAKE
}
 
// NO_RESULT components are owned by their entry; every other component is a user entity. Entry and
// component storage comes from RAMAllocator, so delete is not valid for either.
void Nextion::release_queue_entry_(NextionQueue *nb) {
  if (nb->component != nullptr && nb->component->get_queue_type() == NextionQueueType::NO_RESULT) {
    nb->component->~NextionComponentBase();
    RAMAllocator<NextionComponentBase>().deallocate(nb->component, 1);
  }
  nb->~NextionQueue();
  RAMAllocator<NextionQueue>().deallocate(nb, 1);
}
 
void Nextion::reset_(bool reset_nextion) {
  this->discard_available();
  for (auto *entry : this->nextion_queue_) {
    this->release_queue_entry_(entry);
  }
  this->nextion_queue_.clear();
#ifdef USE_NEXTION_WAVEFORM
  for (auto *entry : this->waveform_queue_) {
    this->release_queue_entry_(entry);
  }
  this->waveform_queue_.clear();
#endif  // USE_NEXTION_WAVEFORM
}
 
void Nextion::dump_config() {
  ESP_LOGCONFIG(TAG, "Nextion:");
 
#ifdef USE_NEXTION_CONFIG_SKIP_CONNECTION_HANDSHAKE
  ESP_LOGCONFIG(TAG, "  Skip handshake: YES");
#else  // USE_NEXTION_CONFIG_SKIP_CONNECTION_HANDSHAKE
  if (this->is_setup()) {
    ESP_LOGCONFIG(TAG,
                  "  Device Model: %s\n"
                  "  FW Version: %s\n"
                  "  Serial Number: %s\n"
                  "  Flash Size: %" PRIu32 " bytes",
                  this->device_model_, this->firmware_version_, this->serial_number_, this->flash_size_);
  } else {
    ESP_LOGCONFIG(TAG, "  Device info: not yet detected");
  }
  ESP_LOGCONFIG(TAG,
#ifdef USE_NEXTION_CONFIG_EXIT_REPARSE_ON_START
                "  Exit reparse: YES\n"
#endif  // USE_NEXTION_CONFIG_EXIT_REPARSE_ON_START
                "  Max queue age: %u ms\n"
                "  Startup override: %u ms\n"
                "  Wake On Touch: %s\n"
                "  Touch Timeout: %" PRIu16,
                this->max_q_age_ms_, this->startup_override_ms_, YESNO(this->connection_state_.auto_wake_on_touch_),
                this->touch_sleep_timeout_);
#endif  // USE_NEXTION_CONFIG_SKIP_CONNECTION_HANDSHAKE
 
#ifdef USE_NEXTION_MAX_COMMANDS_PER_LOOP
  ESP_LOGCONFIG(TAG, "  Max commands per loop: %u", this->max_commands_per_loop_);
#endif  // USE_NEXTION_MAX_COMMANDS_PER_LOOP
 
  if (this->wake_up_page_ != 255) {
    ESP_LOGCONFIG(TAG, "  Wake Up Page: %u", this->wake_up_page_);
  }
 
#ifdef USE_NEXTION_CONF_START_UP_PAGE
  if (this->start_up_page_ != 255) {
    ESP_LOGCONFIG(TAG, "  Start Up Page: %u", this->start_up_page_);
  }
#endif  // USE_NEXTION_CONF_START_UP_PAGE
 
#ifdef USE_NEXTION_COMMAND_SPACING
  ESP_LOGCONFIG(TAG, "  Cmd spacing: %u ms", this->command_pacer_.get_spacing());
#endif  // USE_NEXTION_COMMAND_SPACING
 
#ifdef USE_NEXTION_MAX_QUEUE_SIZE
  ESP_LOGCONFIG(TAG, "  Max queue size: %zu", this->max_queue_size_);
#endif
#ifdef USE_NEXTION_TFT_UPLOAD
  ESP_LOGCONFIG(TAG,
                "  TFT URL: %s\n"
                "  TFT upload HTTP timeout: %" PRIu16 "ms\n"
                "  TFT upload HTTP retries: %u",
                this->tft_url_.c_str(), this->tft_upload_http_timeout_, this->tft_upload_http_retries_);
#ifdef USE_ESP32
  if (this->tft_upload_watchdog_timeout_ > 0) {
    ESP_LOGCONFIG(TAG, "  TFT upload WDT timeout: %" PRIu32 "ms", this->tft_upload_watchdog_timeout_);
  }
#endif  // USE_ESP32
#endif  // USE_NEXTION_TFT_UPLOAD
}
 
void Nextion::update() {
  if (!this->is_setup()) {
    return;
  }
  if (this->writer_.has_value()) {
    (*this->writer_)(*this);
  }
}
 
void Nextion::update_all_components() {
  if ((!this->is_setup() && !this->connection_state_.ignore_is_setup_) || this->is_sleeping())
    return;
 
  for (auto *binarysensortype : this->binarysensortype_) {
    binarysensortype->update_component();
  }
  for (auto *sensortype : this->sensortype_) {
    sensortype->update_component();
  }
  for (auto *switchtype : this->switchtype_) {
    switchtype->update_component();
  }
  for (auto *textsensortype : this->textsensortype_) {
    textsensortype->update_component();
  }
}
 
bool Nextion::send_command(const char *command) {
  if ((!this->is_setup() && !this->connection_state_.ignore_is_setup_) || this->is_sleeping())
    return false;
 
  this->add_no_result_to_queue_with_command_(raw_command_name(command, "command"), command);
  return true;
}
 
bool Nextion::send_command_printf(const char *format, ...) {
  if ((!this->is_setup() && !this->connection_state_.ignore_is_setup_) || this->is_sleeping())
    return false;
 
  char buffer[256];
  va_list arg;
  va_start(arg, format);
  int ret = vsnprintf(buffer, sizeof(buffer), format, arg);
  va_end(arg);
  if (ret <= 0) {
    ESP_LOGW(TAG, "Bad cmd format: '%s'", format);
    return false;
  }
 
  this->add_no_result_to_queue_with_command_(raw_command_name(buffer, "command_printf"), buffer);
  return true;
}
 
#ifdef NEXTION_PROTOCOL_LOG
void Nextion::print_queue_members_() {
  ESP_LOGN(TAG, "print_queue_members_ (top 10) size %zu", this->nextion_queue_.size());
  ESP_LOGN(TAG, "*******************************************");
  int count = 0;
  for (auto *i : this->nextion_queue_) {
    if (count++ == 10)
      break;
 
    if (i == nullptr) {
      ESP_LOGN(TAG, "Queue null");
    } else {
      ESP_LOGN(TAG, "Queue type: %d:%s, name: %s", i->component->get_queue_type(),
               i->component->get_queue_type_string(), i->component->get_variable_name().c_str());
    }
  }
  ESP_LOGN(TAG, "*******************************************");
}
#endif
 
void Nextion::loop() {
  if (!this->check_connect_() || this->connection_state_.is_updating_)
    return;
 
  if (this->connection_state_.nextion_reports_is_setup_ && !this->connection_state_.sent_setup_commands_) {
    this->connection_state_.ignore_is_setup_ = true;
    this->connection_state_.sent_setup_commands_ = true;
    this->send_command_("bkcmd=3");  // Always, returns 0x00 to 0x23 result of serial command.
 
    if (this->brightness_.has_value()) {
      this->set_backlight_brightness(this->brightness_.value());
    }
 
#ifdef USE_NEXTION_CONF_START_UP_PAGE
    // Check if a startup page has been set and send the command
    if (this->start_up_page_ != 255) {
      this->goto_page(this->start_up_page_);
    }
#endif  // USE_NEXTION_CONF_START_UP_PAGE
 
    if (this->wake_up_page_ != 255) {
      this->set_wake_up_page(this->wake_up_page_);
    }
 
    if (this->touch_sleep_timeout_ != 0) {
      this->set_touch_sleep_timeout(this->touch_sleep_timeout_);
    }
 
    this->set_auto_wake_on_touch(this->connection_state_.auto_wake_on_touch_);
 
    this->connection_state_.ignore_is_setup_ = false;
  }
 
  this->process_serial_();             // Receive serial data
  this->process_nextion_commands_();   // Process nextion return commands
  this->purge_stale_queue_entries_();  // Drop expired entries even when the display sends no data
 
  if (!this->connection_state_.nextion_reports_is_setup_) {
    if (this->started_ms_ == 0)
      this->started_ms_ = App.get_loop_component_start_time();
 
    if (this->startup_override_ms_ > 0 &&
        App.get_loop_component_start_time() - this->started_ms_ > this->startup_override_ms_) {
      ESP_LOGV(TAG, "Manual ready set");
      this->connection_state_.nextion_reports_is_setup_ = true;
    }
  }
 
#ifdef USE_NEXTION_COMMAND_SPACING
  this->process_pending_in_queue_();
#ifdef USE_NEXTION_WAVEFORM
  if (!this->waveform_queue_.empty()) {
    this->check_pending_waveform_();
  }
#endif  // USE_NEXTION_WAVEFORM
#endif  // USE_NEXTION_COMMAND_SPACING
}
 
#ifdef USE_NEXTION_COMMAND_SPACING
void Nextion::process_pending_in_queue_() {
#ifdef USE_NEXTION_MAX_COMMANDS_PER_LOOP
  size_t commands_sent = 0;
#endif  // USE_NEXTION_MAX_COMMANDS_PER_LOOP
 
  for (auto *item : this->nextion_queue_) {
    if (item == nullptr || item->pending_command.empty()) {
      continue;  // Already sent, waiting for ACK — skip, don't stop
    }
 
#ifdef USE_NEXTION_MAX_COMMANDS_PER_LOOP
    if (++commands_sent > this->max_commands_per_loop_) {
      ESP_LOGV(TAG, "Pending cmds: loop limit reached, deferring");
      break;
    }
#endif  // USE_NEXTION_MAX_COMMANDS_PER_LOOP
 
    const uint32_t now = App.get_loop_component_start_time();
    if (!this->command_pacer_.can_send(now)) {
      break;  // Spacing not elapsed, stop for this loop iteration
    }
 
    if (!this->send_command_(item->pending_command)) {
      break;  // Unexpected send failure, stop
    }
    item->pending_command.clear();
    ESP_LOGVV(TAG, "Pending cmd sent: %s", item->component->get_variable_name().c_str());
  }
}
#endif  // USE_NEXTION_COMMAND_SPACING
 
bool Nextion::remove_from_q_(bool report_empty) {
  if (this->nextion_queue_.empty()) {
    if (report_empty) {
      ESP_LOGE(TAG, "Queue empty");
    }
    return false;
  }
 
  NextionQueue *nb = this->nextion_queue_.front();
  if (!nb || !nb->component) {
    ESP_LOGE(TAG, "Invalid queue");
    if (nb != nullptr) {
      this->release_queue_entry_(nb);
    }
    this->nextion_queue_.pop_front();
    return false;
  }
  NextionComponentBase *component = nb->component;
 
  ESP_LOGN(TAG, "Removed: %s", component->get_variable_name().c_str());
 
  if (is_sleep_wake_command(component)) {
    this->is_sleeping_ = false;
  }
  this->release_queue_entry_(nb);
  this->nextion_queue_.pop_front();
  return true;
}
 
void Nextion::deliver_queue_response_(const LogString *response_name, const NextionQueueResponse &resp) {
  auto it = this->nextion_queue_.begin();
  while (it != this->nextion_queue_.end()) {
    NextionQueue *nb = *it;
    if (nb == nullptr || nb->component == nullptr) {
      ESP_LOGE(TAG, "Invalid queue entry");
      if (nb != nullptr) {
        this->release_queue_entry_(nb);
      }
      it = this->nextion_queue_.erase(it);
      continue;
    }
    NextionComponentBase *component = nb->component;
    NextionQueueType qtype = component->get_queue_type();
    const bool raw_get = is_raw_get_command(component);
 
    if (!nb->pending_command.empty()) {
      ESP_LOGV(TAG, "%s: skipping unsent '%s'", LOG_STR_ARG(response_name), component->get_variable_name().c_str());
      ++it;
      continue;
    }
 
    if (qtype == NextionQueueType::NO_RESULT && !raw_get) {
      // Leave in queue -- its 0x01 ACK will remove it via remove_from_q_().
      ESP_LOGV(TAG, "%s: skipping NO_RESULT '%s'", LOG_STR_ARG(response_name), component->get_variable_name().c_str());
      ++it;
      continue;
    }
 
    // The display answers queries in order, so the response belongs to this query even when the type does
    // not match. Consume only this entry and never hand the value to a later query.
    if (raw_get) {
      // A raw "get" from send_command() has no entity to update
      ESP_LOGV(TAG, "%s for raw get dropped", LOG_STR_ARG(response_name));
    } else if (!resp.is_string && (qtype == NextionQueueType::SENSOR || qtype == NextionQueueType::BINARY_SENSOR ||
                                   qtype == NextionQueueType::SWITCH)) {
      ESP_LOGN(TAG, "Numeric: %s type %d:%s val %d", component->get_variable_name().c_str(), qtype,
               component->get_queue_type_string(), resp.int_value);
      component->set_state_from_int(resp.int_value, true, false);
    } else if (resp.is_string && qtype == NextionQueueType::TEXT_SENSOR) {
      ESP_LOGN(TAG, "String resp: '%s' id: %s type: %s", resp.str_value->c_str(),
               component->get_variable_name().c_str(), component->get_queue_type_string());
      component->set_state_from_string(*resp.str_value, true, false);
    } else {
      ESP_LOGE(TAG, "%s but '%s' invalid type %d", LOG_STR_ARG(response_name), component->get_variable_name().c_str(),
               qtype);
    }
 
    this->release_queue_entry_(nb);
    this->nextion_queue_.erase(it);
    return;
  }
  ESP_LOGE(TAG, "%s but no sent query in queue", LOG_STR_ARG(response_name));
}
 
void Nextion::set_numeric_return_(int value) {
  NextionQueueResponse resp{};
  resp.is_string = false;
  resp.int_value = value;
  this->deliver_queue_response_(LOG_STR("Numeric return"), resp);
}
 
void Nextion::set_string_return_(const std::string &value) {
  NextionQueueResponse resp{};
  resp.is_string = true;
  resp.str_value = &value;
  this->deliver_queue_response_(LOG_STR("String return"), resp);
}
 
void Nextion::process_serial_() {
  // Read all available bytes in batches to reduce UART call overhead.
  size_t avail = this->available();
  uint8_t buf[64];
  while (avail > 0) {
    size_t to_read = std::min(avail, sizeof(buf));
    if (!this->read_array(buf, to_read)) {
      break;
    }
    avail -= to_read;
 
    this->command_data_.append(reinterpret_cast<const char *>(buf), to_read);
  }
}
// nextion.tech/instruction-set/
void Nextion::process_nextion_commands_() {
  if (this->command_data_.empty()) {
    return;
  }
 
#ifdef USE_NEXTION_MAX_COMMANDS_PER_LOOP
  size_t commands_processed = 0;
#endif  // USE_NEXTION_MAX_COMMANDS_PER_LOOP
 
  size_t to_process_length = 0;
  std::string to_process;
 
  ESP_LOGN(TAG, "command_data_ %s len %d", this->command_data_.c_str(), this->command_data_.length());
#ifdef NEXTION_PROTOCOL_LOG
  this->print_queue_members_();
#endif
  while ((to_process_length = this->command_data_.find(reinterpret_cast<const char *>(COMMAND_DELIMITER), 0,
                                                       DELIMITER_SIZE)) != std::string::npos) {
#ifdef USE_NEXTION_MAX_COMMANDS_PER_LOOP
    if (++commands_processed > this->max_commands_per_loop_) {
      ESP_LOGV(TAG, "Command limit reached, deferring");
      break;
    }
#endif  // USE_NEXTION_MAX_COMMANDS_PER_LOOP
    ESP_LOGN(TAG, "queue size: %zu", this->nextion_queue_.size());
    while (to_process_length + DELIMITER_SIZE < this->command_data_.length() &&
           static_cast<uint8_t>(this->command_data_[to_process_length + DELIMITER_SIZE]) == 0xFF) {
      ++to_process_length;
      ESP_LOGN(TAG, "Add 0xFF");
    }
 
    const uint8_t nextion_event = this->command_data_[0];
 
    to_process_length -= 1;
    to_process = this->command_data_.substr(1, to_process_length);
 
    switch (nextion_event) {
      case 0x00:  // instruction sent by user has failed
        ESP_LOGW(TAG, "Invalid instruction");
        this->remove_from_q_();
 
        break;
      case 0x01:  // instruction sent by user was successful
 
        ESP_LOGVV(TAG, "Cmd OK");
        ESP_LOGN(TAG, "this->nextion_queue_.empty() %s", YESNO(this->nextion_queue_.empty()));
 
        this->remove_from_q_();
        if (!this->is_setup_) {
          if (this->nextion_queue_.empty()) {
            this->is_setup_ = true;
            this->setup_callback_.call();
          }
        }
        break;
      case 0x02:  // invalid Component ID or name was used
        ESP_LOGW(TAG, "Invalid component ID/name");
        this->remove_from_q_();
        break;
      case 0x03:  // invalid Page ID or name was used
        ESP_LOGW(TAG, "Invalid page ID");
        this->remove_from_q_();
        break;
      case 0x04:  // invalid Picture ID was used
        ESP_LOGW(TAG, "Invalid picture ID");
        this->remove_from_q_();
        break;
      case 0x05:  // invalid Font ID was used
        ESP_LOGW(TAG, "Invalid font ID");
        this->remove_from_q_();
        break;
      case 0x06:  // File operation fails
        ESP_LOGW(TAG, "File operation failed");
        break;
      case 0x09:  // Instructions with CRC validation fails their CRC check
        ESP_LOGW(TAG, "CRC validation failed");
        break;
      case 0x11:  // invalid Baud rate was used
        ESP_LOGW(TAG, "Invalid baud rate");
        break;
      case 0x12:  // invalid Waveform ID or Channel # was used
#ifdef USE_NEXTION_WAVEFORM
        if (this->waveform_queue_.empty()) {
          ESP_LOGW(TAG, "Waveform ID/ch used but no sensor queued");
        } else {
          auto &nb = this->waveform_queue_.front();
          NextionComponentBase *component = nb->component;
          ESP_LOGW(TAG, "Invalid waveform ID %d/ch %d", component->get_component_id(),
                   component->get_wave_channel_id());
          ESP_LOGN(TAG, "Remove waveform ID %d/ch %d", component->get_component_id(), component->get_wave_channel_id());
          this->release_queue_entry_(nb);
          this->waveform_queue_.pop();
        }
#else   // USE_NEXTION_WAVEFORM
        ESP_LOGW(TAG, "Waveform ID/ch error but waveform not enabled");
#endif  // USE_NEXTION_WAVEFORM
        break;
      case 0x1A:  // variable name invalid
        ESP_LOGW(TAG, "Invalid variable name");
        this->remove_from_q_();
        break;
      case 0x1B:  // variable operation invalid
        ESP_LOGW(TAG, "Invalid variable operation");
        this->remove_from_q_();
        break;
      case 0x1C:  // failed to assign
        ESP_LOGW(TAG, "Variable assign failed");
        this->remove_from_q_();
        break;
      case 0x1D:  // operate EEPROM failed
        ESP_LOGW(TAG, "EEPROM operation failed");
        break;
      case 0x1E:  // parameter quantity invalid
        ESP_LOGW(TAG, "Invalid parameter count");
        this->remove_from_q_();
        break;
      case 0x1F:  // IO operation failed
        ESP_LOGW(TAG, "Invalid component I/O");
        break;
      case 0x20:  // undefined escape characters
        ESP_LOGW(TAG, "Undefined escape chars");
        this->remove_from_q_();
        break;
      case 0x23:  // too long variable name
        ESP_LOGW(TAG, "Variable name too long");
        this->remove_from_q_();
        break;
      case 0x24:  //  Serial Buffer overflow occurs
        // Buffer will continue to receive the current instruction, all previous instructions are lost.
        ESP_LOGE(TAG, "Serial buffer overflow");
        this->buffer_overflow_callback_.call();
        break;
      case 0x65: {  // touch event return data
        if (to_process_length != 3) {
          ESP_LOGW(TAG, "Incorrect touch len: %zu (need 3)", to_process_length);
          break;
        }
 
        uint8_t page_id = to_process[0];
        uint8_t component_id = to_process[1];
        uint8_t touch_event = to_process[2];  // 0 -> release, 1 -> press
        ESP_LOGV(TAG, "Touch %s: page %u comp %u", touch_event ? LOG_STR_LITERAL("PRESS") : LOG_STR_LITERAL("RELEASE"),
                 page_id, component_id);
        for (auto *touch : this->touch_) {
          touch->process_touch(page_id, component_id, touch_event != 0);
        }
        this->touch_callback_.call(page_id, component_id, touch_event != 0);
        break;
      }
      case 0x66: {  // Nextion initiated new page event return data.
                    // Also is used for sendme command which we never explicitly initiate
        if (to_process_length != 1) {
          ESP_LOGW(TAG, "Page event: expect 1, got %zu", to_process_length);
          break;
        }
 
        uint8_t page_id = to_process[0];
        ESP_LOGV(TAG, "New page: %u", page_id);
        this->page_callback_.call(page_id);
        break;
      }
      case 0x67: {  // Touch Coordinate (awake)
        break;
      }
      case 0x68: {  // touch coordinate data (sleep)
 
        if (to_process_length != 5) {
          ESP_LOGW(TAG, "Touch coordinate: expect 5, got %zu", to_process_length);
          ESP_LOGW(TAG, "%s", to_process.c_str());
          break;
        }
 
        const uint16_t x = (uint16_t(to_process[0]) << 8) | to_process[1];
        const uint16_t y = (uint16_t(to_process[2]) << 8) | to_process[3];
        const uint8_t touch_event = to_process[4];  // 0 -> release, 1 -> press
        ESP_LOGV(TAG, "Touch %s at %u,%u", touch_event ? LOG_STR_LITERAL("PRESS") : LOG_STR_LITERAL("RELEASE"), x, y);
        break;
      }
 
      //  0x70 0x61 0x62 0x31 0x32 0x33 0xFF 0xFF 0xFF
      //  Returned when using get command for a string.
      //  Each byte is converted to char.
      //  data: ab123
      case 0x70:  // string variable data return
      {
        if (this->nextion_queue_.empty()) {
          ESP_LOGW(TAG, "String return but queue is empty");
          break;
        }
 
        this->set_string_return_(to_process);
        break;
      }
        //  0x71 0x01 0x02 0x03 0x04 0xFF 0xFF 0xFF
        //  Returned when get command to return a number
        //  4 byte 32-bit value in little endian order.
        //  (0x01+0x02*256+0x03*65536+0x04*16777216)
        //  data: 67305985
      case 0x71:  // numeric variable data return
      {
        if (this->nextion_queue_.empty()) {
          ESP_LOGE(TAG, "Numeric return but queue empty");
          break;
        }
 
        if (to_process_length < 4) {
          ESP_LOGE(TAG, "Numeric return but insufficient data (need 4, got %zu)", to_process_length);
          break;
        }
 
        int value = static_cast<int>(encode_uint32(to_process[3], to_process[2], to_process[1], to_process[0]));
 
        this->set_numeric_return_(value);
        break;
      }
 
      case 0x86: {  // device automatically enters into sleep mode
        ESP_LOGVV(TAG, "Auto sleep");
        this->is_sleeping_ = true;
        this->sleep_callback_.call();
        break;
      }
      case 0x87:  // device automatically wakes up
      {
        ESP_LOGVV(TAG, "Auto wake");
        this->is_sleeping_ = false;
        this->wake_callback_.call();
        this->all_components_send_state_(false);
        break;
      }
      case 0x88:  // system successful start up
      {
        ESP_LOGV(TAG, "System start: %zu", to_process_length);
        this->connection_state_.nextion_reports_is_setup_ = true;
        break;
      }
      case 0x89: {  // start SD card upgrade
        break;
      }
      // Data from nextion is
      // 0x90 - Start
      // variable length of 0x70 return formatted data (bytes) that contain the variable name: prints "temp1",0
      // 00 - NULL
      // 00/01 - Single byte for on/off
      // FF FF FF - End
      case 0x90: {  // Switched component
        std::string variable_name;
 
        // Get variable name
        auto index = to_process.find('\0');
        if (index == std::string::npos || (to_process_length - index - 1) < 1) {
          ESP_LOGE(TAG, "Bad switch data (0x90)");
          ESP_LOGN(TAG, "proc: %s %zu %zu", to_process.c_str(), to_process_length, index);
          break;
        }
 
        variable_name = to_process.substr(0, index);
        ++index;
 
        ESP_LOGN(TAG, "Switch %s: %s", ONOFF(to_process[index] != 0), variable_name.c_str());
 
#ifdef USE_NEXTION_TRIGGER_CUSTOM_SWITCH
        this->custom_switch_callback_.call(StringRef(variable_name), to_process[index] != 0);
#endif  // USE_NEXTION_TRIGGER_CUSTOM_SWITCH
 
        for (auto *switchtype : this->switchtype_) {
          switchtype->process_bool(variable_name, to_process[index] != 0);
        }
        break;
      }
      // Data from nextion is
      // 0x91 - Start
      // variable length of 0x70 return formatted data (bytes) that contain the variable name: prints "temp1",0
      // 00 - NULL
      // variable length of 0x71 return data: prints temp1.val,0
      // FF FF FF - End
      case 0x91: {  // Sensor component
        std::string variable_name;
 
        auto index = to_process.find('\0');
        if (index == std::string::npos || (to_process_length - index - 1) != 4) {
          ESP_LOGE(TAG, "Bad sensor data (0x91)");
          ESP_LOGN(TAG, "proc: %s %zu %zu", to_process.c_str(), to_process_length, index);
          break;
        }
 
        index = to_process.find('\0');
        variable_name = to_process.substr(0, index);
        // // Get variable name
        int value = static_cast<int>(
            encode_uint32(to_process[index + 4], to_process[index + 3], to_process[index + 2], to_process[index + 1]));
 
        ESP_LOGN(TAG, "Sensor: %s=%d", variable_name.c_str(), value);
 
#ifdef USE_NEXTION_TRIGGER_CUSTOM_SENSOR
        this->custom_sensor_callback_.call(StringRef(variable_name), value);
#endif  // USE_NEXTION_TRIGGER_CUSTOM_SENSOR
 
        for (auto *sensor : this->sensortype_) {
          sensor->process_sensor(variable_name, value);
        }
        break;
      }
 
      // Data from nextion is
      // 0x92 - Start
      // variable length of 0x70 return formatted data (bytes) that contain the variable name: prints "temp1",0
      // 00 - NULL
      // variable length of 0x70 return formatted data (bytes) that contain the text prints temp1.txt,0
      // 00 - NULL
      // FF FF FF - End
      case 0x92: {  // Text Sensor Component
        std::string variable_name;
        std::string text_value;
 
        // Get variable name
        auto index = to_process.find('\0');
        if (index == std::string::npos || (to_process_length - index - 1) < 1) {
          ESP_LOGE(TAG, "Bad text data (0x92)");
          ESP_LOGN(TAG, "proc: %s %zu %zu", to_process.c_str(), to_process_length, index);
          break;
        }
 
        variable_name = to_process.substr(0, index);
        ++index;
 
        // Get variable value without terminating NUL byte.  Length check above ensures substr len >= 0.
        text_value = to_process.substr(index, to_process_length - index - 1);
 
        ESP_LOGN(TAG, "Text sensor: %s='%s'", variable_name.c_str(), text_value.c_str());
 
        // NextionTextSensorResponseQueue *nq = new NextionTextSensorResponseQueue;
        // nq->variable_name = variable_name;
        // nq->state = text_value;
        // this->textsensorq_.push_back(nq);
 
#ifdef USE_NEXTION_TRIGGER_CUSTOM_TEXT_SENSOR
        this->custom_text_sensor_callback_.call(StringRef(variable_name), StringRef(text_value));
#endif  // USE_NEXTION_TRIGGER_CUSTOM_TEXT_SENSOR
 
        for (auto *textsensortype : this->textsensortype_) {
          textsensortype->process_text(variable_name, text_value);
        }
        break;
      }
      // Data from nextion is
      // 0x93 - Start
      // variable length of 0x70 return formatted data (bytes) that contain the variable name: prints "temp1",0
      // 00 - NULL
      // 00/01 - Single byte for on/off
      // FF FF FF - End
      case 0x93: {  // Binary Sensor component
        std::string variable_name;
 
        // Get variable name
        auto index = to_process.find('\0');
        if (index == std::string::npos || (to_process_length - index - 1) < 1) {
          ESP_LOGE(TAG, "Bad binary data (0x93)");
          ESP_LOGN(TAG, "proc: %s %zu %zu", to_process.c_str(), to_process_length, index);
          break;
        }
 
        variable_name = to_process.substr(0, index);
        ++index;
 
        ESP_LOGN(TAG, "Binary sensor: %s=%s", variable_name.c_str(), ONOFF(to_process[index] != 0));
 
#ifdef USE_NEXTION_TRIGGER_CUSTOM_BINARY_SENSOR
        this->custom_binary_sensor_callback_.call(StringRef(variable_name), to_process[index] != 0);
#endif  // USE_NEXTION_TRIGGER_CUSTOM_BINARY_SENSOR
 
        for (auto *binarysensortype : this->binarysensortype_) {
          binarysensortype->process_bool(&variable_name[0], to_process[index] != 0);
        }
        break;
      }
      case 0xFD: {  // data transparent transmit finished
        ESP_LOGVV(TAG, "Data transmit done");
#ifdef USE_NEXTION_WAVEFORM
        this->check_pending_waveform_();
#endif  // USE_NEXTION_WAVEFORM
        break;
      }
      case 0xFE: {  // data transparent transmit ready
        ESP_LOGVV(TAG, "Ready for transmit");
#ifdef USE_NEXTION_WAVEFORM
        if (this->waveform_queue_.empty()) {
          ESP_LOGE(TAG, "No waveforms queued");
          break;
        }
        auto &nb = this->waveform_queue_.front();
        auto *component = nb->component;
        size_t buffer_to_send = component->get_wave_buffer_size() < 255 ? component->get_wave_buffer_size() : 255;
        this->write_array(component->get_wave_buffer().data(), static_cast<int>(buffer_to_send));
        ESP_LOGN(TAG, "Send waveform: component id %d, waveform id %d, size %zu", component->get_component_id(),
                 component->get_wave_channel_id(), buffer_to_send);
        component->clear_wave_buffer(buffer_to_send);
        this->release_queue_entry_(nb);
        this->waveform_queue_.pop();
#else   // USE_NEXTION_WAVEFORM
        ESP_LOGW(TAG, "Waveform transmit ready but waveform not enabled");
#endif  // USE_NEXTION_WAVEFORM
        break;
      }
      default:
        ESP_LOGW(TAG, "Unknown event: 0x%02X", nextion_event);
        break;
    }
 
    this->command_data_.erase(0, to_process_length + DELIMITER_SIZE + 1);
  }
 
  ESP_LOGN(TAG, "Loop end");
  this->process_serial_();
}  // Nextion::process_nextion_commands_()
 
void Nextion::purge_stale_queue_entries_() {
  const uint32_t ms = App.get_loop_component_start_time();
 
  if (this->max_q_age_ms_ > 0 && !this->nextion_queue_.empty() &&
      ms - this->nextion_queue_.front()->queue_time > this->max_q_age_ms_) {
    for (auto it = this->nextion_queue_.begin(); it != this->nextion_queue_.end();) {
      if (ms - (*it)->queue_time > this->max_q_age_ms_) {
        NextionComponentBase *component = (*it)->component;
        ESP_LOGV(TAG, "Remove old queue '%s':'%s'", component->get_queue_type_string(),
                 component->get_variable_name().c_str());
 
        if (is_sleep_wake_command(component)) {
          this->is_sleeping_ = false;
        }
        this->release_queue_entry_(*it);
        it = this->nextion_queue_.erase(it);
 
      } else {
        break;
      }
    }
  }
}
 
void Nextion::set_nextion_sensor_state(int queue_type, const std::string &name, float state) {
  this->set_nextion_sensor_state(static_cast<NextionQueueType>(queue_type), name, state);
}
 
void Nextion::set_nextion_sensor_state(NextionQueueType queue_type, const std::string &name, float state) {
  ESP_LOGN(TAG, "State: %s=%lf (type %d)", name.c_str(), state, queue_type);
 
  switch (queue_type) {
    case NextionQueueType::SENSOR: {
      for (auto *sensor : this->sensortype_) {
        if (name == sensor->get_variable_name()) {
          sensor->set_state(state, true, true);
          break;
        }
      }
      break;
    }
    case NextionQueueType::BINARY_SENSOR: {
      for (auto *sensor : this->binarysensortype_) {
        if (name == sensor->get_variable_name()) {
          sensor->set_state(state != 0, true, true);
          break;
        }
      }
      break;
    }
    case NextionQueueType::SWITCH: {
      for (auto *sensor : this->switchtype_) {
        if (name == sensor->get_variable_name()) {
          sensor->set_state(state != 0, true, true);
          break;
        }
      }
      break;
    }
    default: {
      ESP_LOGW(TAG, "set_sensor_state: bad type %d", queue_type);
    }
  }
}
 
void Nextion::set_nextion_text_state(const std::string &name, const std::string &state) {
  ESP_LOGV(TAG, "State: %s='%s'", name.c_str(), state.c_str());
 
  for (auto *sensor : this->textsensortype_) {
    if (name == sensor->get_variable_name()) {
      sensor->set_state(state, true, true);
      break;
    }
  }
}
 
void Nextion::all_components_send_state_(bool force_update) {
  ESP_LOGV(TAG, "Send states");
  for (auto *binarysensortype : this->binarysensortype_) {
    if (force_update || binarysensortype->get_needs_to_send_update())
      binarysensortype->send_state_to_nextion();
  }
  for (auto *sensortype : this->sensortype_) {
#ifdef USE_NEXTION_WAVEFORM
    if ((force_update || sensortype->get_needs_to_send_update()) && sensortype->get_wave_channel_id() == UINT8_MAX) {
#else   // USE_NEXTION_WAVEFORM
    if (force_update || sensortype->get_needs_to_send_update()) {
#endif  // USE_NEXTION_WAVEFORM
      sensortype->send_state_to_nextion();
    }
  }
  for (auto *switchtype : this->switchtype_) {
    if (force_update || switchtype->get_needs_to_send_update())
      switchtype->send_state_to_nextion();
  }
  for (auto *textsensortype : this->textsensortype_) {
    if (force_update || textsensortype->get_needs_to_send_update())
      textsensortype->send_state_to_nextion();
  }
}
 
void Nextion::update_components_by_prefix(const std::string &prefix) {
  for (auto *binarysensortype : this->binarysensortype_) {
    if (binarysensortype->get_variable_name().find(prefix, 0) != std::string::npos)
      binarysensortype->update_component_settings(true);
  }
  for (auto *sensortype : this->sensortype_) {
    if (sensortype->get_variable_name().find(prefix, 0) != std::string::npos)
      sensortype->update_component_settings(true);
  }
  for (auto *switchtype : this->switchtype_) {
    if (switchtype->get_variable_name().find(prefix, 0) != std::string::npos)
      switchtype->update_component_settings(true);
  }
  for (auto *textsensortype : this->textsensortype_) {
    if (textsensortype->get_variable_name().find(prefix, 0) != std::string::npos)
      textsensortype->update_component_settings(true);
  }
}
 
uint16_t Nextion::recv_ret_string_(std::string &response, uint32_t timeout, bool recv_flag) {
  uint8_t c = 0;
  uint8_t nr_of_ff_bytes = 0;
  bool exit_flag = false;
  bool ff_flag = false;
 
  const uint32_t start = millis();
 
  while ((timeout == 0 && this->available()) || millis() - start <= timeout) {
    if (!this->available()) {
      App.feed_wdt();
      delay(1);
      continue;
    }
 
    this->read_byte(&c);
    if (c == 0xFF) {
      nr_of_ff_bytes++;
    } else {
      nr_of_ff_bytes = 0;
      ff_flag = false;
    }
 
    if (nr_of_ff_bytes >= 3)
      ff_flag = true;
 
    response += (char) c;
    if (recv_flag) {
      if (response.find(0x05) != std::string::npos) {
        exit_flag = true;
      }
    }
    App.feed_wdt();
    delay(2);
 
    if (exit_flag || ff_flag) {
      break;
    }
  }
 
  if (ff_flag)
    response = response.substr(0, response.length() - 3);  // Remove last 3 0xFF
 
  return response.length();
}
 
// Allocates a queue entry owning a bare NO_RESULT component; nullptr when the queue is full or memory is out
NextionQueue *Nextion::make_no_result_entry_(const std::string &variable_name) {
#ifdef USE_NEXTION_MAX_QUEUE_SIZE
  if (this->max_queue_size_ > 0 && this->nextion_queue_.size() >= this->max_queue_size_) {
    ESP_LOGW(TAG, "Queue full (%zu), drop: %s", this->nextion_queue_.size(), variable_name.c_str());
    return nullptr;
  }
#endif
 
  auto *nextion_queue = RAMAllocator<nextion::NextionQueue>().allocate(1);
  if (nextion_queue == nullptr) {
    ESP_LOGW(TAG, "Queue alloc failed");
    return nullptr;
  }
  new (nextion_queue) nextion::NextionQueue;
 
  nextion_queue->component = RAMAllocator<nextion::NextionComponentBase>().allocate(1);
  if (nextion_queue->component == nullptr) {
    ESP_LOGW(TAG, "Component alloc failed");
    this->release_queue_entry_(nextion_queue);
    return nullptr;
  }
  new (nextion_queue->component) nextion::NextionComponentBase;
  nextion_queue->component->set_variable_name(variable_name);
  nextion_queue->queue_time = App.get_loop_component_start_time();
  return nextion_queue;
}
 
void Nextion::add_no_result_to_queue_(const std::string &variable_name) {
  auto *nextion_queue = this->make_no_result_entry_(variable_name);
  if (nextion_queue == nullptr)
    return;
  this->nextion_queue_.push_back(nextion_queue);
  ESP_LOGN(TAG, "Queue NORESULT: %s", variable_name.c_str());
}
 
void Nextion::add_no_result_to_queue_with_command_(const std::string &variable_name, const std::string &command) {
  if ((!this->is_setup() && !this->connection_state_.ignore_is_setup_) || command.empty())
    return;
 
  ESP_LOGV(TAG, "Queue NORESULT '%s': %s", variable_name.c_str(), command.c_str());
 
  if (this->send_command_(command)) {
    this->add_no_result_to_queue_(variable_name);
#ifdef USE_NEXTION_COMMAND_SPACING
  } else {
    // Command blocked by spacing, add to queue WITH the command for retry
    this->add_no_result_to_queue_with_pending_command_(variable_name, command);
#endif  // USE_NEXTION_COMMAND_SPACING
  }
}
 
#ifdef USE_NEXTION_COMMAND_SPACING
void Nextion::add_no_result_to_queue_with_pending_command_(const std::string &variable_name,
                                                           const std::string &command) {
  auto *nextion_queue = this->make_no_result_entry_(variable_name);
  if (nextion_queue == nullptr)
    return;
  nextion_queue->pending_command = command;  // Store command for retry
  this->nextion_queue_.push_back(nextion_queue);
  ESP_LOGVV(TAG, "Queue with pending command: %s", variable_name.c_str());
}
#endif  // USE_NEXTION_COMMAND_SPACING
 
bool Nextion::add_no_result_to_queue_with_ignore_sleep_printf_(const std::string &variable_name, const char *format,
                                                               ...) {
  if ((!this->is_setup() && !this->connection_state_.ignore_is_setup_))
    return false;
 
  char buffer[256];
  va_list arg;
  va_start(arg, format);
  int ret = vsnprintf(buffer, sizeof(buffer), format, arg);
  va_end(arg);
  if (ret <= 0) {
    ESP_LOGW(TAG, "Bad cmd format: '%s'", format);
    return false;
  }
 
  this->add_no_result_to_queue_with_command_(variable_name, buffer);
  return true;
}
 
bool Nextion::add_no_result_to_queue_with_printf_(const std::string &variable_name, const char *format, ...) {
  if ((!this->is_setup() && !this->connection_state_.ignore_is_setup_) || this->is_sleeping())
    return false;
 
  char buffer[256];
  va_list arg;
  va_start(arg, format);
  int ret = vsnprintf(buffer, sizeof(buffer), format, arg);
  va_end(arg);
  if (ret <= 0) {
    ESP_LOGW(TAG, "Bad cmd format: '%s'", format);
    return false;
  }
 
  this->add_no_result_to_queue_with_command_(variable_name, buffer);
  return true;
}
 
void Nextion::add_no_result_to_queue_with_set(NextionComponentBase *component, int32_t state_value) {
  this->add_no_result_to_queue_with_set(component->get_variable_name(), component->get_variable_name_to_send(),
                                        state_value);
}
 
void Nextion::add_no_result_to_queue_with_set(const std::string &variable_name,
                                              const std::string &variable_name_to_send, int32_t state_value) {
  this->add_no_result_to_queue_with_set_internal_(variable_name, variable_name_to_send, state_value);
}
 
void Nextion::add_no_result_to_queue_with_set_internal_(const std::string &variable_name,
                                                        const std::string &variable_name_to_send, int32_t state_value,
                                                        bool is_sleep_safe) {
  if ((!this->is_setup() && !this->connection_state_.ignore_is_setup_) || (!is_sleep_safe && this->is_sleeping()))
    return;
 
  this->add_no_result_to_queue_with_ignore_sleep_printf_(variable_name, "%s=%" PRId32, variable_name_to_send.c_str(),
                                                         state_value);
}
 
void Nextion::add_no_result_to_queue_with_set(NextionComponentBase *component, const std::string &state_value) {
  this->add_no_result_to_queue_with_set(component->get_variable_name(), component->get_variable_name_to_send(),
                                        state_value);
}
void Nextion::add_no_result_to_queue_with_set(const std::string &variable_name,
                                              const std::string &variable_name_to_send,
                                              const std::string &state_value) {
  this->add_no_result_to_queue_with_set_internal_(variable_name, variable_name_to_send, state_value);
}
 
void Nextion::add_no_result_to_queue_with_set_internal_(const std::string &variable_name,
                                                        const std::string &variable_name_to_send,
                                                        const std::string &state_value, bool is_sleep_safe) {
  if ((!this->is_setup() && !this->connection_state_.ignore_is_setup_) || (!is_sleep_safe && this->is_sleeping()))
    return;
 
  this->add_no_result_to_queue_with_printf_(variable_name, "%s=\"%s\"", variable_name_to_send.c_str(),
                                            state_value.c_str());
}
 
void Nextion::add_to_get_queue(NextionComponentBase *component) {
  if ((!this->is_setup() && !this->connection_state_.ignore_is_setup_))
    return;
 
#ifdef USE_NEXTION_MAX_QUEUE_SIZE
  if (this->max_queue_size_ > 0 && this->nextion_queue_.size() >= this->max_queue_size_) {
    ESP_LOGW(TAG, "Queue full (%zu), drop GET: %s", this->nextion_queue_.size(),
             component->get_variable_name().c_str());
    return;
  }
#endif
 
  RAMAllocator<nextion::NextionQueue> allocator;
  nextion::NextionQueue *nextion_queue = allocator.allocate(1);
  if (nextion_queue == nullptr) {
    ESP_LOGW(TAG, "Queue alloc failed");
    return;
  }
  new (nextion_queue) nextion::NextionQueue;
 
  nextion_queue->component = component;
  nextion_queue->queue_time = App.get_loop_component_start_time();
 
  ESP_LOGN(TAG, "Queue %s: %s", component->get_queue_type_string(), component->get_variable_name().c_str());
 
  std::string command = "get " + component->get_variable_name_to_send();
 
#ifdef USE_NEXTION_COMMAND_SPACING
  // Always enqueue first so the response handler is present when the command
  // is eventually sent. Store the command for retry if spacing blocked it;
  // process_pending_in_queue_() will transmit it when the pacer allows.
  nextion_queue->pending_command = command;
  this->nextion_queue_.push_back(nextion_queue);
  if (this->send_command_(command)) {
    nextion_queue->pending_command.clear();
  }
#else   // USE_NEXTION_COMMAND_SPACING
  if (this->send_command_(command)) {
    this->nextion_queue_.push_back(nextion_queue);
  } else {
    this->release_queue_entry_(nextion_queue);
  }
#endif  // USE_NEXTION_COMMAND_SPACING
}
 
#ifdef USE_NEXTION_WAVEFORM
void Nextion::add_addt_command_to_queue(NextionComponentBase *component) {
  if ((!this->is_setup() && !this->connection_state_.ignore_is_setup_) || this->is_sleeping())
    return;
 
  RAMAllocator<nextion::NextionQueue> allocator;
  nextion::NextionQueue *nextion_queue = allocator.allocate(1);
  if (nextion_queue == nullptr) {
    ESP_LOGW(TAG, "Queue alloc failed");
    return;
  }
  new (nextion_queue) nextion::NextionQueue;
 
  nextion_queue->component = component;
  nextion_queue->queue_time = App.get_loop_component_start_time();
 
  if (!this->waveform_queue_.push(nextion_queue)) {
    ESP_LOGW(TAG, "Waveform queue full, drop");
    this->release_queue_entry_(nextion_queue);
    return;
  }
  if (this->waveform_queue_.size() == 1)
    this->check_pending_waveform_();
}
 
void Nextion::check_pending_waveform_() {
  if (this->waveform_queue_.empty())
    return;
 
  auto *nb = this->waveform_queue_.front();
  auto *component = nb->component;
  size_t buffer_to_send = component->get_wave_buffer_size() < 255 ? component->get_wave_buffer_size() : 255;
 
  char command[24];  // "addt " + uint8 + "," + uint8 + "," + uint8 + null = max 17 chars
  buf_append_printf(command, sizeof(command), 0, "addt %u,%u,%zu", component->get_component_id(),
                    component->get_wave_channel_id(), buffer_to_send);
  // If spacing or setup state blocks the send, leave the entry at the front
  // of waveform_queue_ for retry on the next loop iteration via
  // check_pending_waveform_(). Only pop on a successful send.
  this->send_command_(command);
}
#endif  // USE_NEXTION_WAVEFORM
 
void Nextion::set_writer(const nextion_writer_t &writer) { this->writer_ = writer; }
 
bool Nextion::is_updating() { return this->connection_state_.is_updating_; }
 
}  // namespace esphome::nextion