mirror of
https://github.com/c9s/bbgo.git
synced 2024-09-21 16:51:10 +00:00
43 lines
1.0 KiB
Go
43 lines
1.0 KiB
Go
package bbgo
|
|
|
|
import (
|
|
"context"
|
|
"github.com/c9s/bbgo/pkg/bbgo/exchange/binance"
|
|
"github.com/c9s/bbgo/pkg/bbgo/types"
|
|
"github.com/c9s/bbgo/pkg/slack"
|
|
log "github.com/sirupsen/logrus"
|
|
)
|
|
|
|
type Trader struct {
|
|
Notifier *slack.SlackNotifier
|
|
|
|
// Context is trading Context
|
|
Context *TradingContext
|
|
|
|
Exchange *binance.Exchange
|
|
}
|
|
|
|
func (t *Trader) Infof(format string, args ...interface{}) {
|
|
t.Notifier.Infof(format, args...)
|
|
}
|
|
|
|
func (t *Trader) ReportTrade(trade *types.Trade) {
|
|
t.Notifier.ReportTrade(trade)
|
|
}
|
|
|
|
func (t *Trader) ReportPnL() {
|
|
report := t.Context.ProfitAndLossCalculator.Calculate()
|
|
report.Print()
|
|
t.Notifier.ReportPnL(report)
|
|
}
|
|
|
|
func (t *Trader) SubmitOrder(ctx context.Context, order *types.Order) {
|
|
t.Infof(":memo: Submitting %s order on side %s with volume: %s", order.Type, order.Side, order.VolumeStr, order.SlackAttachment())
|
|
|
|
err := t.Exchange.SubmitOrder(ctx, order)
|
|
if err != nil {
|
|
log.WithError(err).Errorf("order create error: side %s volume: %s", order.Side, order.VolumeStr)
|
|
return
|
|
}
|
|
}
|