feat: config optimisation

rpc/chain/client.go

@@ -54,7 +54,7 @@ func NewSimpleClient(main *rpc.Client, chainID uint64) *ClientWithFallback {
 
 func NewClient(main, fallback *rpc.Client, chainID uint64) *ClientWithFallback {
 	hystrix.ConfigureCommand(fmt.Sprintf("ethClient_%d", chainID), hystrix.CommandConfig{
-		Timeout:               10000,
+		Timeout:               20000,
 		MaxConcurrentRequests: 100,
 		SleepWindow:           300000,
 		ErrorPercentThreshold: 25,

services/wallet/token/token.go

@@ -504,7 +504,7 @@ func (tm *Manager) GetBalances(parent context.Context, clients []*chain.ClientWi
 		if err == nil {
 			fetchChainBalance := false
 			var tokenChunks [][]common.Address
-			chunkSize := 100
+			chunkSize := 500
 			for i := 0; i < len(tokens); i += chunkSize {
 				end := i + chunkSize
 				if end > len(tokens) {
@@ -638,7 +638,7 @@ func (tm *Manager) GetBalancesByChain(parent context.Context, clients []*chain.C
 		if err == nil {
 			fetchChainBalance := false
 			var tokenChunks [][]common.Address
-			chunkSize := 100
+			chunkSize := 500
 			for i := 0; i < len(tokens); i += chunkSize {
 				end := i + chunkSize
 				if end > len(tokens) {

services/wallet/transfer/commands.go

@@ -35,9 +35,11 @@ var (
 	binanceChainMaxInitialRange       = big.NewInt(500000)
 	binanceChainErc20BatchSize        = big.NewInt(5000)
 	goerliErc20BatchSize              = big.NewInt(100000)
+	goerliErc20ArbitrumBatchSize      = big.NewInt(100000)
 	erc20BatchSize                    = big.NewInt(500000)
 	binancChainID                     = uint64(56)
 	goerliChainID                     = uint64(5)
+	goerliArbitrumChainID             = uint64(421613)
 	binanceTestChainID                = uint64(97)
 	numberOfBlocksCheckedPerIteration = 40
 )
@@ -122,6 +124,10 @@ func getErc20BatchSize(chainID uint64) *big.Int {
 		return goerliErc20BatchSize
 	}
 
+	if chainID == goerliArbitrumChainID {
+		return goerliErc20ArbitrumBatchSize
+	}
+
 	return erc20BatchSize
 }
 

services/wallet/transfer/downloader.go

@@ -451,24 +451,21 @@ func (d *ERC20TransfersDownloader) GetHeadersInRange(parent context.Context, fro
 	start := time.Now()
 	log.Debug("get erc20 transfers in range", "from", from, "to", to)
 	headers := []*DBHeader{}
+	ctx := context.Background()
 	for _, address := range d.accounts {
-		ctx, cancel := context.WithTimeout(parent, 5*time.Second)
 		outbound, err := d.client.FilterLogs(ctx, ethereum.FilterQuery{
 			FromBlock: from,
 			ToBlock:   to,
 			Topics:    d.outboundTopics(address),
 		})
-		cancel()
 		if err != nil {
 			return nil, err
 		}
-		ctx, cancel = context.WithTimeout(parent, 5*time.Second)
 		inbound, err := d.client.FilterLogs(ctx, ethereum.FilterQuery{
 			FromBlock: from,
 			ToBlock:   to,
 			Topics:    d.inboundTopics(address),
 		})
-		cancel()
 		if err != nil {
 			return nil, err
 		}

services/wallet/transfer/iterative.go

@@ -64,8 +64,8 @@ func (d *IterativeDownloader) Next(parent context.Context) ([]*DBHeader, *big.In
 	if from.Cmp(d.from) == -1 {
 		from = d.from
 	}
-	log.Info("load erc20 transfers in range", "from", from, "to", to, "batchSize", d.batchSize)
 	headers, err := d.downloader.GetHeadersInRange(parent, from, to)
+	log.Info("load erc20 transfers in range", "from", from, "to", to, "batchSize", d.batchSize)
 	if err != nil {
 		log.Error("failed to get transfer in between two bloks", "from", from, "to", to, "error", err)
 		return nil, nil, nil, err