feat: add syrupUSDC and syrupUSDT (#1141)

* Add custom exchange name

* Add custom approval address for erc4626

Author: minhnhathoang

pkg/liquidity-source/erc4626/config.go

@@ -6,8 +6,9 @@ type Config struct {
 }
 
 type VaultCfg struct {
-	Gas       GasCfg   `json:"gas"`
-	SwapTypes SwapType `json:"swapTypes"`
+	Gas       GasCfg         `json:"gas"`
+	SwapTypes SwapType       `json:"swapTypes"`
+	Meta      map[string]any `json:"meta,omitempty"`
 }
 
 type GasCfg struct {

pkg/liquidity-source/erc4626/constant.go

@@ -13,6 +13,8 @@ import (
 const (
 	DexType = "erc4626"
 
+	ExchangeMetaKey = "exchange"
+
 	erc4626MethodAsset          = "asset"
 	erc4626MethodMaxDeposit     = "maxDeposit"
 	erc4626MethodMaxRedeem      = "maxRedeem"

pkg/liquidity-source/erc4626/pool_simulator.go

@@ -3,6 +3,7 @@ package erc4626
 import (
 	"math/big"
 
+	"github.com/KyberNetwork/kyberswap-dex-lib/pkg/valueobject"
 	"github.com/goccy/go-json"
 	"github.com/holiman/uint256"
 	"github.com/pkg/errors"
@@ -151,7 +152,10 @@ func (s *PoolSimulator) UpdateBalance(params pool.UpdateBalanceParams) {
 }
 
 func (s *PoolSimulator) GetMetaInfo(_, _ string) interface{} {
-	return Meta{BlockNumber: s.Info.BlockNumber}
+	return MetaInfo{
+		Meta:        s.Meta,
+		BlockNumber: s.Info.BlockNumber,
+	}
 }
 
 func (s *PoolSimulator) CanSwapTo(address string) []string {
@@ -200,3 +204,12 @@ func (s *PoolSimulator) getSwapType(tokenIn string, tokenOut string) (SwapType,
 
 	return swapType, nil
 }
+
+func (s *PoolSimulator) GetApprovalAddress(_, _ string) string {
+	switch s.GetExchange() {
+	case valueobject.ExchangeMapleSyrup:
+		return s.Meta["router"].(string)
+	default:
+		return s.GetAddress()
+	}
+}

pkg/liquidity-source/erc4626/pool_tracker.go

@@ -94,6 +94,7 @@ func updateEntityState(p *entity.Pool, vaultCfg VaultCfg, state *PoolState) erro
 		MaxRedeem:    uint256.MustFromBig(state.MaxRedeem),
 		DepositRates: lo.Map(state.DepositRates, func(item *big.Int, _ int) *uint256.Int { return uint256.MustFromBig(item) }),
 		RedeemRates:  lo.Map(state.RedeemRates, func(item *big.Int, _ int) *uint256.Int { return uint256.MustFromBig(item) }),
+		Meta:         vaultCfg.Meta,
 	})
 	if err != nil {
 		return errors.WithMessage(err, "json.Marshal extra")

pkg/liquidity-source/erc4626/pools_list_updater.go

@@ -76,14 +76,22 @@ func (u *PoolsListUpdater) getNewPool(ctx context.Context, vaultAddr string, vau
 		return nil, err
 	}
 
+	exchange := u.cfg.DexId
+	if vaultCfg.Meta != nil {
+		if exchangeStr, ok := vaultCfg.Meta[ExchangeMetaKey].(string); ok && exchangeStr != "" {
+			exchange = exchangeStr
+		}
+	}
+
 	p := &entity.Pool{
 		Address:  strings.ToLower(vaultAddr),
-		Exchange: u.cfg.DexId,
+		Exchange: exchange,
 		Type:     DexType,
 		Tokens: []*entity.PoolToken{
 			{Address: strings.ToLower(vaultAddr), Swappable: true},
 			{Address: hexutil.Encode(assetToken[:]), Swappable: true},
 		},
 	}
+
 	return p, updateEntityState(p, vaultCfg, state)
 }

pkg/liquidity-source/erc4626/type.go

@@ -28,10 +28,12 @@ type (
 		MaxRedeem    *uint256.Int   `json:"mR,omitempty"`
 		DepositRates []*uint256.Int `json:"dR,omitempty"`
 		RedeemRates  []*uint256.Int `json:"rR,omitempty"`
+		Meta         map[string]any `json:"meta,omitempty"`
 	}
 
-	Meta struct {
-		BlockNumber uint64 `json:"blockNumber"`
+	MetaInfo struct {
+		Meta        map[string]any `json:"meta,omitempty"`
+		BlockNumber uint64         `json:"blockNumber"`
 	}
 
 	PoolState struct {

pkg/valueobject/exchange.go

@@ -232,6 +232,7 @@ const (
 	ExchangeLynex                      = "lynex"
 	ExchangeLynexV1                    = "lynex-v1"
 	ExchangeLyve                       = "lyve"
+	ExchangeMapleSyrup                 = "maple-syrup"
 	ExchangeMDex                       = "mdex"
 	ExchangeMMF                        = "mmf"
 	ExchangeMMFV3                      = "mmf-v3"
@@ -713,6 +714,7 @@ var AMMSourceSet = map[Exchange]struct{}{
 	ExchangeLynex:                      {},
 	ExchangeLynexV1:                    {},
 	ExchangeLyve:                       {},
+	ExchangeMapleSyrup:                 {},
 	ExchangeMDex:                       {},
 	ExchangeMMF:                        {},
 	ExchangeMMFV3:                      {},