ws

type Channel interface {
	// get channel name
	GetChannel() (string, error)
}

type ChannelRawMessage struct {
	json.RawMessage
}

type ChannelType string

type Client struct {
	// contains filtered or unexported fields
}

type MessageHandler interface {
	// HandleUnknownMessage
	HandleUnknownMessage(ctx context.Context, msg []byte)
	// HandlePushData
	HandlePushData(context.Context, PushData[ChannelRawMessage, json.RawMessage])
	// HandleResponse
	HandleResponse(context.Context, Response[ChannelRawMessage])
}

type NoopMessageHandler struct{}

type OptFn func(*options)

type PushData[Arg Channel, Data any] struct {
	// Successfully subscribed channel
	Arg Arg `json:"arg,omitempty"`
	// Subscribed data
	Data []Data `json:"data,omitempty"`
	// contains filtered or unexported fields
}

type Request[T any] struct {
	// Unique identifier of the messageProvided by client.
	// It will be returned in response message for identifying the corresponding request.
	// A combination of case-sensitive alphanumerics, all numbers, or all letters of up to 32 characters.
	Id string `json:"id,omitempty"`
	// Operation
	Op string `json:"op,omitempty"`
	// Request Parameters
	Args []T `json:"args,omitempty"`
}

type Response[T Channel] struct {
	// Operation
	// login
	// subscribe
	// unsubscribe
	// error
	Event string `json:"event"`

	Arg T `json:"arg"`
	// Error code
	Code string `json:"code"`
	// Error message
	Msg string `json:"msg"`
	// WebSocket connection ID
	ConnId string `json:"connId"`
	// contains filtered or unexported fields
}

type TickersChannel struct {
	// Channel name
	Channel string `json:"channel,omitempty"`
	// Instrument ID
	InstId string `json:"instId"`
}

type TickersData struct {
	// Instrument type
	InstType string `json:"instType"`
	// Instrument ID
	InstID string `json:"instId"`
	// Last traded price
	Last string `json:"last"`
	// Last traded size
	LastSz string `json:"lastSz"`
	// Best ask price
	AskPx string `json:"askPx"`
	// Best ask size
	AskSz string `json:"askSz"`
	// Best bid price
	BidPx string `json:"bidPx"`
	// Best bid size
	BidSz string `json:"bidSz"`
	// Open price in the past 24 hours
	Open24H string `json:"open24h"`
	// Highest price in the past 24 hours
	High24H string `json:"high24h"`
	// Lowest price in the past 24 hours
	Low24H string `json:"low24h"`
	// Open price in the UTC 0
	SodUtc0 string `json:"sodUtc0"`
	// Open price in the UTC 8
	SodUtc8 string `json:"sodUtc8"`
	// 24h trading volume, with a unit of currency.
	// If it is a derivatives contract, the value is the number of base currency.
	// If it is SPOT/MARGIN, the value is the quantity in quote currency.
	VolCcy24H string `json:"volCcy24h"`
	// 24h trading volume, with a unit of contract.
	// If it is a derivatives contract, the value is the number of contracts.
	// If it is SPOT/MARGIN, the value is the quantity in base currency.
	Vol24H string `json:"vol24h"`
	// Ticker data generation time, Unix timestamp format in milliseconds, e.g. 1597026383085
	Ts string `json:"ts"`
}