From aec0d291cacf0a10376b99054a2e9be5e57fa428 Mon Sep 17 00:00:00 2001 From: Sasivarunan Kulandaivel Date: Tue, 25 Mar 2025 16:38:10 +0530 Subject: [PATCH] fix crash bcz of DecodeEvent failure --- client/native/client.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/client/native/client.go b/client/native/client.go index 166f3a36..63020053 100644 --- a/client/native/client.go +++ b/client/native/client.go @@ -420,7 +420,9 @@ func (c *Client) wsRead(ws *websocket.Conn) chan error { e, err := ari.DecodeEvent(data) if err != nil { - errChan <- eris.Wrap(err, "failed to devoce websocket message to event") + c.Options.Logger.Error("failed to decode websocket message to event", "error", err) + // if decode fails, continue to next message, we can't process nil ari.Event anyway + continue } c.bus.Send(e)