From adc86f748870c48efded9315472cc0a355de5df1 Mon Sep 17 00:00:00 2001
From: Your Name <you@example.com>
Date: Sun, 10 Mar 2024 15:34:45 +0100
Subject: [PATCH] Add  jump from READ_STATE_BREAK to READ_STATE_SID.

---
 components/truma_inetbox/LinBusListener.cpp | 17 +++++++++++------
 1 file changed, 11 insertions(+), 6 deletions(-)

diff --git a/components/truma_inetbox/LinBusListener.cpp b/components/truma_inetbox/LinBusListener.cpp
index a91e9fd..32a84a1 100644
--- a/components/truma_inetbox/LinBusListener.cpp
+++ b/components/truma_inetbox/LinBusListener.cpp
@@ -164,6 +164,7 @@ void LinBusListener::onReceive_() {
 void LinBusListener::read_lin_frame_() {
   u_int8_t buf;
   QUEUE_LOG_MSG log_msg = QUEUE_LOG_MSG();
+
   switch (this->current_state_) {
     case READ_STATE_BREAK:
       // Check if there was an unanswered message before break.
@@ -187,14 +188,19 @@ void LinBusListener::read_lin_frame_() {
       // Reset current state
       this->current_state_reset_();
 
-      // First is Break expected
-      if (!this->read_byte(&buf) || buf != LIN_BREAK) {
+      // First is Break expected. Arduino platform does not relay BREAK if send as special.
+      if (!this->read_byte(&buf) || (buf != LIN_BREAK && buf != LIN_SYNC)) {
         log_msg.type = QUEUE_LOG_MSG_TYPE::VV_READ_LIN_FRAME_BREAK_EXPECTED;
         log_msg.current_PID = buf;
         TRUMA_LOGVV_ISR(log_msg);
       } else {
-        // ESP_LOGVV(TAG, "%02X BREAK received.", buf);
-        this->current_state_ = READ_STATE_SYNC;
+        if (buf == LIN_BREAK) {
+          // ESP_LOGVV(TAG, "%02X BREAK received.", buf);
+          this->current_state_ = READ_STATE_SYNC;
+        } else if (buf == LIN_SYNC) {
+          // ESP_LOGVV(TAG, "%02X SYNC found.", buf);
+          this->current_state_ = READ_STATE_SID;
+        }
       }
       break;
     case READ_STATE_SYNC:
@@ -232,14 +238,13 @@ void LinBusListener::read_lin_frame_() {
       // Even on error read data.
       this->current_state_ = READ_STATE_DATA;
       break;
-    case READ_STATE_DATA: {
+    case READ_STATE_DATA:
       auto current = micros();
       if (current > (this->last_data_recieved_ + this->time_per_first_byte_)) {
         // timeout occured.
         this->current_state_ = READ_STATE_BREAK;
         return;
       }
-    }
       this->read_byte(&buf);
       this->current_data_[this->current_data_count_] = buf;
       this->current_data_count_++;