exchanges

type BaseState struct {
	Price float64 `json:"price"`
	// BaseVolume is poorly named. This is the volume in terms of (usually) BTC,
	// not the base asset of any particular market.
	BaseVolume float64 `json:"base_volume,omitempty"`
	Volume     float64 `json:"volume,omitempty"`
	Change     float64 `json:"change,omitempty"`
	Stamp      int64   `json:"timestamp,omitempty"`
}

type BinanceCandlestickResponse [][]interface{}

type BinanceDepthResponse struct {
	UpdateID int64
	Bids     [][2]string
	Asks     [][2]string
}

type BinanceExchange struct {
	*CommonExchange
}

type BinancePriceResponse struct {
	Symbol             string `json:"symbol"`
	PriceChange        string `json:"priceChange"`
	PriceChangePercent string `json:"priceChangePercent"`
	WeightedAvgPrice   string `json:"weightedAvgPrice"`
	PrevClosePrice     string `json:"prevClosePrice"`
	LastPrice          string `json:"lastPrice"`
	LastQty            string `json:"lastQty"`
	BidPrice           string `json:"bidPrice"`
	BidQty             string `json:"bidQty"`
	AskPrice           string `json:"askPrice"`
	AskQty             string `json:"askQty"`
	OpenPrice          string `json:"openPrice"`
	HighPrice          string `json:"highPrice"`
	LowPrice           string `json:"lowPrice"`
	Volume             string `json:"volume"`
	QuoteVolume        string `json:"quoteVolume"`
	OpenTime           int64  `json:"openTime"`
	CloseTime          int64  `json:"closeTime"`
	FirstID            int64  `json:"firstId"`
	LastID             int64  `json:"lastId"`
	Count              int64  `json:"count"`
}

type BittrexCandlestick struct {
	StartsAt    time.Time   `json:"startsAt"`
	Open        StringFloat `json:"open"`
	High        StringFloat `json:"high"`
	Low         StringFloat `json:"low"`
	Close       StringFloat `json:"close"`
	Volume      StringFloat `json:"volume"`
	QuoteVolume StringFloat `json:"quoteVolume"`
}

type BittrexDepthResponse struct {
	Seq uint64
	Bid []*BittrexRateQty `json:"bid"`
	Ask []*BittrexRateQty `json:"ask"`
}

type BittrexExchange struct {
	*CommonExchange
	MarketName string
	// contains filtered or unexported fields
}

type BittrexMarketSummary struct {
	Symbol        string      `json:"symbol"`
	High          StringFloat `json:"high"`
	Low           StringFloat `json:"low"`
	Volume        StringFloat `json:"volume"`
	QuoteVolume   StringFloat `json:"quoteVolume"`
	PercentChange StringFloat `json:"percentChange"`
	UpdatedAt     time.Time   `json:"updatedAt"`
}

type BittrexOrderbookDelta struct {
	Qty  StringFloat `json:"quantity"`
	Rate StringFloat `json:"rate"`
}

type BittrexOrderbookUpdate struct {
	MarketSymbol string                   `json:"marketSymbol"`
	Depth        int64                    `json:"depth"`
	Sequence     uint64                   `json:"sequence"`
	BidDeltas    []*BittrexOrderbookDelta `json:"bidDeltas"`
	AskDeltas    []*BittrexOrderbookDelta `json:"askDeltas"`
}

type BittrexPriceResponse struct {
	LastTradeRate StringFloat `json:"lastTradeRate"`
	BidRate       StringFloat `json:"bidRate"`
	AskRate       StringFloat `json:"askRate"`
}

type BittrexRateQty struct {
	Qty  StringFloat `json:"quantity"`
	Rate StringFloat `json:"rate"`
}

type BittrexWSMsg struct {
	Name    string
	Updates []*BittrexOrderbookUpdate
}

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

type Candlestick struct {
	High   float64   `json:"high"`
	Low    float64   `json:"low"`
	Open   float64   `json:"open"`
	Close  float64   `json:"close"`
	Volume float64   `json:"volume"`
	Start  time.Time `json:"start"`
}

type Candlesticks []Candlestick

type CoinbaseExchange struct {
	*CommonExchange
}

type CoinbaseResponse struct {
	Data CoinbaseResponseData `json:"data"`
}

type CoinbaseResponseData struct {
	Currency string            `json:"currency"`
	Rates    map[string]string `json:"rates"`
}

type CoindeskExchange struct {
	*CommonExchange
}

type CoindeskResponse struct {
	Time       CoindeskResponseTime           `json:"time"`
	Disclaimer string                         `json:"disclaimer"`
	ChartName  string                         `json:"chartName"`
	Bpi        map[string]CoindeskResponseBpi `json:"bpi"`
}

type CoindeskResponseBpi struct {
	Code        string  `json:"code"`
	Symbol      string  `json:"symbol"`
	Rate        string  `json:"rate"`
	Description string  `json:"description"`
	RateFloat   float64 `json:"rate_float"`
}

type CoindeskResponseTime struct {
	Updated    string    `json:"updated"`
	UpdatedIso time.Time `json:"updatedISO"`
	Updateduk  string    `json:"updateduk"`
}

type CommonExchange struct {
	URL string
	// contains filtered or unexported fields
}

type Conversion struct {
	Value float64 `json:"value"`
	Index string  `json:"index"`
}

type DEXConfig struct {
	Token    string
	Host     string
	Cert     []byte
	CertHost string
}

type DecredDEX struct {
	*CommonExchange
	// contains filtered or unexported fields
}

type DepthData struct {
	Time int64        `json:"time"`
	Bids []DepthPoint `json:"bids"`
	Asks []DepthPoint `json:"asks"`
}

type DepthPoint struct {
	Quantity float64 `json:"quantity"`
	Price    float64 `json:"price"`
}

type Doer interface {
	Do(*http.Request) (*http.Response, error)
}

type DragonExCandlestickColumns []string

type DragonExCandlestickData struct {
	Columns DragonExCandlestickColumns `json:"columns"`
	Lists   DragonExCandlestickPts     `json:"lists"`
}

type DragonExCandlestickList []interface{}

type DragonExCandlestickPts []DragonExCandlestickList

type DragonExCandlestickResponse struct {
	DragonExResponse
	Data DragonExCandlestickData
}

type DragonExDepthArray []DragonExDepthPt

type DragonExDepthPt struct {
	Price  string `json:"price"`
	Volume string `json:"volume"`
}

type DragonExDepthResponse struct {
	DragonExResponse
	Data DragonExDepthArray `json:"data"`
}

type DragonExPriceResponse struct {
	DragonExResponse
	Data []DragonExPriceResponseData `json:"data"`
}

type DragonExPriceResponseData struct {
	ClosePrice      string `json:"close_price"`
	CurrentVolume   string `json:"current_volume"`
	MaxPrice        string `json:"max_price"`
	MinPrice        string `json:"min_price"`
	OpenPrice       string `json:"open_price"`
	PriceBase       string `json:"price_base"`
	PriceChange     string `json:"price_change"`
	PriceChangeRate string `json:"price_change_rate"`
	Timestamp       int64  `json:"timestamp"`
	TotalAmount     string `json:"total_amount"`
	TotalVolume     string `json:"total_volume"`
	UsdtVolume      string `json:"usdt_amount"`
	SymbolID        int    `json:"symbol_id"`
}

type DragonExResponse struct {
	Ok   bool   `json:"ok"`
	Code int    `json:"code"`
	Msg  string `json:"msg"`
}

type DragonExchange struct {
	*CommonExchange
	SymbolID int
	// contains filtered or unexported fields
}

type Exchange interface {
	LastUpdate() time.Time
	LastFail() time.Time
	LastTry() time.Time
	Refresh()
	IsFailed() bool
	Token() string
	Hurry(time.Duration)
	Update(*ExchangeState)
	SilentUpdate(*ExchangeState) // skip passing update to the update channel
	UpdateIndices(FiatIndices)
}

type ExchangeBot struct {
	DcrBtcExchanges map[string]Exchange
	IndexExchanges  map[string]Exchange
	Exchanges       map[string]Exchange

	// BtcIndex is the (typically fiat) currency to which the DCR price should be
	// converted by default. Other conversions are available via a lookup in
	// indexMap, but with slightly lower performance.
	// 3-letter currency code, e.g. USD.
	BtcIndex string

	DataExpiry    time.Duration
	RequestExpiry time.Duration

	TLSCredentials credentials.TransportCredentials
	// contains filtered or unexported fields
}

type ExchangeBotConfig struct {
	Disabled       []string
	DataExpiry     string
	RequestExpiry  string
	BtcIndex       string
	Indent         bool
	MasterBot      string
	MasterCertFile string
}

type ExchangeBotState struct {
	BtcIndex string                    `json:"btc_index"`
	BtcPrice float64                   `json:"btc_fiat_price"`
	Price    float64                   `json:"price"`
	Volume   float64                   `json:"volume"`
	DcrBtc   map[string]*ExchangeState `json:"dcr_btc_exchanges"`
	// FiatIndices:
	// TODO: We only really need the BaseState for the fiat indices.
	FiatIndices map[string]*ExchangeState `json:"btc_indices"`
}

type ExchangeRates struct {
	BtcIndex  string               `json:"btcIndex"`
	DcrPrice  float64              `json:"dcrPrice"`
	BtcPrice  float64              `json:"btcPrice"`
	Exchanges map[string]BaseState `json:"exchanges"`
}

type ExchangeState struct {
	BaseState
	Depth        *DepthData                      `json:"depth,omitempty"`
	Candlesticks map[candlestickKey]Candlesticks `json:"candlesticks,omitempty"`
}

type ExchangeUpdate struct {
	Token string
	State *ExchangeState
}

type FiatIndices map[string]float64

type HuobiCandlestickData []*HuobiCandlestickPt

type HuobiCandlestickPt struct {
	ID     int64   `json:"id"` // ID is actually start time as unix stamp
	Open   float64 `json:"open"`
	Close  float64 `json:"close"`
	Low    float64 `json:"low"`
	High   float64 `json:"high"`
	Amount float64 `json:"amount"` // Volume BTC
	Vol    float64 `json:"vol"`    // Volume DCR
	Count  int64   `json:"count"`
}

type HuobiCandlestickResponse struct {
	HuobiResponse
	Data HuobiCandlestickData `json:"data"`
}

type HuobiDepthPts [][2]float64

type HuobiDepthResponse struct {
	HuobiResponse
	Tick HuobiDepthTick `json:"tick"`
}

type HuobiDepthTick struct {
	ID   int64         `json:"id"`
	Ts   int64         `json:"ts"`
	Bids HuobiDepthPts `json:"bids"`
	Asks HuobiDepthPts `json:"asks"`
}

type HuobiExchange struct {
	*CommonExchange
	Ok string
}

type HuobiPriceResponse struct {
	HuobiResponse
	Tick HuobiPriceTick `json:"tick"`
}

type HuobiPriceTick struct {
	Amount  float64   `json:"amount"`
	Open    float64   `json:"open"`
	Close   float64   `json:"close"`
	High    float64   `json:"high"`
	ID      int64     `json:"id"`
	Count   int64     `json:"count"`
	Low     float64   `json:"low"`
	Version int64     `json:"version"`
	Ask     []float64 `json:"ask"`
	Vol     float64   `json:"vol"`
	Bid     []float64 `json:"bid"`
}

type HuobiResponse struct {
	Status string `json:"status"`
	Ch     string `json:"ch"`
	Ts     int64  `json:"ts"`
}

type IndexUpdate struct {
	Token   string
	Indices FiatIndices
}

type PoloniexCandlestickPt struct {
	Date            int64   `json:"date"`
	High            float64 `json:"high"`
	Low             float64 `json:"low"`
	Open            float64 `json:"open"`
	Close           float64 `json:"close"`
	Volume          float64 `json:"volume"`
	QuoteVolume     float64 `json:"quoteVolume"`
	WeightedAverage float64 `json:"weightedAverage"`
}

type PoloniexCandlestickResponse []*PoloniexCandlestickPt

type PoloniexDepthArray []*PoloniexDepthPt

type PoloniexDepthPt [2]interface{}

type PoloniexDepthResponse struct {
	Asks     PoloniexDepthArray `json:"asks"`
	Bids     PoloniexDepthArray `json:"bids"`
	IsFrozen string             `json:"isFrozen"`
	Seq      int64              `json:"seq"`
}

type PoloniexExchange struct {
	*CommonExchange
	CurrencyPair string
	// contains filtered or unexported fields
}

type PoloniexPair struct {
	ID            int    `json:"id"`
	Last          string `json:"last"`
	LowestAsk     string `json:"lowestAsk"`
	HighestBid    string `json:"highestBid"`
	PercentChange string `json:"percentChange"`
	BaseVolume    string `json:"baseVolume"`
	QuoteVolume   string `json:"quoteVolume"`
	IsFrozen      string `json:"isFrozen"`
	High24hr      string `json:"high24hr"`
	Low24hr       string `json:"low24hr"`
}

type StringFloat float64

type URLs struct {
	Price        string
	Stats        string
	Depth        string
	Candlesticks map[candlestickKey]string
	Websocket    string
}

type UpdateChannels struct {
	Exchange chan *ExchangeUpdate
	Index    chan *IndexUpdate
	Quit     chan struct{}
}

type WebsocketProcessor func([]byte)