ws_types_subscriptable.go

package hyperliquid

import "github.com/sonirico/vago/fp"

type subscriptable interface {
	Key() string
}

type (
	Trades   []Trade
	WsOrders []WsOrder
)

func (t Trades) Key() string {
	if len(t) == 0 {
		return ""
	}
	return keyTrades(t[0].Coin)
}

func (a ActiveAssetCtx) Key() string {
	return keyActiveAssetCtx(a.Coin)
}

func (c Candle) Key() string {
	return keyCandles(c.Symbol, c.Interval)
}

func (c L2Book) Key() string {
	return keyL2Book(c.Coin)
}

func (a AllMids) Key() string {
	return keyAllMids(fp.None[string]())
}

func (n Notification) Key() string {
	// Notification messages are user-specific but don't contain user info in the message itself.
	// The dispatching is handled by the subscription system based on the subscription key.
	return ChannelNotification
}

func (w WsOrders) Key() string {
	// WsOrder messages are user-specific but don't contain user info in the message itself.
	// The dispatching is handled by the subscription system based on the subscription key.
	return ChannelOrderUpdates
}

func (w WebData2) Key() string {
	// WebData2 messages are user-specific but don't contain user info in the message itself.
	// The dispatching is handled by the subscription system based on the subscription key.
	return ChannelWebData2
}

func (w Bbo) Key() string { return keyBbo(w.Coin) }

func (w WsOrderFills) Key() string {
	return keyUserFills(w.User)
}

func (c ClearinghouseState) Key() string {
	// ClearinghouseState messages are user-specific but don't contain user/dex info in the message itself.
	// The dispatching is handled by the subscription system based on the subscription key.
	return ChannelClearinghouseState
}

func (c ClearinghouseStateMessage) Key() string {
	if c.Dex == "" {
		return key(ChannelClearinghouseState, c.User)
	}
	return key(ChannelClearinghouseState, c.User, c.Dex)
}

func (o OpenOrders) Key() string {
	// OpenOrders messages contain user and dex info, but we use the subscription key for dispatching
	// The subscription key already includes dex, so we just return a generic key
	return ChannelOpenOrders
}

func (t TwapStates) Key() string {
	// TwapStates messages contain user and dex info, but we use the subscription key for dispatching
	// The subscription key already includes dex, so we just return a generic key
	return ChannelTwapStates
}

func (w WebData3) Key() string {
	// WebData3 messages are user-specific but don't contain user/dex info in the message itself.
	// The dispatching is handled by the subscription system based on the subscription key.
	return ChannelWebData3
}