From 114d350e5b53b3d9d3feb53e7a7d0849be8090ef Mon Sep 17 00:00:00 2001
From: caoqianming <caoqianming@foxmail.com>
Date: Thu, 5 Mar 2026 09:31:52 +0800
Subject: [PATCH] =?UTF-8?q?refactor:=20=E7=A7=BB=E9=99=A4=20ReloadEvent::P?=
 =?UTF-8?q?ointCreate=EF=BC=8C=E7=BB=9F=E4=B8=80=E4=BD=BF=E7=94=A8=20Point?=
 =?UTF-8?q?CreateBatch?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/event.rs | 27 ---------------------------
 1 file changed, 27 deletions(-)

diff --git a/src/event.rs b/src/event.rs
index 6d26aa6..565ce0f 100644
--- a/src/event.rs
+++ b/src/event.rs
@@ -12,10 +12,6 @@ pub enum ReloadEvent {
     SourceDelete {
         source_id: Uuid,
     },
-    PointCreate {
-        source_id: Uuid,
-        point_id: Uuid,
-    },
     PointCreateBatch {
         source_id: Uuid,
         point_ids: Vec<Uuid>,
@@ -58,29 +54,6 @@ impl EventManager {
                             tracing::error!("Failed to disconnect from source {}: {}", source_id, e);
                         }
                     }
-                    ReloadEvent::PointCreate { source_id, point_id } => {
-                        match connection_manager
-                            .subscribe_points_from_source(source_id, Some(vec![point_id]), &pool)
-                            .await
-                        {
-                            Ok(stats) => {
-                                let subscribed = *stats.get("subscribed").unwrap_or(&0);
-                                let polled = *stats.get("polled").unwrap_or(&0);
-                                let total = *stats.get("total").unwrap_or(&0);
-                                tracing::info!(
-                                    "PointCreate subscribe finished for source {} point {}: subscribed={}, polled={}, total={}",
-                                    source_id,
-                                    point_id,
-                                    subscribed,
-                                    polled,
-                                    total
-                                );
-                            }
-                            Err(e) => {
-                                tracing::error!("Failed to subscribe to point {}: {}", point_id, e);
-                            }
-                        }
-                    }
                     ReloadEvent::PointCreateBatch { source_id, point_ids } => {
                         let requested_count = point_ids.len();
                         match connection_manager