feat: integrate frxusd

Author: minhnhathoang

pkg/liquidity-source/erc4626/pool_simulator.go

@@ -159,10 +159,12 @@ func (s *PoolSimulator) UpdateBalance(params pool.UpdateBalanceParams) {
 	}
 }
 
-func (s *PoolSimulator) GetMetaInfo(_, _ string) any {
+func (s *PoolSimulator) GetMetaInfo(tokenIn, tokenOut string) any {
+	isDeposit, _ := s.getSwapType(tokenIn, tokenOut)
 	return Meta{
 		BlockNumber:   s.Info.BlockNumber,
 		IsNativeAsset: s.IsNativeAsset,
+		IsDeposit:     isDeposit == Deposit,
 	}
 }
 

pkg/liquidity-source/erc4626/pool_tracker.go

@@ -74,7 +74,7 @@ func (t *PoolTracker) getNewPoolState(
 
 	vaultAddr := p.Tokens[0].Address
 	vaultCfg := t.cfg.Vaults[vaultAddr]
-	_, state, err := fetchAssetAndState(ctx, t.ethrpcClient, vaultAddr, vaultCfg, false, overrides)
+	_, state, err := FetchAssetAndState(ctx, t.ethrpcClient, vaultAddr, vaultCfg, false, overrides)
 	if err != nil {
 		lg.WithFields(logger.Fields{
 			"error": err,
@@ -83,10 +83,10 @@ func (t *PoolTracker) getNewPoolState(
 		return p, err
 	}
 
-	return p, updateEntityState(&p, vaultCfg, state)
+	return p, UpdateEntityState(&p, vaultCfg, state)
 }
 
-func updateEntityState(p *entity.Pool, vaultCfg VaultCfg, state *PoolState) error {
+func UpdateEntityState(p *entity.Pool, vaultCfg VaultCfg, state *PoolState) error {
 	extraBytes, err := json.Marshal(Extra{
 		Gas:          Gas(vaultCfg.Gas),
 		SwapTypes:    vaultCfg.SwapTypes,
@@ -108,7 +108,7 @@ func updateEntityState(p *entity.Pool, vaultCfg VaultCfg, state *PoolState) erro
 	return nil
 }
 
-func fetchAssetAndState(ctx context.Context, ethrpcClient *ethrpc.Client, vaultAddr string, vaultCfg VaultCfg,
+func FetchAssetAndState(ctx context.Context, ethrpcClient *ethrpc.Client, vaultAddr string, vaultCfg VaultCfg,
 	fetchAsset bool, overrides map[common.Address]gethclient.OverrideAccount) (common.Address, *PoolState, error) {
 	var (
 		assetToken common.Address

pkg/liquidity-source/erc4626/pools_list_updater.go

@@ -70,11 +70,11 @@ func (u *PoolsListUpdater) GetNewPools(ctx context.Context, metadataBytes []byte
 }
 
 func (u *PoolsListUpdater) getNewPool(ctx context.Context, vaultAddr string, vaultCfg VaultCfg) (*entity.Pool, error) {
-	assetToken, state, err := fetchAssetAndState(ctx, u.ethrpcClient, vaultAddr, vaultCfg, true, nil)
+	assetToken, state, err := FetchAssetAndState(ctx, u.ethrpcClient, vaultAddr, vaultCfg, true, nil)
 	if err != nil {
 		u.logger.WithFields(logger.Fields{
 			"error": err,
-		}).Error("failed to fetchAssetAndState")
+		}).Error("failed to FetchAssetAndState")
 		return nil, err
 	}
 
@@ -96,5 +96,5 @@ func (u *PoolsListUpdater) getNewPool(ctx context.Context, vaultAddr string, vau
 		StaticExtra: string(staticExtraBytes),
 	}
 
-	return p, updateEntityState(p, vaultCfg, state)
+	return p, UpdateEntityState(p, vaultCfg, state)
 }

pkg/liquidity-source/erc4626/type.go

@@ -36,8 +36,9 @@ type (
 	}
 
 	Meta struct {
-		BlockNumber   uint64 `json:"blockNumber"`
-		IsNativeAsset bool   `json:"isNativeAsset"`
+		BlockNumber   uint64 `json:"bN"`
+		IsNativeAsset bool   `json:"isNativeAsset,omitempty"`
+		IsDeposit     bool   `json:"isDeposit,omitempty"`
 	}
 
 	PoolState struct {