From 8127d04855cf70054b78575a1985b868eb3ced4f Mon Sep 17 00:00:00 2001
From: caoqianming <caoqianming@foxmail.com>
Date: Tue, 3 Mar 2026 16:56:37 +0800
Subject: [PATCH] =?UTF-8?q?refactor:=20=E5=B0=86=20PointValueChange=20?=
 =?UTF-8?q?=E9=87=8D=E5=91=BD=E5=90=8D=E4=B8=BA=20PointNewValue?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/connection.rs | 6 +++---
 src/event.rs      | 6 +++---
 src/websocket.rs  | 2 +-
 3 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/src/connection.rs b/src/connection.rs
index e01e7e2..dd3183c 100644
--- a/src/connection.rs
+++ b/src/connection.rs
@@ -261,7 +261,7 @@ impl ConnectionManager {
                             .map(crate::telemetry::PointQuality::from_status_code)
                             .unwrap_or(crate::telemetry::PointQuality::Unknown);
 
-                        let _ = event_manager.send(crate::event::ReloadEvent::PointValueChange(
+                        let _ = event_manager.send(crate::event::ReloadEvent::PointNewValue(
                             crate::telemetry::PointNewValue {
                                 source_id,
                                 point_id: Some(point_id),
@@ -758,7 +758,7 @@ impl ConnectionManager {
         // Emit local updates only when the full batch succeeds.
         if let Some(event_manager) = &self.event_manager {
             for (source_id, point_id, variant) in success_events {
-                if let Err(e) = event_manager.send(crate::event::ReloadEvent::PointValueChange(
+                if let Err(e) = event_manager.send(crate::event::ReloadEvent::PointNewValue(
                     crate::telemetry::PointNewValue {
                         source_id,
                         point_id: Some(point_id),
@@ -883,7 +883,7 @@ impl ConnectionManager {
                                 .unwrap_or(crate::telemetry::PointQuality::Unknown);
 
                             if let Some(event_manager) = &manager.event_manager {
-                                let _ = event_manager.send(crate::event::ReloadEvent::PointValueChange(
+                                let _ = event_manager.send(crate::event::ReloadEvent::PointNewValue(
                                     crate::telemetry::PointNewValue {
                                     source_id: current_source_id,
                                     point_id: None,
diff --git a/src/event.rs b/src/event.rs
index cb5592d..0e6af8a 100644
--- a/src/event.rs
+++ b/src/event.rs
@@ -24,7 +24,7 @@ pub enum ReloadEvent {
         source_id: Uuid,
         point_ids: Vec<Uuid>,
     },
-    PointValueChange(crate::telemetry::PointNewValue),
+    PointNewValue(crate::telemetry::PointNewValue),
 }
 
 pub struct EventManager {
@@ -118,7 +118,7 @@ impl EventManager {
                             tracing::error!("Failed to unsubscribe points: {}", e);
                         }
                     }
-                    ReloadEvent::PointValueChange(payload) => {
+                    ReloadEvent::PointNewValue(payload) => {
                         let source_id = payload.source_id;
                         let client_handle = payload.client_handle;
                         let point_id = if let Some(point_id) = payload.point_id {
@@ -149,7 +149,7 @@ impl EventManager {
                             }
 
                             if let Some(ws_manager) = &ws_manager_clone {
-                                let ws_message = crate::websocket::WsMessage::PointValueChange(
+                                let ws_message = crate::websocket::WsMessage::PointNewValue(
                                     monitor.clone(),
                                 );
 
diff --git a/src/websocket.rs b/src/websocket.rs
index 25bebc8..e5627ff 100644
--- a/src/websocket.rs
+++ b/src/websocket.rs
@@ -15,7 +15,7 @@ use uuid::Uuid;
 #[derive(Debug, Clone, Serialize, Deserialize)]
 #[serde(tag = "type", content = "data")]
 pub enum WsMessage {
-    PointValueChange(crate::telemetry::PointMonitorInfo),
+    PointNewValue(crate::telemetry::PointMonitorInfo),
     PointSetValueBatchResult(crate::connection::BatchSetPointValueRes),
 }