fix: Distribute Reward happened behind the latest epoch

ai-chen2050 · ai-chen2050 · commit 4cc7b82280da · 2025-04-10T12:15:43.000+08:00
diff --git a/cmd/dispatcher/handler.go b/cmd/dispatcher/handler.go
@@ -114,11 +114,7 @@ func handleRequest(w http.ResponseWriter, r *http.Request, cfg *config.Dispatche
 				interval = 10 // Default to distributing ten epochs
 			}
 
-			if currentEpoch%uint64(interval) == 0 {
-				time.Sleep(1 * time.Second)
-				// Distribute rewards for the current epoch
-				go DistributeRewardsWithRetry(currentEpoch, cfg, 3)
-			}
+			go DistributeRewardsWithRetry(currentEpoch - uint64(interval), cfg, 3)
 		}
 	}
 
diff --git a/config/config.go b/config/config.go
@@ -16,7 +16,7 @@ type DispatcherConfig struct {
 	EthRpcURL               string `json:"eth_rpc_url"`
 	EthChainID              int64  `json:"eth_chain_id"`
 	ValidatorStakingAddress string `json:"validator_staking_address"`
-	RewardDistrInterval     int    `json:"reward_distr_interval"` // Number of epochs between reward distributions
+	RewardDistrInterval     int    `json:"reward_distr_interval"` // Number of epochs behind the current epoch to start reward distributions
 }
 
 // ValidatorConfig holds configuration for the validator service

Original file line number	Diff line number	Diff line change
`@@ -114,11 +114,7 @@ func handleRequest(w http.ResponseWriter, r http.Request, cfg config.Dispatche`
`114`	`114`	`interval = 10 // Default to distributing ten epochs`
`115`	`115`	`}`
`116`	`116`
`117`		`- if currentEpoch%uint64(interval) == 0 {`
`118`		`- time.Sleep(1 * time.Second)`
`119`		`- // Distribute rewards for the current epoch`
`120`		`- go DistributeRewardsWithRetry(currentEpoch, cfg, 3)`
`121`		`- }`
	`117`	`+ go DistributeRewardsWithRetry(currentEpoch - uint64(interval), cfg, 3)`
`122`	`118`	`}`
`123`	`119`	`}`
`124`	`120`
Original file line number	Diff line number	Diff line change
`@@ -16,7 +16,7 @@ type DispatcherConfig struct {`
`16`	`16`	EthRpcURL string `json:"eth_rpc_url"`
`17`	`17`	EthChainID int64 `json:"eth_chain_id"`
`18`	`18`	ValidatorStakingAddress string `json:"validator_staking_address"`
`19`		- RewardDistrInterval int `json:"reward_distr_interval"` // Number of epochs between reward distributions
	`19`	+ RewardDistrInterval int `json:"reward_distr_interval"` // Number of epochs behind the current epoch to start reward distributions
`20`	`20`	`}`
`21`	`21`
`22`	`22`	`// ValidatorConfig holds configuration for the validator service`