diff --git a/exchanges/gateio/gateio_websocket.go b/exchanges/gateio/gateio_websocket.go index 15ebcdf0..60853d4a 100644 --- a/exchanges/gateio/gateio_websocket.go +++ b/exchanges/gateio/gateio_websocket.go @@ -339,7 +339,8 @@ func (g *Gateio) GenerateDefaultSubscriptions() { // Subscribe sends a websocket message to receive data from the channel func (g *Gateio) Subscribe(channelToSubscribe wshandler.WebsocketChannelSubscription) error { params := []interface{}{g.FormatExchangeCurrency(channelToSubscribe.Currency, - asset.Spot).String()} + asset.Spot).Upper()} + for i := range channelToSubscribe.Params { params = append(params, channelToSubscribe.Params[i]) } @@ -372,7 +373,7 @@ func (g *Gateio) Unsubscribe(channelToSubscribe wshandler.WebsocketChannelSubscr ID: g.WebsocketConn.GenerateMessageID(true), Method: unsbuscribeText, Params: []interface{}{g.FormatExchangeCurrency(channelToSubscribe.Currency, - asset.Spot).String(), 1800}, + asset.Spot).Upper(), 1800}, } resp, err := g.WebsocketConn.SendMessageReturnResponse(subscribe.ID, subscribe) if err != nil {