exapi

type APIConfig struct {
	HttpClient    *http.Client
	Endpoint      string
	ApiKey        string
	ApiSecretKey  string
	ApiPassphrase string //for okex.com v3 api
	ClientId      string //for bitstamp.net , huobi.pro

	Lever int //杠杆倍数 , for future
}

type Account struct {
	Exchange    string                  `json:"exchange,string"` // 交易所名字
	Asset       float64                 `json:"asset,string"`    //总资产
	NetAsset    float64                 `json:"netasset,string"` //净资产
	SubAccounts map[Currency]SubAccount `json:"sub_accounts"`    // 每个币种账本
}

type Connection struct {
	// 互斥锁
	sync.Mutex

	// 消息处理函数，当有数据时调用，当断开连接时，data传nil
	OnMessage func([]byte) error
	// contains filtered or unexported fields
}

type Currency struct {
	Name string `json:"name"`
}

type CurrencyPair struct {
	Stock Currency `json:"stock"`
	Money Currency `json:"money"`
}

type CurrencyStatus struct {
	Deposit  bool // 是否可以充值
	Withdraw bool // 是否可以提币
}

type Depth struct {
	ContractType string       `json:"contract_type"` // for future
	Market       CurrencyPair `json:"market"`        // 交易对
	Symbol       string       `json:"symbol"`        // 交易对
	TS           int64        `json:"ts"`            // 时间，单位为毫秒(millisecond)
	AskList      DepthRecords `json:"asks"`          // 卖方订单列表，价格从低到高排序
	BidList      DepthRecords `json:"bids"`          // 买方订单列表，价格从高到底排序
}

type DepthRecord struct {
	Price  float64 `json:"price,string"`  // 报价
	Amount float64 `json:"amount,string"` // 数量
}

type DepthRecords []DepthRecord

type FutureAccount struct {
	FutureSubAccounts map[Currency]FutureSubAccount
}

type FutureKline struct {
	*Kline
	Vol2 float64 //个数
}

type FutureOrder struct {
	OrderID2     string //请尽量用这个字段替代OrderID字段
	Price        float64
	Amount       float64
	AvgPrice     float64
	DealAmount   float64
	OrderID      int64
	OrderTime    int64
	Status       TradeStatus
	Currency     CurrencyPair
	OType        int     //1：开多 2：开空 3：平多 4： 平空
	LeverRate    int     //倍数
	Fee          float64 //手续费
	ContractName string
}

type FuturePosition struct {
	BuyAmount      float64
	BuyAvailable   float64
	BuyPriceAvg    float64
	BuyPriceCost   float64
	BuyProfitReal  float64
	CreateDate     int64
	LeverRate      int
	SellAmount     float64
	SellAvailable  float64
	SellPriceAvg   float64
	SellPriceCost  float64
	SellProfitReal float64
	Symbol         CurrencyPair //btc_usd:比特币,ltc_usd:莱特币
	ContractType   string
	ContractId     int64
	ForceLiquPrice float64 //预估爆仓价
}

type FutureSubAccount struct {
	Currency      Currency
	AccountRights float64 //账户权益
	KeepDeposit   float64 //保证金
	ProfitReal    float64 //已实现盈亏
	ProfitUnreal  float64
	RiskRate      float64 //保证金率
}

type FutureTicker struct {
	*Ticker
	ContractType string  `json:"omitempty"`
	ContractId   int     `json:"contractId"`
	LimitHigh    float64 `json:"limitHigh,string"`
	LimitLow     float64 `json:"limitLow,string"`
	HoldAmount   float64 `json:"hold_amount,string"`
	UnitAmount   float64 `json:"unitAmount,string"`
}

type Kline struct {
	Market CurrencyPair `json:"market"`       // 交易对
	Symbol string       `json:"symbol"`       // 交易对
	TS     int64        `json:"ts"`           // 开盘时间，单位为秒(second)
	Open   float64      `json:"open,string"`  // 开盘价
	Close  float64      `json:"close,string"` // 收盘价
	High   float64      `json:"high,string"`  // 最高价
	Low    float64      `json:"low,string"`   // 最低价
	Vol    float64      `json:"vol,string"`   // 报价币种成交量
}

type KlinePeriod int

type Logger interface {
	Write(string)
}

type Order struct {
	OrderID    string       `json:"order_id"`           // 订单id
	Price      float64      `json:"price,string"`       // 委托价格
	Amount     float64      `json:"amount,string"`      // 委托量
	AvgPrice   float64      `json:"avg_price,string"`   // 平均成交价
	DealAmount float64      `json:"deal_amount,string"` // 成交量
	Fee        float64      `json:"fee,string"`         // 手续费
	TS         int64        `json:"ts"`                 // 时间，单位为毫秒(millisecond)
	Status     TradeStatus  `json:"status"`             // 订单状态
	Market     CurrencyPair `json:"market"`             // 交易对
	Symbol     string       `json:"symbol"`             // 交易对
	Side       TradeSide    `json:"side"`               // 交易方向
}

type OrderDeal struct {
	OrderID          string       `json:"order_id"`                  // 订单id
	DealID           string       `json:"deal_id"`                   // 本次成交id
	TS               int64        `json:"ts"`                        // 时间，单位为毫秒(millisecond)
	Price            float64      `json:"price,string"`              // 委托价格
	FilledAmount     float64      `json:"filled_amount,string"`      // 本次成交量
	FilledCashAmount float64      `json:"filled_cash_amount,string"` // 本次成交金额
	UnFilledAmount   float64      `json:"unfilled_amount,string"`    // 未成交的量
	Side             TradeSide    `json:"side"`                      // 交易方向
	Market           CurrencyPair `json:"market"`                    // 交易对
	Symbol           string       `json:"symbol"`                    // 交易对
}

type SpotAPI interface {
	// 获取交易所名称
	GetExchangeName() string
	// 设置交易所地址，仅在初始化时设置，不支持后续动态更改
	SetURL(exurl string)
	// 获取交易所地址
	GetURL() string

	// 获取支持的交易对
	GetAllCurrencyPair() (map[string]SymbolSetting, error)
	// 获取此币种是否可以充提币
	GetCurrencyStatus(currency Currency) (CurrencyStatus, error)
	// 获取所有币种是否可以充提币
	GetAllCurrencyStatus() (map[string]CurrencyStatus, error)

	// 公共行情
	// 获取单一币种对的行情
	GetTicker(pair CurrencyPair) (*Ticker, error)
	// 获取所有币种对的行情
	GetAllTicker() ([]Ticker, error)
	//获取单一币种对的深度
	GetDepth(pair CurrencyPair, size int, step int) (*Depth, error)
	// 获取单一币种对的成交记录
	GetTrades(pair CurrencyPair, size int) ([]Trade, error)
	// 获取单一币种对的K线记录，按时间升序排列
	GetKlineRecords(pair CurrencyPair, period KlinePeriod, size, since int) ([]Kline, error)

	// 交易相关
	// 限价单
	LimitBuy(pair CurrencyPair, price, amount string) (*Order, error)
	LimitSell(pair CurrencyPair, price, amount string) (*Order, error)
	// 市价单，下单后返回的数据不准，需要调用GetOrder获取准确信息
	// 买入金额，单位为计价货币
	MarketBuy(pair CurrencyPair, amount string) (*Order, error)
	// 卖出数量，单位为基础货币
	MarketSell(pair CurrencyPair, amount string) (*Order, error)
	// 撤单
	Cancel(orderId string, pair CurrencyPair) (bool, error)
	// 获取订单详情
	GetOrder(orderId string, pair CurrencyPair) (*Order, error)
	// 获取当前未完成订单列表
	GetPendingOrders(pair CurrencyPair) ([]Order, error)
	// 获取最近完成订单
	GetFinishedOrders(pair CurrencyPair) ([]Order, error)
	// 获取订单的成交明细
	GetOrderDeal(orderId string, pair CurrencyPair) ([]OrderDeal, error)
	// 获取单一币种对的最近成交明细
	GetUserTrades(pair CurrencyPair) ([]Trade, error)
	// 获取账户余额
	GetAccount() (*Account, error)
}

type SpotWebsocket interface {
	// 设置交易所地址，仅在初始化时设置，不支持后续动态更改
	SetURL(exURL string)
	// 获取交易所地址
	GetURL() string
	// 设置代理地址
	SetProxyURL(proxyURL string)
	// 获取代理地址
	GetProxyURL() string

	// 订阅或取消行情，cb传nil为取消，目前cb只有最后一次设置的生效
	SubTicker(pair CurrencyPair, cb func(*Ticker) error) (err error)
	SubDepth(pair CurrencyPair, cb func(*Depth) error) (err error)
	SubTrade(pair CurrencyPair, cb func([]Trade) error) (err error)
	//SubKline(pair CurrencyPair, period KlinePeriod, cb func([]Kline) error) (err error)
	// 全部重新订阅
	Resubscribe() (err error)
	// 全部取消订阅
	Unsubscribe() (err error)
	// 设置初始化函数，当连接建立时调用
	SetConnectHandler(h func(*Connection) error)
	// 设置心跳函数
	SetHeartBeatHandler(h func(*Connection) error)
	// 关闭连接
	Close()

	// 以下为需要单独定制的接口
	// 获取交易所名称
	GetExchangeName() string
	// 格式化主题名称
	FormatTopicName(topic string, pair CurrencyPair) string
	// 格式化主题订阅消息
	FormatTopicSubData(topic string, pair CurrencyPair) []byte
	// 格式化主题取消订阅消息
	FormatTopicUnsubData(topic string, pair CurrencyPair) []byte
	// 消息解析函数
	OnMessage([]byte) error
}

type SpotWsBase struct {
	SpotWebsocket
	// 交易所地址
	WsURL string
	// 代理地址
	ProxyURL string
	// 心跳时长
	HeartbeatIntervalTime time.Duration

	// 底层websocket连接
	Conn *Connection
	// 消息主题的map
	TopicMap TopicMap

	// 连接建立处理函数
	OnConnect func(*Connection) error

	// 心跳处理函数
	OnHeartBeat func(*Connection) error

	// callbacks
	OnTicker func(*Ticker) error
	OnDepth  func(*Depth) error
	OnTrade  func([]Trade) error
	// contains filtered or unexported fields
}

type StreamType string

type SubAccount struct {
	Currency     Currency // 币种
	Amount       float64  `json:"amount,string"`        // 可用余额
	FrozenAmount float64  `json:"frozen_amount,string"` // 冻结余额
	LoanAmount   float64  `json:"loan_amount,string"`   // 借贷余额
}

type SymbolSetting struct {
	Symbol      string  `json:"symbol"`       // 币对名称
	Base        string  `json:"base"`         // 基础币种
	Quote       string  `json:"quote"`        // 报价币种
	MinSize     float64 `json:"min_size"`     // 最小交易量
	MinPrice    float64 `json:"min_price"`    // 最小价格
	MinNotional float64 `json:"min_notional"` // 最小成交量，价格和数量相乘必须要大于此值
	MakerFee    float64 `json:"maker_fee"`    // 挂单手续费
	TakerFee    float64 `json:"taker_fee"`    // 吃单手续费
}

type Ticker struct {
	//Symbol string       `json:"symbol"`      // 交易对
	Market CurrencyPair `json:"market"`      // 交易对
	Symbol string       `json:"symbol"`      // 交易对
	Open   float64      `json:"open,string"` // 开盘价
	Last   float64      `json:"last,string"` // 收盘价
	High   float64      `json:"high,string"` // 最高价
	Low    float64      `json:"low,string"`  // 最低价
	Vol    float64      `json:"vol,string"`  // 基础币种成交量
	Buy    float64      `json:"buy,string"`  // 最优买价
	Sell   float64      `json:"sell,string"` // 最优卖家
	TS     int64        `json:"ts"`          // 最新时间，单位为毫秒(millisecond)
}

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

type Trade struct {
	Tid    int64        `json:"tid"`           // 交易id
	Side   TradeSide    `json:"type"`          // 交易方向
	Amount float64      `json:"amount,string"` // 成交量
	Price  float64      `json:"price,string"`  // 成交价
	TS     int64        `json:"ts"`            // 时间，单位为毫秒(millisecond)
	Market CurrencyPair `json:"market"`        // 交易对
	Symbol string       `json:"symbol"`        // 交易对
}

type TradeSide int

type TradeStatus int