From 3023a1d8ea8622a29bcfb7bc23c8606dcd94916e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=BA=90=E6=96=87=E9=9B=A8?= <41315874+fumiama@users.noreply.github.com> Date: Fri, 28 Jul 2023 16:05:08 +0800 Subject: [PATCH] fix: driver heartbeat --- driver/wsclient.go | 4 ++-- driver/wsserver.go | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/driver/wsclient.go b/driver/wsclient.go index fafa3d1..d4f15d7 100644 --- 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 index 5a2ad43..9ed46b5 100644 --- 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) } }