add logging to tbs.

diadata-org · Jul 25, 2023 · d0bbba3 · d0bbba3
1 parent fbaef56
commit d0bbba3
Show file tree

Hide file tree

Showing 2 changed files with 5 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.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
@@ -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)
 					}
 				}
 			}