broker

type BrokerService interface {
	Start()
	Stop()
	GetClient(login string) (Client, error)
	GetProfile(login string) (Profile, error)
	Create(deal Deal) (Deal, error)
	Cancel(dealID int64) (bool, error)
	History(ticker string) ([]OHLCV, error)
}

type Client struct {
	ID      int64
	Login   string
	Balance float64
}

type ClientRepo interface {
	Add(client *Client) error
	Get(login string) (Client, bool, error)
	SumBalance(clientID int64, amount float64) error
	SubBalance(clientID int64, amount float64) error
}

type Deal struct {
	ID       int64
	ClientID int64
	Ticker   string
	Type     DealType
	Amount   int32
	Partial  bool
	Price    float64
	Status   DealStatus
	Time     time.Time
}

type DealRepo interface {
	Add(deal Deal) error
	GetOpened(clientID int64) ([]Deal, error)
	Update(deal Deal) error
	UpdateStatus(dealID int64, status DealStatus) error
}

type DealStatus string

type DealType string

type ExchangeService interface {
	Statistic(ctx context.Context, out chan OHLCV) error
	Create(deal Deal) (int64, error)
	Cancel(dealID int64) (bool, error)
	Results(ctx context.Context, out chan Deal) error
}

type OHLCV struct {
	ID       int64
	Ticker   string
	Time     time.Time
	Interval time.Duration
	Open     float64
	High     float64
	Low      float64
	Close    float64
	Volume   int32
}

type Position struct {
	ClientID int64
	Ticker   string
	Amount   int32
}

type PositionRepo interface {
	Add(position Position) error
	Get(clientID int64) ([]Position, error)
	Remove(position Position) error
}

type Profile struct {
	ClientID  int64
	Balance   float64
	Positions []Position
	OpenDeals []Deal
}

type StatisticRepo interface {
	Add(ohlcv OHLCV) error
	Get(ticker string) ([]OHLCV, error)
}