feat: returns tokens even when error

protocol/communities/manager.go

@@ -1593,7 +1593,7 @@ func (m *Manager) getOwnedERC721Tokens(walletAddresses []gethcommon.Address, tok
 	ownedERC721Tokens := make(map[uint64]map[string][]opensea.Asset)
 
 	for chainID, erc721Tokens := range tokenRequirements {
-		client, err := opensea.NewOpenseaClient(chainID, m.walletConfig.OpenseaAPIKey)
+		client, err := opensea.NewOpenseaClient(chainID, m.walletConfig.OpenseaAPIKey, nil)
 		if err != nil {
 			return nil, err
 		}

rpc/chain/client.go

@@ -4,10 +4,7 @@ import (
 	"context"
 	"fmt"
 	"math/big"
-<<<<<<< HEAD
 	"strings"
-=======
->>>>>>> 6fcba6e30 (feat: add buffer for status event)
 	"sync"
 	"time"
 
@@ -175,13 +172,10 @@ func (c *ClientWithFallback) makeCallNoReturn(main func() error, fallback func()
 
 		err = fallback()
 		if err != nil {
-<<<<<<< HEAD
 			if isVMError(err) {
 				resultChan <- CommandResult{vmError: err}
 				return nil
 			}
-=======
->>>>>>> fdaa1ce1b (fix: set is connected for chain without fallback)
 			c.setIsConnected(false)
 			return err
 		}
@@ -218,7 +212,9 @@ func (c *ClientWithFallback) makeCallSingleReturn(main func() (any, error), fall
 		return nil
 	}, func(err error) error {
 		if c.fallback == nil {
-			c.setIsConnected(false)
+			if toggleIsConnected {
+				c.setIsConnected(false)
+			}
 			return err
 		}
 

services/wallet/reader.go

@@ -204,6 +204,7 @@ func (r *Reader) GetWalletToken(ctx context.Context, addresses []common.Address)
 	group.Add(func(parent context.Context) error {
 		balances, err = r.tokenManager.GetBalancesByChain(ctx, clients, addresses, tokenAddresses)
 		if err != nil {
+			log.Info("tokenManager.GetBalancesByChain err", err)
 			return err
 		}
 		return nil
@@ -215,10 +216,6 @@ func (r *Reader) GetWalletToken(ctx context.Context, addresses []common.Address)
 		return nil, ctx.Err()
 	}
 	err = group.Error()
-	if err != nil {
-		return nil, err
-	}
-
 	result := make(map[common.Address][]Token)
 	for _, address := range addresses {
 		for symbol, tokens := range getTokenBySymbols(allTokens) {
@@ -235,7 +232,7 @@ func (r *Reader) GetWalletToken(ctx context.Context, addresses []common.Address)
 				}
 				hasError := false
 				if client, ok := clients[token.ChainID]; ok {
-					hasError = !client.IsConnected
+					hasError = err != nil || !client.IsConnected
 				}
 				balancesPerChain[token.ChainID] = ChainBalance{
 					Balance:  balance,

services/wallet/thirdparty/opensea/client.go

@@ -245,11 +245,6 @@ func NewOpenseaClient(chainID uint64, apiKey string, feed *event.Feed) (*Client,
 	if err != nil {
 		return nil, err
 	}
-	if client, ok := OpenseaClientInstances[chainID]; ok {
-		if client.apiKey == tmpAPIKey {
-			return client, nil
-		}
-	}
 
 	openseaClient := &Client{
 		client:        OpenseaHTTPClient,
@@ -272,12 +267,14 @@ func (o *Client) setIsConnected(value bool) {
 		if value {
 			message = "up"
 		}
-		o.feed.Send(walletevent.Event{
+		if o.feed != nil {
-			Type:     EventCollectibleStatusChanged,
+			o.feed.Send(walletevent.Event{
-			Accounts: []common.Address{},
+				Type:     EventCollectibleStatusChanged,
-			Message:  message,
+				Accounts: []common.Address{},
-			At:       time.Now().Unix(),
+				Message:  message,
-		})
+				At:       time.Now().Unix(),
+			})
+		}
 	}
 	o.IsConnected = value
 }

services/wallet/token/token.go

@@ -677,7 +677,6 @@ func (tm *Manager) GetBalancesByChain(parent context.Context, clients map[uint64
 					Context: ctx,
 				}, accounts)
 				if err != nil {
-
 					log.Error("can't fetch chain balance", err)
 					return nil
 				}
@@ -702,7 +701,6 @@ func (tm *Manager) GetBalancesByChain(parent context.Context, clients map[uint64
 						Context: ctx,
 					}, account, chunk)
 					if err != nil {
-
 						log.Error("can't fetch erc20 token balance", "account", account, "error", err)
 						return nil
 					}