From c13a5cdf6e42aa37394b5f9c3d882227372b98e1 Mon Sep 17 00:00:00 2001
From: c9s <yoanlin93@gmail.com>
Date: Sat, 22 Jul 2023 17:32:24 +0800
Subject: [PATCH] core: add recover logs for the recovered trade count

---
 pkg/core/tradecollector.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/pkg/core/tradecollector.go b/pkg/core/tradecollector.go
index a782a8126..87c59e053 100644
--- a/pkg/core/tradecollector.go
+++ b/pkg/core/tradecollector.go
@@ -99,13 +99,17 @@ func (c *TradeCollector) Recover(ctx context.Context, ex types.ExchangeTradeHist
 		return err
 	}
 
+	cnt := 0
 	for _, td := range trades {
 		logrus.Debugf("checking trade: %s", td.String())
 		if c.processTrade(td) {
 			logrus.Infof("recovered trade: %s", td.String())
+			cnt++
 			c.EmitRecover(td)
 		}
 	}
+
+	logrus.Infof("%d %s trades were recovered", cnt, symbol)
 	return nil
 }