Fixing proxy message sending 3

paveldn · Feb 6, 2024 · 0ef3125 · 0ef3125
1 parent 2c6d583
commit 0ef3125
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 1 deletion.
diff --git a/include/protocol/haier_protocol.h b/include/protocol/haier_protocol.h
@@ -122,6 +122,7 @@ class ProtocolHandler
     std::chrono::steady_clock::time_point   cooldown_time_point_;
     std::chrono::steady_clock::time_point   answer_time_point_;
     std::chrono::steady_clock::time_point   retry_time_point_;
+    std::chrono::steady_clock::time_point   last_message_time_point_;
 };
 
 

diff --git a/src/protocol/haier_protocol.cpp b/src/protocol/haier_protocol.cpp
@@ -89,7 +89,15 @@ void ProtocolHandler::loop()
           if (this->write_message_(msg.message, msg.use_crc))
           {
             this->last_message_type_ = msg.message.get_frame_type();
-            this->state_ = msg.proxy_message ? ProtocolState::WAITING_FOR_PROXY_ANSWER : ProtocolState::WAITING_FOR_ANSWER;
+            if (msg.proxy_message)
+            {
+              this->state_ = ProtocolState::WAITING_FOR_PROXY_ANSWER;
+            }
+            else
+            {
+              this->state_ = ProtocolState::WAITING_FOR_ANSWER;
+              last_message_time_point_ = now;
+            }
             this->answer_time_point_ = now + this->answer_timeout_interval_;
             this->retry_time_point_ = now + msg.retry_interval;
           }
@@ -126,6 +134,8 @@ void ProtocolHandler::loop()
     }
     if (this->transport_.available() > 0)
     {
+
+      HAIER_LOGD("Answer delay: %dms", std::chrono::duration_cast<std::chrono::milliseconds>(now - this->last_message_time_point_).count());
       TimestampedFrame frame;
       this->transport_.pop(frame);
       FrameType msg_type = (FrameType) frame.frame.get_frame_type();