fix(staking): replace total stake amount history api (#47)

Author: gezerui0124

pkg/server/handler.go

@@ -298,7 +298,7 @@ func (s *Server) TotalStakeHandler() gin.HandlerFunc {
 	return func(c *gin.Context) {
 		logger := log.With().Str("handler", "TotalStakeHandler").Logger()
 
-		row, err := db.GetLatestCLTotalStake(s.dbOperator)
+		row, err := db.GetLatestCLTotalStakeHist(s.dbOperator)
 		if err != nil {
 			logger.Error().Err(err).Msg("failed to get latest cl total stake")
 			c.JSON(http.StatusOK, Response{
@@ -308,7 +308,7 @@ func (s *Server) TotalStakeHandler() gin.HandlerFunc {
 			return
 		}
 
-		indexPointTime, err := db.GetIndexPointTime(s.dbOperator, "cl_total_stake")
+		indexPointTime, err := db.GetIndexPointTime(s.dbOperator, "cl_staking_event")
 		if err != nil {
 			logger.Error().Err(err).Msg("failed to get index point time")
 			c.JSON(http.StatusOK, Response{
@@ -359,98 +359,6 @@ func (s *Server) TotalStakeHistoryHandler() gin.HandlerFunc {
 			return
 		}
 
-		var stakeHistory []StakeAmountData
-		// Get the last amount before the period
-		if Interval(interval) != IntervalAllTime {
-			row, err := db.GetLatestCLTotalStakeBefore(s.dbOperator, startTime.Unix())
-			if err != nil {
-				logger.Error().Err(err).Msg("failed to get latest cl total stake before period")
-				c.JSON(http.StatusOK, Response{
-					Code:  http.StatusInternalServerError,
-					Error: ErrInternalDataServiceError.Error(),
-				})
-				return
-			}
-			stakeHistory = append(stakeHistory, StakeAmountData{
-				TotalStakeAmount: row.TotalStakeAmount,
-				UpdateAt:         row.UpdateAt,
-			})
-		}
-		// Get all amount updates after the start time
-		if Interval(interval) == IntervalAllTime {
-			rows, err := db.GetCLTotalStakes(s.dbOperator)
-			if err != nil {
-				logger.Error().Err(err).Msg("failed to get all cl total stakes")
-				c.JSON(http.StatusOK, Response{
-					Code:  http.StatusInternalServerError,
-					Error: ErrInternalDataServiceError.Error(),
-				})
-				return
-			}
-			for _, row := range rows {
-				stakeHistory = append(stakeHistory, StakeAmountData{
-					TotalStakeAmount: row.TotalStakeAmount,
-					UpdateAt:         row.UpdateAt,
-				})
-			}
-		} else {
-			rows, err := db.GetCLTotalStakesAfter(s.dbOperator, startTime.Unix())
-			if err != nil {
-				logger.Error().Err(err).Msg("failed to get cl total stakes within period")
-				c.JSON(http.StatusOK, Response{
-					Code:  http.StatusInternalServerError,
-					Error: ErrInternalDataServiceError.Error(),
-				})
-				return
-			}
-			for _, row := range rows {
-				stakeHistory = append(stakeHistory, StakeAmountData{
-					TotalStakeAmount: row.TotalStakeAmount,
-					UpdateAt:         row.UpdateAt,
-				})
-			}
-		}
-
-		c.JSON(http.StatusOK, Response{
-			Code: http.StatusOK,
-			Msg: map[string]any{
-				"total_stake_amount_history": stakeHistory,
-			},
-		})
-	}
-}
-
-func (s *Server) TotalStakeHistoryHandlerV2() gin.HandlerFunc {
-	return func(c *gin.Context) {
-		logger := log.With().Str("handler", "TotalStakeHistoryHandlerV2").Logger()
-
-		interval := c.Query("interval")
-		if interval == "" {
-			interval = string(IntervalOneDay)
-		}
-
-		var (
-			startTime   time.Time
-			currentTime = time.Now()
-		)
-		switch Interval(interval) {
-		case IntervalOneDay:
-			startTime = currentTime.AddDate(0, 0, -1)
-		case IntervalSevenDays:
-			startTime = currentTime.AddDate(0, 0, -7)
-		case IntervalThirtyDays:
-			startTime = currentTime.AddDate(0, 0, -30)
-		case IntervalAllTime:
-			// no filter needed
-		default:
-			logger.Error().Str("interval", interval).Msg("invalid interval")
-			c.JSON(http.StatusOK, Response{
-				Code:  http.StatusBadRequest,
-				Error: ErrInvalidParameter.Error(),
-			})
-			return
-		}
-
 		var stakeHistory []StakeAmountData
 		// Get the last amount before the period
 		if Interval(interval) != IntervalAllTime {

pkg/server/server.go

@@ -191,7 +191,6 @@ func (s *Server) setupStakingAPI() {
 		apiGroup.GET("/rewards/:evm_address", s.RewardsHandler())
 		apiGroup.GET("/staking/total_stake", s.TotalStakeHandler())
 		apiGroup.GET("/staking/total_stake/history", s.TotalStakeHistoryHandler())
-		apiGroup.GET("/staking/total_stake/history/v2", s.TotalStakeHistoryHandlerV2())
 		// Proxy to Story API.
 		apiGroup.GET("/staking/params", s.StakingParamsHandler())