diff --git a/node/pkg/websocketfetcher/providers/orangex/orangex.go b/node/pkg/websocketfetcher/providers/orangex/orangex.go index e83edcdc6..00cf1664d 100644 --- 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 index 773e5189c..314b41a97 100644 --- 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)) }