fix: driver heartbeat

wdvxdr1123 · Jul 28, 2023 · 3023a1d · 3023a1d
1 parent 2b719f2
commit 3023a1d
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/driver/wsclient.go b/driver/wsclient.go
@@ -125,10 +125,10 @@ func (ws *WSClient) Listen(handler func([]byte, zero.APICaller)) {
 			}
 			continue
 		}
-		if rsp.Get("meta_event_type").Str != "heartbeat" { // 忽略心跳事件
-			log.Debug("[ws] 接收到事件: ", helper.BytesToString(payload))
+		if rsp.Get("meta_event_type").Str == "heartbeat" { // 忽略心跳事件
 			continue
 		}
+		log.Debug("[ws] 接收到事件: ", helper.BytesToString(payload))
 		handler(payload, ws)
 	}
 }

diff --git a/driver/wsserver.go b/driver/wsserver.go
@@ -196,10 +196,10 @@ func (wssc *WSSCaller) listen(handler func([]byte, zero.APICaller)) {
 			}
 			continue
 		}
-		if rsp.Get("meta_event_type").Str != "heartbeat" { // 忽略心跳事件
-			log.Debug("[wss] 接收到事件: ", helper.BytesToString(payload))
+		if rsp.Get("meta_event_type").Str == "heartbeat" { // 忽略心跳事件
 			continue
 		}
+		log.Debug("[wss] 接收到事件: ", helper.BytesToString(payload))
 		handler(payload, wssc)
 	}
 }