From a7dcc39c228d1f74285895ac66efb8d27045baba Mon Sep 17 00:00:00 2001
From: c9s <yoanlin93@gmail.com>
Date: Tue, 14 Nov 2023 16:09:29 +0800
Subject: [PATCH] service: log sync start time

---
 pkg/service/sync.go | 29 ++++++++++++++++++-----------
 1 file changed, 18 insertions(+), 11 deletions(-)

diff --git a/pkg/service/sync.go b/pkg/service/sync.go
index 34010c5c5..ae9f6adb7 100644
--- a/pkg/service/sync.go
+++ b/pkg/service/sync.go
@@ -25,30 +25,37 @@ type SyncService struct {
 }
 
 // SyncSessionSymbols syncs the trades from the given exchange session
-func (s *SyncService) SyncSessionSymbols(ctx context.Context, exchange types.Exchange, startTime time.Time, symbols ...string) error {
+func (s *SyncService) SyncSessionSymbols(
+	ctx context.Context, exchange types.Exchange, startTime time.Time, symbols ...string,
+) error {
 	markets, err := cache.LoadExchangeMarketsWithCache(ctx, exchange)
 	if err != nil {
 		return err
 	}
 
 	for _, symbol := range symbols {
-		if _, ok := markets[symbol]; ok {
-			log.Infof("syncing %s %s trades...", exchange.Name(), symbol)
-			if err := s.TradeService.Sync(ctx, exchange, symbol, startTime); err != nil {
-				return err
-			}
+		// skip symbols do not exist in the market info
+		if _, ok := markets[symbol]; !ok {
+			continue
+		}
 
-			log.Infof("syncing %s %s orders...", exchange.Name(), symbol)
-			if err := s.OrderService.Sync(ctx, exchange, symbol, startTime); err != nil {
-				return err
-			}
+		log.Infof("syncing %s %s trades from %s...", exchange.Name(), symbol, startTime)
+		if err := s.TradeService.Sync(ctx, exchange, symbol, startTime); err != nil {
+			return err
+		}
+
+		log.Infof("syncing %s %s orders from %s...", exchange.Name(), symbol, startTime)
+		if err := s.OrderService.Sync(ctx, exchange, symbol, startTime); err != nil {
+			return err
 		}
 	}
 
 	return nil
 }
 
-func (s *SyncService) SyncMarginHistory(ctx context.Context, exchange types.Exchange, startTime time.Time, assets ...string) error {
+func (s *SyncService) SyncMarginHistory(
+	ctx context.Context, exchange types.Exchange, startTime time.Time, assets ...string,
+) error {
 	if _, implemented := exchange.(types.MarginHistoryService); !implemented {
 		log.Debugf("exchange %T does not support types.MarginHistoryService", exchange)
 		return nil