add logging to tbs for volume liquidity ratio.

diadata-org · Aug 21, 2023 · 129116f · 129116f
1 parent f19ab59
commit 129116f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/cmd/services/tradesBlockService/go.mod b/cmd/services/tradesBlockService/go.mod
@@ -3,7 +3,7 @@ module github.com/diadata-org/diadata/services/tradesBlockService
 go 1.17
 
 require (
-	github.com/diadata-org/diadata v1.4.329-rc-1
+	github.com/diadata-org/diadata v1.4.329-rc-2
 	github.com/segmentio/kafka-go v0.4.35
 	github.com/sirupsen/logrus v1.8.1
 )

diff --git a/internal/pkg/tradesBlockService/tradesBlockService.go b/internal/pkg/tradesBlockService/tradesBlockService.go
@@ -149,6 +149,7 @@ func NewTradesBlockService(datastore models.Datastore, relDB models.RelDatastore
 	log.Info("normalX: ", normalX)
 	log.Info("tradeVolumeThreshold: ", tradeVolumeThreshold)
 	log.Info("tradeVolumeThresholdUSD: ", tradeVolumeThresholdUSD)
+	log.Info("volumeLiquidityRatio: ", volumeLiquidityRatio)
 
 	var err error
 	s.volumeCache, err = s.relDB.GetVolumesMap(time.Now().AddDate(0, 0, -7))
@@ -260,6 +261,7 @@ func (s *TradesBlockService) checkTrade(t dia.Trade) bool {
 	if err == nil {
 		liquidity, lowerBound := pool.GetPoolLiquidityUSD()
 		if quoteVolumeOk && !lowerBound && quoteVolume > volumeLiquidityRatio*liquidity {
+			log.Warn("discard trade due to volumeLiquidityRatio: ", t)
 			return false
 		}
 	}