diff --git a/pkg/exchange/max/maxapi/websocket.go b/pkg/exchange/max/maxapi/websocket.go index 017e4da01..c8b4970e2 100644 --- a/pkg/exchange/max/maxapi/websocket.go +++ b/pkg/exchange/max/maxapi/websocket.go @@ -21,6 +21,7 @@ type Subscription struct { Channel string `json:"channel"` Market string `json:"market"` Depth int `json:"depth,omitempty"` + Resolution string `json:"resolution,omitempty"` } type WebsocketCommand struct { diff --git a/pkg/exchange/max/stream.go b/pkg/exchange/max/stream.go index ae57994a7..ec518dd2d 100644 --- a/pkg/exchange/max/stream.go +++ b/pkg/exchange/max/stream.go @@ -73,12 +73,6 @@ func NewStream(key, secret string) *Stream { } func (s *Stream) Subscribe(channel types.Channel, symbol string, options types.SubscribeOptions) { - // "book" - switch channel { - case types.KLineChannel: - panic("kline channel is not supported in max") - } - s.websocketService.Subscribe(string(channel), symbol) }