lychiyu/bbgo_origin
1
0
Fork 0
mirror of https://github.com/c9s/bbgo.git synced 2024-11-21 22:43:52 +00:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

xmaker: add enableDelayHedge option

Browse Source
This commit is contained in:
c9s 2024-10-15 18:51:37 +08:00
parent 1210a79fc7
commit 334c868117
No known key found for this signature in database
GPG Key ID: 7385E7E464CB0A54
1 changed files with 31 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
pkg/strategy/xmaker/strategy.go
View File

@ -136,6 +136,8 @@ type Strategy struct {
DepthQuantity fixedpoint.Value `json:"depthQuantity"`
SourceDepthLevel types.Depth `json:"sourceDepthLevel"`
// EnableDelayHedge enables the delay hedge feature
EnableDelayHedge bool `json:"enableDelayHedge"`
// MaxHedgeDelayDuration is the maximum delay duration to hedge the position
MaxDelayHedgeDuration types.Duration `json:"maxHedgeDelayDuration"`
DelayHedgeSignalThreshold float64 `json:"delayHedgeSignalThreshold"`
@ -217,7 +219,7 @@ type Strategy struct {
accountValueCalculator *bbgo.AccountValueCalculator
lastPrice fixedpoint.Value
lastPrice fixedpoint.MutexValue
groupID uint32
stopC chan struct{}
@ -635,9 +637,9 @@ func (s *Strategy) updateQuote(ctx context.Context) error {
}
// use mid-price for the last price
s.lastPrice = bestBid.Price.Add(bestAsk.Price).Div(two)
s.priceSolver.Update(s.Symbol, s.lastPrice)
midPrice := bestBid.Price.Add(bestAsk.Price).Div(two)
s.lastPrice.Set(midPrice)
s.priceSolver.Update(s.Symbol, midPrice)
bookLastUpdateTime := s.sourceBook.LastUpdateTime()
@ -679,7 +681,7 @@ func (s *Strategy) updateQuote(ctx context.Context) error {
makerQuota := &bbgo.QuotaTransaction{}
if b, ok := makerBalances[s.makerMarket.BaseCurrency]; ok {
if s.makerMarket.IsDustQuantity(b.Available, s.lastPrice) {
if s.makerMarket.IsDustQuantity(b.Available, s.lastPrice.Get()) {
disableMakerAsk = true
s.logger.Infof("%s maker ask disabled: insufficient base balance %s", s.Symbol, b.String())
} else {
@ -1176,7 +1178,18 @@ func (s *Strategy) Hedge(ctx context.Context, pos fixedpoint.Value) {
side = types.SideTypeSell
}
lastPrice := s.lastPrice
signal := s.lastAggregatedSignal.Get()
// if the signal is strong enough, we can delay the hedge and wait for the next tick
if math.Abs(signal) > s.DelayHedgeSignalThreshold {
if period, ok := s.getPositionHoldingPeriod(time.Now()); ok {
if period < s.MaxDelayHedgeDuration.Duration() {
return
}
}
}
lastPrice := s.lastPrice.Get()
sourceBook := s.sourceBook.CopyDepth(1)
switch side {
@ -1302,6 +1315,14 @@ func (s *Strategy) Defaults() error {
s.BollBandInterval = types.Interval1m
}
if s.MaxDelayHedgeDuration == 0 {
s.MaxDelayHedgeDuration = types.Duration(10 * time.Second)
}
if s.DelayHedgeSignalThreshold == 0.0 {
s.DelayHedgeSignalThreshold = 0.5
}
if s.SourceDepthLevel == "" {
s.SourceDepthLevel = types.DepthLevelMedium
}
@ -1468,6 +1489,10 @@ func (s *Strategy) hedgeWorker(ctx context.Context) {
uncoverPosition := position.Sub(coveredPosition)
absPos := uncoverPosition.Abs()
if s.sourceMarket.IsDustQuantity(absPos, s.lastPrice.Get()) {
continue
}
if !s.DisableHedge {
continue
}