publisher

type Channel string

type Client struct {
	Id         int64
	Conn       *websocket.Conn
	WriteCh    chan interface{}
	L2ChangeCh chan *Level2Change
	Sub        *Subscription
	Channels   map[string]struct{}
	Mu         sync.Mutex
}

type FundsMessage struct {
	Type      string `json:"type"`
	Sequence  int64  `json:"sequence"`
	UserId    string `json:"userId"`
	Currency  string `json:"currencyCode"`
	Available string `json:"available"`
	Hold      string `json:"hold"`
}

type Level2Change struct {
	Seq       int64
	ProductId string
	Side      string
	Price     string
	Size      string
}

type Level2SnapshotMessage struct {
	Type      Level2Type       `json:"type"`
	ProductId string           `json:"productId"`
	Bids      [][3]interface{} `json:"bids"`
	Asks      [][3]interface{} `json:"asks"`
}

type Level2Type string

type Level2UpdateMessage struct {
	Type      Level2Type       `json:"type"`
	ProductId string           `json:"procduct_id"`
	Changes   [][3]interface{} `json:"changes"` // ["buy", "6500.09", "0.847023376"]
}

type LogOffset struct {
	Log    interface{}
	Offset int64
}

type MatchMessage struct {
	Type         string `json:"type"`
	TradeId      int64  `json:"tradeId"`
	Sequence     int64  `json:"sequence"`
	Time         string `json:"time"`
	ProductId    string `json:"productId"`
	Price        string `json:"price"`
	Size         string `json:"size"`
	MakerOrderId string `json:"makerOrderId"`
	TakerOrderId string `json:"takerOrderId"`
	Side         string `json:"side"`
}

type MatchStream struct {
	ProductId string
	Sub       *Subscription
	BestBid   decimal.Decimal
	BestAsk   decimal.Decimal
	Tick24h   *entities.Tick
	Tick30d   *entities.Tick
	LogReader matching.LogReader
}

type OrderBook struct {
	ProductId string
	Seq       int64
	LogOffset int64
	LogSeq    int64
	Depths    map[entities.Side]*treemap.Map
	Orders    map[int64]*matching.BookOrder
}

type OrderBookFullSnapshot struct {
	ProductId string
	Seq       int64
	LogOffset int64
	LogSeq    int64
	Orders    []matching.BookOrder
}

type OrderBookLevel2Snapshot struct {
	ProductId string
	Seq       int64
	Asks      [][3]interface{}
	Bids      [][3]interface{}
}

type OrderBookStream struct {
	ProductId  string
	LogReader  matching.LogReader
	LogCh      chan *LogOffset
	OrderBook  *OrderBook
	Sub        *Subscription
	SnapshotCh chan interface{}
}

type OrderMessage struct {
	UserId        int64  `json:"userId"`
	Type          string `json:"type"`
	Sequence      int64  `json:"sequence"`
	Id            string `json:"id"`
	Price         string `json:"price"`
	Size          string `json:"size"`
	Funds         string `json:"funds"`
	ProductId     string `json:"productId"`
	Side          string `json:"side"`
	OrderType     string `json:"orderType"`
	CreatedAt     string `json:"createdAt"`
	FillFees      string `json:"fillFees"`
	FilledSize    string `json:"filledSize"`
	ExecutedValue string `json:"executedValue"`
	Status        string `json:"status"`
	Settled       bool   `json:"settled"`
}

type PriceLevel struct {
	Price      decimal.Decimal
	Size       decimal.Decimal
	OrderCount int64
}

type RedisSnapshotStore struct {
	RedisClient *redis.Client
}

type RedisStream struct {
	Sub   *Subscription
	Mutex sync.Mutex
}

type Request struct {
	Type        string   `json:"type"`
	ProductIds  []string `json:"product_ids"`
	CurrencyIds []string `json:"currency_ids"`
	Channels    []string `json"channels"`
	Token       string   `json:"token"`
}

type Response struct {
	Type       string   `json:"type"`
	ProductIds []string `json:"product_ids"`
	Channels   []string `json:"channels"`
	Token      string   `json:"token"`
}

type Server struct {
	Addr string
	Path string
	Sub  *Subscription
}

type Subscription struct {
	Subscribers map[string]map[int64]*Client
	Mu          sync.RWMutex
}

type TickerMessage struct {
	Type      string `json:"type"`
	TradeId   int64  `json:"tradeId"`
	Sequence  int64  `json:"sequence"`
	Time      string `json:"time"`
	ProductId string `json:"productId"`
	Price     string `json:"price"`
	Side      string `json:"side"`
	LastSize  string `json:"lastSize"`
	BestBid   string `json:"bestBid"`
	BestAsk   string `json:"bestAsk"`
	Volume24h string `json:"volume24h"`
	Volume30d string `json:"volume30d"`
	Low24h    string `json:"low24h"`
	Open24h   string `json:"open24h"`
}

type TickerStream struct {
	ProductId      string
	Sub            *Subscription
	BestBid        decimal.Decimal
	BestAsk        decimal.Decimal
	LogReader      matching.LogReader
	LastTickerTime int64
}