From bc1ead16b969e5ba8939bfbe85422034b2d6d9e7 Mon Sep 17 00:00:00 2001
From: Major <major@ycorpo.com>
Date: Tue, 20 Jun 2023 21:05:34 +0200
Subject: [PATCH] fix: db sync

---
 internal/strategies/fetcher.go | 47 +++++++---------------------------
 1 file changed, 9 insertions(+), 38 deletions(-)

diff --git a/internal/strategies/fetcher.go b/internal/strategies/fetcher.go
index 4ad9d0905..7cdfc8644 100755
--- a/internal/strategies/fetcher.go
+++ b/internal/strategies/fetcher.go
@@ -3,13 +3,11 @@ package strategies
 import (
 	"math/big"
 	"strconv"
-	"sync"
 
 	"github.com/ethereum/go-ethereum/common"
 	"github.com/yearn/ydaemon/common/bigNumber"
 	"github.com/yearn/ydaemon/common/ethereum"
 	"github.com/yearn/ydaemon/common/helpers"
-	"github.com/yearn/ydaemon/common/store"
 	"github.com/yearn/ydaemon/common/traces"
 	"github.com/yearn/ydaemon/internal/meta"
 	"github.com/yearn/ydaemon/internal/models"
@@ -219,41 +217,14 @@ func RetrieveAllStrategies(
 		SetTag(`subsystem`, `daemon`)
 	defer trace.Finish()
 
-	/**********************************************************************************************
-	** First, try to retrieve the list of strategies from the database to exclude the one existing
-	** from the upcoming calls
-	**********************************************************************************************/
-	strategyMap := make(map[common.Address]*models.TStrategy)
-	store.ListFromBadgerDB(chainID, store.TABLES.STRATEGIES, &strategyMap)
-
-	/**********************************************************************************************
-	** Once we got out basic list, we will fetch theses basics informations.
-	**********************************************************************************************/
-	if len(strategyAddedList) > 0 {
-		updatedStrategiesMap := findAllStrategies(chainID, strategyAddedList)
-
-		/**********************************************************************************************
-		** Once everything is setup, we will store each token in the DB. The storage is set as a map
-		** of strategyAddress -> TStrategy. All the strategies will be retrievable from the
-		** store.Interate() func.
-		**********************************************************************************************/
-		wg := sync.WaitGroup{}
-		wg.Add(len(updatedStrategiesMap))
-		for _, token := range updatedStrategiesMap {
-			go func(_strategy *models.TStrategy) {
-				defer wg.Done()
-				store.SaveInBadgerDB(
-					chainID,
-					store.TABLES.STRATEGIES,
-					_strategy.Address.Hex(),
-					_strategy,
-				)
-			}(token)
-		}
-		wg.Wait()
-		store.ListFromBadgerDB(chainID, store.TABLES.STRATEGIES, &strategyMap)
-	}
+	updatedStrategiesMap := findAllStrategies(chainID, strategyAddedList)
+	// for _, s := range strategyAddedList {
+	// 	if s.VaultAddress == common.HexToAddress(`0x849dC56ceCa7Cf55AbF5ec87910DA21c5C7dA581`) {
+	// 		logs.Pretty(s)
+	// 	}
+	// }
+	// logs.Pretty(updatedStrategiesMap)
 
-	StoreStrategies(chainID, strategyMap)
-	return strategyMap
+	StoreStrategies(chainID, updatedStrategiesMap)
+	return updatedStrategiesMap
 }