core

type BalanceInfo struct {
	Balance float64
}

type CandleInfo struct {
	Exchange string
	Symbol   string
	BinSize  string
	Data     interface{}
}

type CandleName struct {
	Name    string
	BinSize string
}

type CandleParam struct {
	Start    time.Time
	End      time.Time
	Exchange string
	BinSize  string
	Symbol   string
}

type EventData struct {
	Type string      `json:"type"`
	Data interface{} `json:"data"`
}

type Exchange interface {
	Start(map[string]interface{}) error
	Stop() error

	// Kline get klines
	GetKline(symbol, bSize string, start, end time.Time) (data chan *Candle, err chan error)

	Watch(WatchParam) error

	// for trade
	// ProcessOrder process order
	ProcessOrder(act TradeAction) (ret *Order, err error)
	CancelAllOrders() (orders []*Order, err error)

	// GetBalanceChan
	GetDataChan() chan *ExchangeData
}

type ExchangeData struct {
	Data EventData `json:"data"`
	Name string
}

type NewExchangeFn func(cfg *viper.Viper, cltName, symbol string) (t Exchange, err error)

type NotifyEvent struct {
	Type    string // text,markdown
	Content string
}

type RiskLimit struct {
	Code         string  // symbol info, empty = global
	Lever        float64 // lever
	MaxLostRatio float64 // max lose ratio
}

type RiskLimits map[string]RiskLimit

type SymbolInfo struct {
	ID          int64  `xorm:"pk autoincr null 'id'"`
	Exchange    string `xorm:"notnull unique(esr)  'exchange'"`
	Symbol      string `xorm:"notnull unique(esr) 'symbol'"`
	Resolutions string `xorm:"notnull unique(esr) 'resolutions'"`
	Pricescale  int    `xorm:"notnull 'pricescale'"`
}

type WatchParam = EventData