fix: update based on feedback

Bisonai · Oct 11, 2024 · 2588952 · 2588952
1 parent 25cc82a
commit 2588952
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/node/pkg/websocketfetcher/providers/orangex/orangex.go b/node/pkg/websocketfetcher/providers/orangex/orangex.go
@@ -113,6 +113,11 @@ func (f *OrangeXFetcher) handleMessage(ctx context.Context, message map[string]a
 		log.Error().Str("Player", "OrangeX").Err(err).Msg("error in orangex.handleMessage")
 		return err
 	}
+
+	if feedData == nil {
+		return nil
+	}
+
 	f.FeedDataBuffer <- feedData
 	return nil
 }

diff --git a/node/pkg/wss/utils.go b/node/pkg/wss/utils.go
@@ -171,10 +171,6 @@ func (ws *WebsocketHelper) Write(ctx context.Context, message interface{}) error
 	return nil
 }
 
-func (ws *WebsocketHelper) RawByteWrite(ctx context.Context, message []byte) error {
-	return ws.Conn.Write(ctx, websocket.MessageBinary, message)
-}
-
 func (ws *WebsocketHelper) RawWrite(ctx context.Context, message string) error {
 	return ws.Conn.Write(ctx, websocket.MessageText, []byte(message))
 }