From 487d3cdf2643f82facadce0e073aa773ab7ee6a1 Mon Sep 17 00:00:00 2001
From: caoqianming <caoqianming@foxmail.com>
Date: Fri, 6 Mar 2026 09:13:30 +0800
Subject: [PATCH] =?UTF-8?q?refactor:=20=E4=BC=98=E5=8C=96=20unsubscribe=5F?=
 =?UTF-8?q?points=5Ffrom=5Fsource=20=E4=B8=AD=20status=20=E9=94=81?=
 =?UTF-8?q?=E7=B2=92=E5=BA=A6=EF=BC=8C=E4=BD=BF=E7=94=A8=20get=5Fsession?=
 =?UTF-8?q?=20=E5=87=BD=E6=95=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/connection.rs | 12 +++++++-----
 1 file changed, 7 insertions(+), 5 deletions(-)

diff --git a/src/connection.rs b/src/connection.rs
index bfde9ca..44f8fef 100644
--- a/src/connection.rs
+++ b/src/connection.rs
@@ -1207,14 +1207,16 @@ impl ConnectionManager {
         }
 
         let target_ids: std::collections::HashSet<Uuid> = point_ids.into_iter().collect();
-        let (session, subscription_id, point_item_pairs) = {
+        let session = self.get_session(source_id).await;
+        let Some(session) = session else {
+            return Ok(0);
+        };
+
+        let (subscription_id, point_item_pairs) = {
             let status = self.status.read().await;
             let Some(conn_status) = status.get(&source_id) else {
                 return Ok(0);
             };
-            let Some(session) = conn_status.session.clone() else {
-                return Ok(0);
-            };
             let Some(subscription_id) = conn_status.subscription_id else {
                 return Ok(0);
             };
@@ -1226,7 +1228,7 @@ impl ConnectionManager {
                 .map(|(point_id, monitored_item_id)| (*point_id, *monitored_item_id))
                 .collect();
 
-            (session, subscription_id, items)
+            (subscription_id, items)
         };
 
         if point_item_pairs.is_empty() {