From b889355d8d054badbae89d57569a49a746536f78 Mon Sep 17 00:00:00 2001
From: Terrence <terrence@tenclass.com>
Date: Wed, 12 Feb 2025 05:37:27 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=94=A4=E9=86=92=E5=90=8E?=
 =?UTF-8?q?=E4=BA=AE=E7=BA=A2=E7=81=AF=E4=B8=8D=E8=AF=B4=E8=AF=9D=E7=9A=84?=
 =?UTF-8?q?bug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 main/protocols/mqtt_protocol.cc | 2 ++
 main/protocols/protocol.h       | 3 +++
 2 files changed, 5 insertions(+)

diff --git a/main/protocols/mqtt_protocol.cc b/main/protocols/mqtt_protocol.cc
index 8052c011..1f8f78c0 100644
--- a/main/protocols/mqtt_protocol.cc
+++ b/main/protocols/mqtt_protocol.cc
@@ -154,6 +154,7 @@ bool MqttProtocol::OpenAudioChannel() {
     }
 
     session_id_ = "";
+    xEventGroupClearBits(event_group_handle_, MQTT_PROTOCOL_SERVER_HELLO_EVENT);
 
     // 发送 hello 消息申请 UDP 通道
     std::string message = "{";
@@ -234,6 +235,7 @@ void MqttProtocol::ParseServerHello(const cJSON* root) {
     auto session_id = cJSON_GetObjectItem(root, "session_id");
     if (session_id != nullptr) {
         session_id_ = session_id->valuestring;
+        ESP_LOGI(TAG, "Session ID: %s", session_id_.c_str());
     }
 
     // Get sample rate from hello message
diff --git a/main/protocols/protocol.h b/main/protocols/protocol.h
index 913f54ff..faa8a94d 100644
--- a/main/protocols/protocol.h
+++ b/main/protocols/protocol.h
@@ -30,6 +30,9 @@ public:
     inline int server_sample_rate() const {
         return server_sample_rate_;
     }
+    inline const std::string& session_id() const {
+        return session_id_;
+    }
 
     void OnIncomingAudio(std::function<void(std::vector<uint8_t>&& data)> callback);
     void OnIncomingJson(std::function<void(const cJSON* root)> callback);