log timestamps for pairs in dal collector

Bisonai · Jul 30, 2024 · 85c4a56 · 85c4a56
1 parent b9c096b
commit 85c4a56
Showing 1 changed file with 11 additions and 0 deletions.
diff --git a/node/pkg/dal/collector/collector.go b/node/pkg/dal/collector/collector.go
@@ -6,6 +6,7 @@ import (
 	"os"
 	"strconv"
 	"sync"
+	"time"
 
 	"bisonai.com/orakl/node/pkg/aggregator"
 	"bisonai.com/orakl/node/pkg/chain/websocketchainreader"
@@ -157,7 +158,17 @@ func (c *Collector) receiveEach(ctx context.Context, configId int32) error {
 }
 
 func (c *Collector) processIncomingData(ctx context.Context, data aggregator.SubmissionData) {
+	symbol := c.Symbols[data.GlobalAggregate.ConfigID]
+	log.Info().Msgf(
+		"%s: %.2f seconds had passed when data is received",
+		symbol,
+		time.Since(data.GlobalAggregate.Timestamp).Seconds(),
+	)
+
+	start := time.Now()
 	result, err := c.IncomingDataToOutgoingData(ctx, data)
+	log.Info().Msgf("%s took %.2f seconds to process", symbol, time.Since(start).Seconds())
+
 	if err != nil {
 		log.Error().Err(err).Str("Player", "DalCollector").Msg("failed to convert incoming data to outgoing data")
 		return