models

type Asset struct {
	ID       string      `json:"id"`
	Name     string      `json:"name"`
	SourceID interface{} `json:"sourceID"`
	Group    Groups      `json:"group"`
	IsOTC    bool        `json:"isOTC"`
}

type Database struct {
	IDatabase
}

type GetHistoryOptions struct {
	ID      string `json:"id"`
	Start   string `json:"start"`
	End     string `json:"end"`
	Candle  []int  `json:"candle"`
	Latest  bool   `json:"latest"`
	Minsize int    `json:"minsize"`
}

type GetSrc struct {
	ID            string          `json:"id"`
	ActiveAsset   map[string]bool `json:"activeAsset"`
	ActiveCandles []int           `json:"activeCandles"`
}

type Groups int

type IDatabase interface {
	Init() (err error)
	Reload() (err error)
	Set(bucket string, key string, data []byte) (err error)
	Get(bucket string, key string) (data []byte, err error)
	Del(bucket, key string) (err error)
}

type ISources interface {
	GetID() string
	GetName() string
	Start() error
	SetConfig(key, value string) error
	GetConfig() []SourceConfig
	ListPairs(func([]Asset, error)) error
	GetHistory(opt GetHistoryOptions, cb func(*PointStore, error)) error
	GetActiveAsset() map[string]bool
	GetActiveCandles() []int
	GetLatestCandles(asset string, candle int) ([]Points, SourceStatus)
	OnSourceLiveUpdate(id string, callback func(asset string, candle int, data Points))
	OnTicksUpdate(id string, callback func(asset string, serverTime int64, data map[int][]Points))
}

type PointStore struct {
	Candle sync.Map
}

type Points struct {
	Close float64 `json:"close"`
	Open  float64 `json:"open"`
	High  float64 `json:"high"`
	Low   float64 `json:"low"`
	Ask   float64 `json:"ask"`
	Bid   float64 `json:"bid"`
	To    int64   `json:"to"`
	From  int64   `json:"from"`
	At    int64   `json:"at"`
	Size  int     `json:"size"`
}

type Response struct {
	Code         int         `json:"code" xml:"code"`
	Status       string      `json:"status" xml:"status"`
	Error        interface{} `json:"error" xml:"error"`
	RequestID    string      `json:"requestId" xml:"requestId"`
	ExcutionTime string      `json:"excutionTime" xml:"excutionTime"`
	Data         interface{} `json:"data" xml:"data"`
}

type SendMessage struct {
	Channel string      `json:"channel"`
	Time    int64       `json:"time"`
	Msg     interface{} `json:"msg"`
}

type SourceConfig struct {
	Key     string
	Value   string
	Example string
}

type SourceStatus int

type Sources struct {
	ISources
}

type StackError struct {
	Function   string `json:"function" xml:"function"`
	File       string `json:"file" xml:"file"`
	LineNumber int    `json:"lineNumber" xml:"lineNumber"`
}

type SubMsg struct {
	SubChannel string      `json:"subChannel"`
	Data       interface{} `json:"data"`
}

type SubsLiveCandle struct {
	Candle int    `json:"candle"`
	Asset  string `json:"asset"`
	Data   Points `json:"data"`
}

type SyncMap struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type WebserverOptions struct {
	Database *Database
	Logger   *logging.Logger
	Host     string
	Files    string
	Port     int
	Dev      bool
}