ft: update bal-v3 to ethCall from AddrDummy (#1247)

NgoKimPhu · web-flow · commit 0accf98b2d49 · 2026-01-07T13:04:09.000+07:00
diff --git a/pkg/liquidity-source/balancer/v3/eclp/pool_tracker.go b/pkg/liquidity-source/balancer/v3/eclp/pool_tracker.go
@@ -123,7 +123,7 @@ func (t *PoolTracker) queryRPCData(ctx context.Context, p *entity.Pool, staticEx
 		isPoolInRecoveryMode bool
 	)
 
-	req := t.ethrpcClient.R().SetContext(ctx).SetOverrides(overrides)
+	req := t.ethrpcClient.R().SetContext(ctx).SetOverrides(overrides).SetFrom(shared.AddrDummy)
 
 	poolAddress := p.Address
 	paramsPool := []any{common.HexToAddress(poolAddress)}
diff --git a/pkg/liquidity-source/balancer/v3/quant-amm/pool_tracker.go b/pkg/liquidity-source/balancer/v3/quant-amm/pool_tracker.go
@@ -142,7 +142,7 @@ func (t *PoolTracker) queryRPCData(ctx context.Context, p *entity.Pool, staticEx
 		isVaultPaused bool
 	)
 
-	req := t.ethrpcClient.R().SetContext(ctx).SetOverrides(overrides)
+	req := t.ethrpcClient.R().SetContext(ctx).SetOverrides(overrides).SetFrom(shared.AddrDummy)
 
 	poolAddress := p.Address
 	paramsPool := []any{common.HexToAddress(poolAddress)}
diff --git a/pkg/liquidity-source/balancer/v3/reclamm/pool_tracker.go b/pkg/liquidity-source/balancer/v3/reclamm/pool_tracker.go
@@ -131,7 +131,7 @@ func (t *PoolTracker) queryRPCData(ctx context.Context, p *entity.Pool, staticEx
 		isPoolInRecoveryMode bool
 	)
 
-	req := t.ethrpcClient.R().SetContext(ctx).SetOverrides(overrides)
+	req := t.ethrpcClient.R().SetContext(ctx).SetOverrides(overrides).SetFrom(shared.AddrDummy)
 
 	poolAddress := p.Address
 	paramsPool := []any{common.HexToAddress(poolAddress)}
diff --git a/pkg/liquidity-source/balancer/v3/shared/constant.go b/pkg/liquidity-source/balancer/v3/shared/constant.go
@@ -31,6 +31,8 @@ var (
 		"":         common.HexToAddress("0xbA1333333333a1BA1108E8412f11850A5C319bA9"), // default
 		"coinhane": common.HexToAddress("0xb61cb1E8EF4BB1b74bB858B8B60d82d79488F13D"),
 	}
+
+	AddrDummy = common.HexToAddress("0x1371783000000000000000000000000001371760")
 )
 
 const (
diff --git a/pkg/liquidity-source/balancer/v3/stable/pool_tracker.go b/pkg/liquidity-source/balancer/v3/stable/pool_tracker.go
@@ -130,7 +130,7 @@ func (t *PoolTracker) queryRPCData(ctx context.Context, p *entity.Pool, staticEx
 		isPoolInRecoveryMode bool
 	)
 
-	req := t.ethrpcClient.R().SetContext(ctx).SetOverrides(overrides)
+	req := t.ethrpcClient.R().SetContext(ctx).SetOverrides(overrides).SetFrom(shared.AddrDummy)
 
 	poolAddress := p.Address
 	paramsPool := []any{common.HexToAddress(poolAddress)}
diff --git a/pkg/liquidity-source/balancer/v3/weighted/pool_tracker.go b/pkg/liquidity-source/balancer/v3/weighted/pool_tracker.go
@@ -123,7 +123,7 @@ func (t *PoolTracker) queryRPCData(ctx context.Context, p *entity.Pool, staticEx
 		isPoolInRecoveryMode bool
 	)
 
-	req := t.ethrpcClient.R().SetContext(ctx).SetOverrides(overrides)
+	req := t.ethrpcClient.R().SetContext(ctx).SetOverrides(overrides).SetFrom(shared.AddrDummy)
 
 	poolAddress := p.Address
 	paramsPool := []any{common.HexToAddress(poolAddress)}

Original file line number	Diff line number	Diff line change
`@@ -123,7 +123,7 @@ func (t PoolTracker) queryRPCData(ctx context.Context, p entity.Pool, staticEx`
`123`	`123`	`isPoolInRecoveryMode bool`
`124`	`124`	`)`
`125`	`125`
`126`		`- req := t.ethrpcClient.R().SetContext(ctx).SetOverrides(overrides)`
	`126`	`+ req := t.ethrpcClient.R().SetContext(ctx).SetOverrides(overrides).SetFrom(shared.AddrDummy)`
`127`	`127`
`128`	`128`	`poolAddress := p.Address`
`129`	`129`	`paramsPool := []any{common.HexToAddress(poolAddress)}`
Original file line number	Diff line number	Diff line change
`@@ -142,7 +142,7 @@ func (t PoolTracker) queryRPCData(ctx context.Context, p entity.Pool, staticEx`
`142`	`142`	`isVaultPaused bool`
`143`	`143`	`)`
`144`	`144`
`145`		`- req := t.ethrpcClient.R().SetContext(ctx).SetOverrides(overrides)`
	`145`	`+ req := t.ethrpcClient.R().SetContext(ctx).SetOverrides(overrides).SetFrom(shared.AddrDummy)`
`146`	`146`
`147`	`147`	`poolAddress := p.Address`
`148`	`148`	`paramsPool := []any{common.HexToAddress(poolAddress)}`
Original file line number	Diff line number	Diff line change
`@@ -131,7 +131,7 @@ func (t PoolTracker) queryRPCData(ctx context.Context, p entity.Pool, staticEx`
`131`	`131`	`isPoolInRecoveryMode bool`
`132`	`132`	`)`
`133`	`133`
`134`		`- req := t.ethrpcClient.R().SetContext(ctx).SetOverrides(overrides)`
	`134`	`+ req := t.ethrpcClient.R().SetContext(ctx).SetOverrides(overrides).SetFrom(shared.AddrDummy)`
`135`	`135`
`136`	`136`	`poolAddress := p.Address`
`137`	`137`	`paramsPool := []any{common.HexToAddress(poolAddress)}`
Original file line number	Diff line number	Diff line change
`@@ -31,6 +31,8 @@ var (`
`31`	`31`	`"": common.HexToAddress("0xbA1333333333a1BA1108E8412f11850A5C319bA9"), // default`
`32`	`32`	`"coinhane": common.HexToAddress("0xb61cb1E8EF4BB1b74bB858B8B60d82d79488F13D"),`
`33`	`33`	`}`
	`34`	`+`
	`35`	`+ AddrDummy = common.HexToAddress("0x1371783000000000000000000000000001371760")`
`34`	`36`	`)`
`35`	`37`
`36`	`38`	`const (`
Original file line number	Diff line number	Diff line change
`@@ -130,7 +130,7 @@ func (t PoolTracker) queryRPCData(ctx context.Context, p entity.Pool, staticEx`
`130`	`130`	`isPoolInRecoveryMode bool`
`131`	`131`	`)`
`132`	`132`
`133`		`- req := t.ethrpcClient.R().SetContext(ctx).SetOverrides(overrides)`
	`133`	`+ req := t.ethrpcClient.R().SetContext(ctx).SetOverrides(overrides).SetFrom(shared.AddrDummy)`
`134`	`134`
`135`	`135`	`poolAddress := p.Address`
`136`	`136`	`paramsPool := []any{common.HexToAddress(poolAddress)}`