Fix: check channel message pointer (#30)

celenium-io · Nov 5, 2023 · 5969eec · 5969eec
1 parent fbfe66c
commit 5969eec
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/cmd/api/handler/websocket/channel.go b/cmd/api/handler/websocket/channel.go
@@ -91,6 +91,10 @@ func (channel *Channel[I, M]) waitMessage(ctx context.Context) {
 			if !ok {
 				return
 			}
+			if msg == nil {
+				log.Warn().Str("channel", channel.storageChannelName).Msg("nil message")
+				continue
+			}
 			if msg.Channel != channel.storageChannelName {
 				channel.log.Error().
 					Str("msg", msg.Channel).