bbgo_origin/pkg/strategy/xmaker/strategy.go

960 lines
27 KiB
Go
Raw Normal View History

package xmaker
import (
"context"
"fmt"
"math"
2021-05-09 12:03:06 +00:00
"math/rand"
"sync"
"time"
"github.com/c9s/bbgo/pkg/bbgo"
2021-03-22 09:27:07 +00:00
"github.com/c9s/bbgo/pkg/exchange/max"
"github.com/c9s/bbgo/pkg/fixedpoint"
2021-05-30 06:46:48 +00:00
"github.com/c9s/bbgo/pkg/indicator"
"github.com/c9s/bbgo/pkg/service"
"github.com/c9s/bbgo/pkg/types"
2021-05-30 06:46:48 +00:00
"github.com/pkg/errors"
"github.com/sirupsen/logrus"
)
2021-05-17 13:33:55 +00:00
var defaultMargin = fixedpoint.NewFromFloat(0.003)
2021-05-10 15:27:08 +00:00
var localTimeZone *time.Location
const ID = "xmaker"
const stateKey = "state-v1"
var log = logrus.WithField("strategy", ID)
func init() {
bbgo.RegisterStrategy(ID, &Strategy{})
2021-05-10 15:27:08 +00:00
var err error
localTimeZone, err = time.LoadLocation("Local")
if err != nil {
panic(err)
}
}
type State struct {
2021-06-26 12:13:30 +00:00
HedgePosition fixedpoint.Value `json:"hedgePosition"`
CoveredPosition fixedpoint.Value `json:"coveredPosition,omitempty"`
Position *bbgo.Position `json:"position,omitempty"`
ProfitStats ProfitStats `json:"profitStats,omitempty"`
2021-06-26 12:11:20 +00:00
}
type ProfitStats struct {
2021-10-08 06:57:44 +00:00
bbgo.ProfitStats
2021-06-26 12:11:20 +00:00
MakerExchange types.ExchangeName `json:"makerExchange"`
AccumulatedMakerVolume fixedpoint.Value `json:"accumulatedMakerVolume,omitempty"`
AccumulatedMakerBidVolume fixedpoint.Value `json:"accumulatedMakerBidVolume,omitempty"`
AccumulatedMakerAskVolume fixedpoint.Value `json:"accumulatedMakerAskVolume,omitempty"`
TodayMakerVolume fixedpoint.Value `json:"todayMakerVolume,omitempty"`
TodayMakerBidVolume fixedpoint.Value `json:"todayMakerBidVolume,omitempty"`
TodayMakerAskVolume fixedpoint.Value `json:"todayMakerAskVolume,omitempty"`
}
func (s *ProfitStats) AddTrade(trade types.Trade) {
2021-10-08 06:57:44 +00:00
s.ProfitStats.AddTrade(trade)
2021-06-26 12:11:20 +00:00
if trade.Exchange == s.MakerExchange {
s.AccumulatedMakerVolume.AtomicAdd(fixedpoint.NewFromFloat(trade.Quantity))
s.TodayMakerVolume.AtomicAdd(fixedpoint.NewFromFloat(trade.Quantity))
switch trade.Side {
case types.SideTypeSell:
s.AccumulatedMakerAskVolume.AtomicAdd(fixedpoint.NewFromFloat(trade.Quantity))
s.TodayMakerAskVolume.AtomicAdd(fixedpoint.NewFromFloat(trade.Quantity))
case types.SideTypeBuy:
s.AccumulatedMakerBidVolume.AtomicAdd(fixedpoint.NewFromFloat(trade.Quantity))
s.TodayMakerBidVolume.AtomicAdd(fixedpoint.NewFromFloat(trade.Quantity))
}
}
}
func (s *ProfitStats) ResetToday() {
2021-10-08 06:57:44 +00:00
s.ProfitStats.ResetToday()
2021-06-26 12:11:20 +00:00
s.TodayMakerVolume = 0
s.TodayMakerBidVolume = 0
s.TodayMakerAskVolume = 0
}
type Strategy struct {
*bbgo.Graceful
*bbgo.Notifiability
*bbgo.Persistence
2021-05-30 06:46:48 +00:00
Symbol string `json:"symbol"`
// SourceExchange session name
SourceExchange string `json:"sourceExchange"`
2021-05-30 06:46:48 +00:00
// MakerExchange session name
MakerExchange string `json:"makerExchange"`
2021-05-09 13:14:51 +00:00
UpdateInterval types.Duration `json:"updateInterval"`
HedgeInterval types.Duration `json:"hedgeInterval"`
2021-05-09 10:55:56 +00:00
OrderCancelWaitTime types.Duration `json:"orderCancelWaitTime"`
2021-06-06 18:49:44 +00:00
Margin fixedpoint.Value `json:"margin"`
BidMargin fixedpoint.Value `json:"bidMargin"`
AskMargin fixedpoint.Value `json:"askMargin"`
UseDepthPrice bool `json:"useDepthPrice"`
2021-05-09 18:52:41 +00:00
EnableBollBandMargin bool `json:"enableBollBandMargin"`
BollBandInterval types.Interval `json:"bollBandInterval"`
BollBandMargin fixedpoint.Value `json:"bollBandMargin"`
BollBandMarginFactor fixedpoint.Value `json:"bollBandMarginFactor"`
StopHedgeQuoteBalance fixedpoint.Value `json:"stopHedgeQuoteBalance"`
StopHedgeBaseBalance fixedpoint.Value `json:"stopHedgeBaseBalance"`
2021-05-09 18:52:41 +00:00
// Quantity is used for fixed quantity of the first layer
Quantity fixedpoint.Value `json:"quantity"`
// QuantityMultiplier is the factor that multiplies the quantity of the previous layer
QuantityMultiplier fixedpoint.Value `json:"quantityMultiplier"`
// QuantityScale helps user to define the quantity by layer scale
QuantityScale *bbgo.LayerScale `json:"quantityScale,omitempty"`
// MaxExposurePosition defines the unhedged quantity of stop
2021-04-04 03:14:09 +00:00
MaxExposurePosition fixedpoint.Value `json:"maxExposurePosition"`
DisableHedge bool `json:"disableHedge"`
2021-05-28 17:31:13 +00:00
NotifyTrade bool `json:"notifyTrade"`
NumLayers int `json:"numLayers"`
// Pips is the pips of the layer prices
2021-05-17 15:55:09 +00:00
Pips fixedpoint.Value `json:"pips"`
// --------------------------------
// private field
makerSession *bbgo.ExchangeSession
sourceSession *bbgo.ExchangeSession
sourceMarket types.Market
makerMarket types.Market
// boll is the BOLLINGER indicator we used for predicting the price.
boll *indicator.BOLL
state *State
book *types.StreamOrderBook
activeMakerOrders *bbgo.LocalActiveOrderBook
orderStore *bbgo.OrderStore
tradeStore *bbgo.TradeStore
tradeC chan types.Trade
lastPrice float64
2021-03-22 09:27:07 +00:00
groupID uint32
stopC chan struct{}
}
2021-05-09 12:03:06 +00:00
func (s *Strategy) ID() string {
return ID
}
func (s *Strategy) CrossSubscribe(sessions map[string]*bbgo.ExchangeSession) {
sourceSession, ok := sessions[s.SourceExchange]
if !ok {
2021-03-21 04:43:41 +00:00
panic(fmt.Errorf("source session %s is not defined", s.SourceExchange))
}
sourceSession.Subscribe(types.BookChannel, s.Symbol, types.SubscribeOptions{})
sourceSession.Subscribe(types.KLineChannel, s.Symbol, types.SubscribeOptions{Interval: "1m"})
2021-05-17 13:33:55 +00:00
makerSession, ok := sessions[s.MakerExchange]
if !ok {
panic(fmt.Errorf("maker session %s is not defined", s.MakerExchange))
}
makerSession.Subscribe(types.KLineChannel, s.Symbol, types.SubscribeOptions{Interval: "1m"})
}
2021-05-10 16:58:11 +00:00
func aggregatePrice(pvs types.PriceVolumeSlice, requiredQuantity fixedpoint.Value) (price fixedpoint.Value) {
q := requiredQuantity
totalAmount := fixedpoint.Value(0)
if len(pvs) == 0 {
price = 0
return price
} else if pvs[0].Volume >= requiredQuantity {
return pvs[0].Price
}
for i := 0; i < len(pvs); i++ {
pv := pvs[i]
if pv.Volume >= q {
totalAmount += q.Mul(pv.Price)
break
}
2021-05-10 16:10:49 +00:00
2021-05-10 16:58:11 +00:00
q -= pv.Volume
totalAmount += pv.Volume.Mul(pv.Price)
}
price = totalAmount.Div(requiredQuantity)
return price
2021-05-10 16:10:49 +00:00
}
func (s *Strategy) updateQuote(ctx context.Context, orderExecutionRouter bbgo.OrderExecutionRouter) {
if err := s.makerSession.Exchange.CancelOrders(ctx, s.activeMakerOrders.Orders()...); err != nil {
2021-05-10 16:10:49 +00:00
log.WithError(err).Errorf("can not cancel %s orders", s.Symbol)
return
}
2021-05-10 16:10:49 +00:00
// avoid unlock issue and wait for the balance update
2021-05-09 10:55:56 +00:00
if s.OrderCancelWaitTime > 0 {
time.Sleep(s.OrderCancelWaitTime.Duration())
} else {
// use the default wait time
time.Sleep(500 * time.Millisecond)
}
if s.activeMakerOrders.NumOfAsks() > 0 || s.activeMakerOrders.NumOfBids() > 0 {
2021-05-09 10:55:56 +00:00
log.Warnf("there are some %s orders not canceled, skipping placing maker orders", s.Symbol)
2021-05-09 12:03:06 +00:00
s.activeMakerOrders.Print()
return
}
2021-06-07 09:02:24 +00:00
bestBid, bestAsk, hasPrice := s.book.BestBidAndAsk()
if !hasPrice {
return
}
sourceBook := s.book.CopyDepth(20)
if valid, err := sourceBook.IsValid(); !valid {
2021-06-07 09:02:24 +00:00
log.WithError(err).Errorf("%s invalid copied order book, skip quoting: %v", s.Symbol, err)
return
}
2021-03-21 03:16:15 +00:00
var disableMakerBid = false
var disableMakerAsk = false
2021-05-10 16:10:49 +00:00
// check maker's balance quota
// we load the balances from the account while we're generating the orders,
2021-03-21 03:16:15 +00:00
// the balance may have a chance to be deducted by other strategies or manual orders submitted by the user
makerBalances := s.makerSession.Account.Balances()
makerQuota := &bbgo.QuotaTransaction{}
2021-03-21 03:16:15 +00:00
if b, ok := makerBalances[s.makerMarket.BaseCurrency]; ok {
2021-05-10 16:10:49 +00:00
if b.Available.Float64() > s.makerMarket.MinQuantity {
makerQuota.BaseAsset.Add(b.Available)
} else {
2021-03-21 04:43:41 +00:00
disableMakerAsk = true
}
}
2021-03-21 04:43:41 +00:00
2021-03-21 03:16:15 +00:00
if b, ok := makerBalances[s.makerMarket.QuoteCurrency]; ok {
2021-05-10 16:10:49 +00:00
if b.Available.Float64() > s.makerMarket.MinNotional {
makerQuota.QuoteAsset.Add(b.Available)
} else {
2021-04-04 03:14:09 +00:00
disableMakerBid = true
}
}
hedgeBalances := s.sourceSession.Account.Balances()
hedgeQuota := &bbgo.QuotaTransaction{}
if b, ok := hedgeBalances[s.sourceMarket.BaseCurrency]; ok {
2021-03-21 04:43:41 +00:00
// to make bid orders, we need enough base asset in the foreign exchange,
2021-03-21 03:16:15 +00:00
// if the base asset balance is not enough for selling
if s.StopHedgeBaseBalance > 0 {
if b.Available > (s.StopHedgeBaseBalance + fixedpoint.NewFromFloat(s.sourceMarket.MinQuantity)) {
hedgeQuota.BaseAsset.Add(b.Available - s.StopHedgeBaseBalance - fixedpoint.NewFromFloat(s.sourceMarket.MinQuantity))
} else {
log.Warnf("%s maker bid disabled: insufficient base balance %s", s.Symbol, b.String())
disableMakerBid = true
}
} else if b.Available.Float64() > s.sourceMarket.MinQuantity {
2021-05-10 16:10:49 +00:00
hedgeQuota.BaseAsset.Add(b.Available)
} else {
2021-05-11 04:53:32 +00:00
log.Warnf("%s maker bid disabled: insufficient base balance %s", s.Symbol, b.String())
2021-03-21 03:16:15 +00:00
disableMakerBid = true
}
}
2021-03-21 03:16:15 +00:00
if b, ok := hedgeBalances[s.sourceMarket.QuoteCurrency]; ok {
2021-03-21 04:43:41 +00:00
// to make ask orders, we need enough quote asset in the foreign exchange,
2021-03-21 03:16:15 +00:00
// if the quote asset balance is not enough for buying
if s.StopHedgeQuoteBalance > 0 {
if b.Available > (s.StopHedgeQuoteBalance + fixedpoint.NewFromFloat(s.sourceMarket.MinNotional)) {
hedgeQuota.QuoteAsset.Add(b.Available - s.StopHedgeQuoteBalance - fixedpoint.NewFromFloat(s.sourceMarket.MinNotional))
} else {
log.Warnf("%s maker ask disabled: insufficient quote balance %s", s.Symbol, b.String())
disableMakerAsk = true
}
} else if b.Available.Float64() > s.sourceMarket.MinNotional {
2021-05-10 16:10:49 +00:00
hedgeQuota.QuoteAsset.Add(b.Available)
} else {
2021-05-11 04:53:32 +00:00
log.Warnf("%s maker ask disabled: insufficient quote balance %s", s.Symbol, b.String())
2021-03-21 03:16:15 +00:00
disableMakerAsk = true
}
}
2021-05-10 16:10:49 +00:00
// if max exposure position is configured, we should not:
// 1. place bid orders when we already bought too much
// 2. place ask orders when we already sold too much
if s.MaxExposurePosition > 0 {
pos := s.state.HedgePosition.AtomicLoad()
if pos < -s.MaxExposurePosition {
// stop sell if we over-sell
disableMakerAsk = true
} else if pos > s.MaxExposurePosition {
// stop buy if we over buy
disableMakerBid = true
}
}
2021-03-21 04:43:41 +00:00
if disableMakerAsk && disableMakerBid {
2021-05-17 13:33:55 +00:00
log.Warnf("%s bid/ask maker is disabled due to insufficient balances", s.Symbol)
2021-03-21 04:43:41 +00:00
return
}
2021-06-06 18:23:07 +00:00
bestBidPrice := bestBid.Price
bestAskPrice := bestAsk.Price
log.Infof("%s book ticker: best ask / best bid = %f / %f", s.Symbol, bestAskPrice.Float64(), bestBidPrice.Float64())
2021-05-10 16:10:49 +00:00
var submitOrders []types.SubmitOrder
2021-05-10 16:58:11 +00:00
var accumulativeBidQuantity, accumulativeAskQuantity fixedpoint.Value
2021-05-10 16:10:49 +00:00
var bidQuantity = s.Quantity
var askQuantity = s.Quantity
var bidMargin = s.BidMargin
var askMargin = s.AskMargin
2021-05-17 15:55:09 +00:00
var pips = s.Pips
if s.EnableBollBandMargin {
lastDownBand := s.boll.LastDownBand()
lastUpBand := s.boll.LastUpBand()
// when bid price is lower than the down band, then it's in the downtrend
// when ask price is higher than the up band, then it's in the uptrend
if bestBidPrice.Float64() < lastDownBand {
// ratio here should be greater than 1.00
ratio := lastDownBand / bestBidPrice.Float64()
// so that the original bid margin can be multiplied by 1.x
bollMargin := s.BollBandMargin.MulFloat64(ratio).Mul(s.BollBandMarginFactor)
log.Infof("%s bollband downtrend: adjusting ask margin %f + %f = %f",
s.Symbol,
askMargin.Float64(),
bollMargin.Float64(),
(askMargin + bollMargin).Float64())
askMargin = askMargin + bollMargin
2021-05-17 15:55:09 +00:00
pips = pips.MulFloat64(ratio)
}
if bestAskPrice.Float64() > lastUpBand {
// ratio here should be greater than 1.00
ratio := bestAskPrice.Float64() / lastUpBand
// so that the original bid margin can be multiplied by 1.x
bollMargin := s.BollBandMargin.MulFloat64(ratio).Mul(s.BollBandMarginFactor)
log.Infof("%s bollband uptrend adjusting bid margin %f + %f = %f",
s.Symbol,
bidMargin.Float64(),
bollMargin.Float64(),
(bidMargin + bollMargin).Float64())
bidMargin = bidMargin + bollMargin
2021-05-17 15:55:09 +00:00
pips = pips.MulFloat64(ratio)
}
}
2021-06-06 18:49:44 +00:00
bidPrice := bestBidPrice
askPrice := bestAskPrice
for i := 0; i < s.NumLayers; i++ {
2021-03-21 03:16:15 +00:00
// for maker bid orders
if !disableMakerBid {
2021-05-09 18:52:41 +00:00
if s.QuantityScale != nil {
qf, err := s.QuantityScale.Scale(i + 1)
if err != nil {
log.WithError(err).Errorf("quantityScale error")
return
}
log.Infof("%s scaling bid #%d quantity to %f", s.Symbol, i+1, qf)
2021-05-09 18:52:41 +00:00
// override the default bid quantity
bidQuantity = fixedpoint.NewFromFloat(qf)
}
2021-05-10 16:58:11 +00:00
accumulativeBidQuantity += bidQuantity
2021-06-06 18:49:44 +00:00
if s.UseDepthPrice {
bidPrice = aggregatePrice(sourceBook.SideBook(types.SideTypeBuy), accumulativeBidQuantity)
}
2021-05-17 15:55:09 +00:00
2021-06-06 18:49:44 +00:00
bidPrice = bidPrice.MulFloat64(1.0 - bidMargin.Float64())
2021-05-17 15:55:09 +00:00
if i > 0 && pips > 0 {
bidPrice -= pips.MulFloat64(s.makerMarket.TickSize)
}
2021-05-10 16:58:11 +00:00
2021-03-21 03:16:15 +00:00
if makerQuota.QuoteAsset.Lock(bidQuantity.Mul(bidPrice)) && hedgeQuota.BaseAsset.Lock(bidQuantity) {
// if we bought, then we need to sell the base from the hedge session
submitOrders = append(submitOrders, types.SubmitOrder{
Symbol: s.Symbol,
Type: types.OrderTypeLimit,
Side: types.SideTypeBuy,
Price: bidPrice.Float64(),
Quantity: bidQuantity.Float64(),
TimeInForce: "GTC",
GroupID: s.groupID,
})
makerQuota.Commit()
hedgeQuota.Commit()
} else {
makerQuota.Rollback()
hedgeQuota.Rollback()
}
2021-05-09 18:52:41 +00:00
if s.QuantityMultiplier > 0 {
bidQuantity = bidQuantity.Mul(s.QuantityMultiplier)
}
}
2021-03-21 03:16:15 +00:00
// for maker ask orders
if !disableMakerAsk {
2021-05-09 18:52:41 +00:00
if s.QuantityScale != nil {
qf, err := s.QuantityScale.Scale(i + 1)
if err != nil {
log.WithError(err).Errorf("quantityScale error")
return
}
log.Infof("%s scaling ask #%d quantity to %f", s.Symbol, i+1, qf)
2021-05-09 18:52:41 +00:00
// override the default bid quantity
askQuantity = fixedpoint.NewFromFloat(qf)
}
2021-05-10 16:58:11 +00:00
accumulativeAskQuantity += askQuantity
2021-06-06 18:49:44 +00:00
if s.UseDepthPrice {
askPrice = aggregatePrice(sourceBook.SideBook(types.SideTypeSell), accumulativeAskQuantity)
}
askPrice = askPrice.MulFloat64(1.0 + askMargin.Float64())
2021-05-17 15:55:09 +00:00
if i > 0 && pips > 0 {
askPrice -= pips.MulFloat64(s.makerMarket.TickSize)
}
2021-05-09 18:52:41 +00:00
2021-03-21 03:16:15 +00:00
if makerQuota.BaseAsset.Lock(askQuantity) && hedgeQuota.QuoteAsset.Lock(askQuantity.Mul(askPrice)) {
// if we bought, then we need to sell the base from the hedge session
submitOrders = append(submitOrders, types.SubmitOrder{
Symbol: s.Symbol,
Market: s.makerMarket,
2021-03-21 03:16:15 +00:00
Type: types.OrderTypeLimit,
Side: types.SideTypeSell,
Price: askPrice.Float64(),
Quantity: askQuantity.Float64(),
TimeInForce: "GTC",
GroupID: s.groupID,
})
makerQuota.Commit()
hedgeQuota.Commit()
} else {
makerQuota.Rollback()
hedgeQuota.Rollback()
}
2021-05-09 18:52:41 +00:00
if s.QuantityMultiplier > 0 {
askQuantity = askQuantity.Mul(s.QuantityMultiplier)
}
}
}
if len(submitOrders) == 0 {
2021-05-17 13:33:55 +00:00
log.Warnf("no orders generated")
return
}
makerOrders, err := orderExecutionRouter.SubmitOrdersTo(ctx, s.MakerExchange, submitOrders...)
if err != nil {
log.WithError(err).Errorf("order error: %s", err.Error())
return
}
s.activeMakerOrders.Add(makerOrders...)
s.orderStore.Add(makerOrders...)
}
2021-05-30 06:46:48 +00:00
func (s *Strategy) Hedge(ctx context.Context, pos fixedpoint.Value) {
side := types.SideTypeBuy
if pos == 0 {
return
}
2021-05-30 06:46:48 +00:00
quantity := fixedpoint.Abs(pos)
if pos < 0 {
side = types.SideTypeSell
}
lastPrice := s.lastPrice
sourceBook := s.book.CopyDepth(1)
switch side {
case types.SideTypeBuy:
if bestAsk, ok := sourceBook.BestAsk(); ok {
lastPrice = bestAsk.Price.Float64()
}
case types.SideTypeSell:
if bestBid, ok := sourceBook.BestBid(); ok {
lastPrice = bestBid.Price.Float64()
}
}
notional := quantity.MulFloat64(lastPrice)
if notional.Float64() <= s.sourceMarket.MinNotional {
2021-06-06 18:17:13 +00:00
log.Warnf("%s %f less than min notional, skipping hedge", s.Symbol, notional.Float64())
return
}
// adjust quantity according to the balances
account := s.sourceSession.Account
switch side {
case types.SideTypeBuy:
// check quote quantity
2021-05-10 12:22:33 +00:00
if quote, ok := account.Balance(s.sourceMarket.QuoteCurrency); ok {
if quote.Available < notional {
// adjust price to higher 0.1%, so that we can ensure that the order can be executed
quantity = bbgo.AdjustQuantityByMaxAmount(quantity, fixedpoint.NewFromFloat(lastPrice*1.001), quote.Available)
}
}
case types.SideTypeSell:
// check quote quantity
2021-05-10 12:22:33 +00:00
if base, ok := account.Balance(s.sourceMarket.BaseCurrency); ok {
if base.Available < quantity {
quantity = base.Available
}
}
}
log.Infof("submitting %s hedge order %s %f", s.Symbol, side.String(), quantity.Float64())
2021-05-15 17:16:03 +00:00
s.Notifiability.Notify("Submitting %s hedge order %s %f", s.Symbol, side.String(), quantity.Float64())
orderExecutor := &bbgo.ExchangeOrderExecutor{Session: s.sourceSession}
returnOrders, err := orderExecutor.SubmitOrders(ctx, types.SubmitOrder{
Market: s.sourceMarket,
Symbol: s.Symbol,
Type: types.OrderTypeMarket,
Side: side,
Quantity: quantity.Float64(),
})
if err != nil {
log.WithError(err).Errorf("market order submit error: %s", err.Error())
return
}
2021-05-30 06:46:48 +00:00
// if it's selling, than we should add positive position
if side == types.SideTypeSell {
s.state.CoveredPosition.AtomicAdd(quantity)
} else {
s.state.CoveredPosition.AtomicAdd(-quantity)
}
s.orderStore.Add(returnOrders...)
}
func (s *Strategy) handleTrade(trade types.Trade) {
s.tradeC <- trade
}
func (s *Strategy) processTrade(trade types.Trade) {
log.Infof("processing trade %+v", trade)
if trade.Symbol != s.Symbol {
return
}
if !s.orderStore.Exists(trade.OrderID) {
return
}
2021-05-28 17:41:29 +00:00
if s.NotifyTrade {
s.Notifiability.Notify(trade)
}
log.Infof("identified %s trade %d with an existing order: %d", trade.Symbol, trade.ID, trade.OrderID)
q := fixedpoint.NewFromFloat(trade.Quantity)
switch trade.Side {
case types.SideTypeSell:
q = -q
case types.SideTypeBuy:
case types.SideTypeSelf:
// ignore self trades
2021-05-11 07:56:46 +00:00
log.Warnf("ignore self trade")
return
default:
log.Infof("ignore non sell/buy side trades, got: %v", trade.Side)
return
}
2021-05-09 15:56:54 +00:00
s.state.HedgePosition.AtomicAdd(q)
2021-05-30 06:46:48 +00:00
if trade.Exchange == s.sourceSession.ExchangeName {
s.state.CoveredPosition.AtomicAdd(q)
}
2021-06-26 12:11:20 +00:00
s.state.ProfitStats.AddTrade(trade)
2021-05-09 15:56:54 +00:00
2021-05-22 09:17:37 +00:00
if profit, netProfit, madeProfit := s.state.Position.AddTrade(trade); madeProfit {
p := bbgo.Profit{
Symbol: s.Symbol,
Profit: profit,
NetProfit: netProfit,
TradeAmount: fixedpoint.NewFromFloat(trade.QuoteQuantity),
ProfitMargin: profit.DivFloat64(trade.QuoteQuantity),
NetProfitMargin: netProfit.DivFloat64(trade.QuoteQuantity),
QuoteCurrency: s.state.Position.QuoteCurrency,
BaseCurrency: s.state.Position.BaseCurrency,
2021-10-09 05:25:17 +00:00
Time: trade.Time.Time(),
}
s.state.ProfitStats.AddProfit(p)
s.Notify(&p)
} else {
log.Infof("position changed: %s", s.state.Position)
2021-05-15 17:16:03 +00:00
s.Notify(s.state.Position)
}
s.lastPrice = trade.Price
2021-05-22 09:44:20 +00:00
if err := s.SaveState(); err != nil {
log.WithError(err).Error("save state error")
}
}
2021-05-09 18:52:41 +00:00
func (s *Strategy) Validate() error {
if s.Quantity == 0 || s.QuantityScale == nil {
return errors.New("quantity or quantityScale can not be empty")
}
if s.QuantityMultiplier != 0 && s.QuantityMultiplier < 0 {
return errors.New("quantityMultiplier can not be a negative number")
}
if len(s.Symbol) == 0 {
return errors.New("symbol is required")
}
return nil
}
2021-05-22 09:44:20 +00:00
func (s *Strategy) LoadState() error {
var state State
// load position
if err := s.Persistence.Load(&state, ID, s.Symbol, stateKey); err != nil {
if err != service.ErrPersistenceNotExists {
return err
}
s.state = &State{}
} else {
s.state = &state
log.Infof("state is restored: %+v", s.state)
}
2021-06-26 12:11:20 +00:00
// if position is nil, we need to allocate a new position for calculation
if s.state.Position == nil {
2021-10-17 14:24:51 +00:00
s.state.Position = bbgo.NewPositionFromMarket(s.makerMarket)
2021-06-26 12:11:20 +00:00
}
s.state.ProfitStats.Symbol = s.makerMarket.Symbol
s.state.ProfitStats.BaseCurrency = s.makerMarket.BaseCurrency
s.state.ProfitStats.QuoteCurrency = s.makerMarket.QuoteCurrency
2021-06-26 12:11:20 +00:00
s.state.ProfitStats.MakerExchange = s.makerSession.ExchangeName
if s.state.ProfitStats.AccumulatedSince == 0 {
s.state.ProfitStats.AccumulatedSince = time.Now().Unix()
}
2021-05-22 09:44:20 +00:00
return nil
}
func (s *Strategy) SaveState() error {
if err := s.Persistence.Save(s.state, ID, s.Symbol, stateKey); err != nil {
return err
} else {
log.Infof("%s state is saved => %+v", ID, s.state)
2021-05-22 09:44:20 +00:00
}
return nil
}
func (s *Strategy) CrossRun(ctx context.Context, orderExecutionRouter bbgo.OrderExecutionRouter, sessions map[string]*bbgo.ExchangeSession) error {
// buffer 100 trades in the channel
s.tradeC = make(chan types.Trade, 100)
if s.BollBandInterval == "" {
s.BollBandInterval = types.Interval1m
}
if s.BollBandMarginFactor == 0 {
s.BollBandMarginFactor = fixedpoint.NewFromFloat(1.0)
}
if s.BollBandMargin == 0 {
s.BollBandMargin = fixedpoint.NewFromFloat(0.001)
}
// configure default values
if s.UpdateInterval == 0 {
s.UpdateInterval = types.Duration(time.Second)
}
if s.HedgeInterval == 0 {
s.HedgeInterval = types.Duration(10 * time.Second)
}
if s.NumLayers == 0 {
s.NumLayers = 1
}
if s.BidMargin == 0 {
if s.Margin != 0 {
s.BidMargin = s.Margin
} else {
s.BidMargin = defaultMargin
}
}
if s.AskMargin == 0 {
if s.Margin != 0 {
s.AskMargin = s.Margin
} else {
s.AskMargin = defaultMargin
}
}
// configure sessions
sourceSession, ok := sessions[s.SourceExchange]
if !ok {
return fmt.Errorf("source exchange session %s is not defined", s.SourceExchange)
}
s.sourceSession = sourceSession
makerSession, ok := sessions[s.MakerExchange]
if !ok {
return fmt.Errorf("maker exchange session %s is not defined", s.MakerExchange)
}
s.makerSession = makerSession
s.sourceMarket, ok = s.sourceSession.Market(s.Symbol)
if !ok {
return fmt.Errorf("source session market %s is not defined", s.Symbol)
}
s.makerMarket, ok = s.makerSession.Market(s.Symbol)
if !ok {
return fmt.Errorf("maker session market %s is not defined", s.Symbol)
}
standardIndicatorSet, ok := s.sourceSession.StandardIndicatorSet(s.Symbol)
if !ok {
return fmt.Errorf("%s standard indicator set not found", s.Symbol)
}
s.boll = standardIndicatorSet.BOLL(types.IntervalWindow{
Interval: s.BollBandInterval,
Window: 21,
}, 1.0)
// restore state
2021-03-21 04:43:41 +00:00
instanceID := fmt.Sprintf("%s-%s", ID, s.Symbol)
2021-03-22 09:27:07 +00:00
s.groupID = max.GenerateGroupID(instanceID)
log.Infof("using group id %d from fnv(%s)", s.groupID, instanceID)
2021-05-22 09:44:20 +00:00
if err := s.LoadState(); err != nil {
return err
} else {
2021-05-09 13:14:51 +00:00
s.Notify("%s position is restored => %f", s.Symbol, s.state.HedgePosition.Float64())
}
2021-05-16 09:58:51 +00:00
if s.makerSession.MakerFeeRate > 0 || s.makerSession.TakerFeeRate > 0 {
s.state.Position.SetExchangeFeeRate(types.ExchangeName(s.MakerExchange), bbgo.ExchangeFee{
MakerFeeRate: s.makerSession.MakerFeeRate,
TakerFeeRate: s.makerSession.TakerFeeRate,
})
}
if s.sourceSession.MakerFeeRate > 0 || s.sourceSession.TakerFeeRate > 0 {
s.state.Position.SetExchangeFeeRate(types.ExchangeName(s.SourceExchange), bbgo.ExchangeFee{
MakerFeeRate: s.sourceSession.MakerFeeRate,
TakerFeeRate: s.sourceSession.TakerFeeRate,
})
}
s.book = types.NewStreamBook(s.Symbol)
2021-05-27 19:13:50 +00:00
s.book.BindStream(s.sourceSession.MarketDataStream)
s.sourceSession.UserDataStream.OnTradeUpdate(s.handleTrade)
s.makerSession.UserDataStream.OnTradeUpdate(s.handleTrade)
s.activeMakerOrders = bbgo.NewLocalActiveOrderBook()
s.activeMakerOrders.BindStream(s.makerSession.UserDataStream)
s.tradeStore = bbgo.NewTradeStore(s.Symbol)
s.orderStore = bbgo.NewOrderStore(s.Symbol)
s.orderStore.BindStream(s.sourceSession.UserDataStream)
s.orderStore.BindStream(s.makerSession.UserDataStream)
s.stopC = make(chan struct{})
go func() {
2021-05-09 12:03:06 +00:00
posTicker := time.NewTicker(durationJitter(s.HedgeInterval.Duration(), 200))
defer posTicker.Stop()
2021-05-09 12:03:06 +00:00
quoteTicker := time.NewTicker(durationJitter(s.UpdateInterval.Duration(), 200))
defer quoteTicker.Stop()
reportTicker := time.NewTicker(time.Hour)
defer reportTicker.Stop()
defer func() {
if err := s.makerSession.Exchange.CancelOrders(context.Background(), s.activeMakerOrders.Orders()...); err != nil {
log.WithError(err).Errorf("can not cancel %s orders", s.Symbol)
}
}()
for {
select {
case <-s.stopC:
2021-05-09 18:17:19 +00:00
log.Warnf("%s maker goroutine stopped, due to the stop signal", s.Symbol)
return
case <-ctx.Done():
2021-05-09 18:17:19 +00:00
log.Warnf("%s maker goroutine stopped, due to the cancelled context", s.Symbol)
return
2021-05-09 12:03:06 +00:00
case <-quoteTicker.C:
s.updateQuote(ctx, orderExecutionRouter)
case <-reportTicker.C:
s.Notifiability.Notify(&s.state.ProfitStats)
case trade := <-s.tradeC:
log.Infof("recieved trade %+v", trade)
if s.orderStore.Exists(trade.OrderID) {
s.processTrade(trade)
} else {
// buffer this trade to the next tick of hedge
s.tradeStore.Add(trade)
}
case <-posTicker.C:
// process pending trades
if s.tradeStore.Num() > 0 {
for _, trade := range s.tradeStore.Trades() {
2021-05-29 16:11:35 +00:00
if s.orderStore.Exists(trade.OrderID) {
s.processTrade(trade)
}
}
s.tradeStore.Clear()
}
2021-05-30 06:46:48 +00:00
// for positive position:
// uncover position = 5 - 3 (covered position) = 2
// for negative position:
// uncover position = -5 - -3 (covered position) = -2
position := s.state.HedgePosition.AtomicLoad()
2021-05-30 06:46:48 +00:00
uncoverPosition := position - s.state.CoveredPosition.AtomicLoad()
absPos := math.Abs(uncoverPosition.Float64())
if !s.DisableHedge && absPos > s.sourceMarket.MinQuantity {
2021-05-30 06:46:48 +00:00
s.Hedge(ctx, -uncoverPosition)
}
}
}
}()
s.Graceful.OnShutdown(func(ctx context.Context, wg *sync.WaitGroup) {
defer wg.Done()
close(s.stopC)
2021-05-22 09:44:20 +00:00
// wait for the quoter to stop
2021-05-09 18:17:19 +00:00
time.Sleep(s.UpdateInterval.Duration())
2021-05-09 11:04:44 +00:00
2021-05-22 09:44:20 +00:00
// ensure every order is cancelled
2021-05-15 17:16:03 +00:00
for s.activeMakerOrders.NumOfOrders() > 0 {
orders := s.activeMakerOrders.Orders()
2021-05-14 03:53:07 +00:00
log.Warnf("%d orders are not cancelled yet:", len(orders))
2021-05-09 12:03:06 +00:00
s.activeMakerOrders.Print()
if err := s.makerSession.Exchange.CancelOrders(ctx, s.activeMakerOrders.Orders()...); err != nil {
log.WithError(err).Errorf("can not cancel %s orders", s.Symbol)
2021-05-22 09:44:20 +00:00
continue
}
log.Infof("waiting for orders to be cancelled...")
select {
case <-time.After(3 * time.Second):
case <-ctx.Done():
break
}
2021-05-22 09:44:20 +00:00
// verify the current open orders via the RESTful API
if s.activeMakerOrders.NumOfOrders() > 0 {
log.Warnf("there are orders not cancelled, using REStful API to verify...")
openOrders, err := s.makerSession.Exchange.QueryOpenOrders(ctx, s.Symbol)
if err != nil {
log.WithError(err).Errorf("can not query %s open orders", s.Symbol)
continue
}
openOrderStore := bbgo.NewOrderStore(s.Symbol)
openOrderStore.Add(openOrders...)
for _, o := range s.activeMakerOrders.Orders() {
// if it does not exist, we should remove it
if !openOrderStore.Exists(o.OrderID) {
s.activeMakerOrders.Remove(o)
}
}
}
}
2021-05-14 03:53:07 +00:00
log.Info("all orders are cancelled successfully")
2021-05-22 09:44:20 +00:00
if err := s.SaveState(); err != nil {
log.WithError(err).Errorf("can not save state: %+v", s.state)
} else {
s.Notify("%s: %s position is saved: %f", ID, s.Symbol, s.state.HedgePosition.Float64(), s.state.Position)
}
})
return nil
}
2021-05-09 12:03:06 +00:00
func durationJitter(d time.Duration, jitterInMilliseconds int) time.Duration {
n := rand.Intn(jitterInMilliseconds)
2021-05-09 13:14:51 +00:00
return d + time.Duration(n)*time.Millisecond
2021-05-09 12:03:06 +00:00
}