diff --git a/cmd/services/tradesBlockService/go.mod b/cmd/services/tradesBlockService/go.mod index 9db6dbdf9..f9ae550c5 100644 --- 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.315-rc-1 + github.com/diadata-org/diadata v1.4.315-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 index 7e984b727..82ba4d8a8 100644 --- a/internal/pkg/tradesBlockService/tradesBlockService.go +++ b/internal/pkg/tradesBlockService/tradesBlockService.go @@ -140,6 +140,8 @@ func NewTradesBlockService(datastore models.Datastore, relDB models.RelDatastore log.Info("bluechip threshold: ", blueChipThreshold) log.Info("smallX: ", smallX) log.Info("normalX: ", normalX) + log.Info("tradeVolumeThreshold: ", tradeVolumeThreshold) + log.Info("tradeVolumeThresholdUSD: ", tradeVolumeThresholdUSD) s.volumeCache = s.loadVolumes() log.Info("...done loading volumes.") @@ -310,6 +312,8 @@ func (s *TradesBlockService) process(t dia.Trade) { t.EstimatedUSDPrice = t.Price * price if t.USDVolume() > tradeVolumeThresholdUSD { verifiedTrade = true + } else { + log.Warn("low $ volume on trade: ", t) } } }