Refresh data in goroutine

spacemeshos · Aug 29, 2024 · dd2441c · dd2441c
1 parent b29a4ed
commit dd2441c
Show file tree

Hide file tree

Showing 5 changed files with 89 additions and 65 deletions.
diff --git a/api/handler/circulation.go b/api/handler/circulation.go
@@ -34,16 +34,20 @@ func Circulation(c echo.Context) error {
 func CirculationRefresh(c echo.Context) error {
 	cc := c.(*ApiContext)
 
-	circulation, err := cc.StorageClient.GetCirculation(cc.Storage)
-	if err != nil {
-		log.Warning("failed to get circulation: %v", err)
-		return c.NoContent(http.StatusInternalServerError)
-	}
-
-	if err = cc.Cache.Set(context.Background(), "circulation", circulation); err != nil {
-		log.Warning("failed to cache circulation: %v", err)
-		return c.NoContent(http.StatusInternalServerError)
-	}
+	go func() {
+		circulation, err := cc.StorageClient.GetCirculation(cc.Storage)
+		if err != nil {
+			log.Warning("failed to get circulation: %v", err)
+			return
+		}
+
+		if err = cc.Cache.Set(context.Background(), "circulation", circulation); err != nil {
+			log.Warning("failed to cache circulation: %v", err)
+			return
+		}
+
+		log.Info("circulation refreshed")
+	}()
 
 	return c.NoContent(http.StatusOK)
 }
diff --git a/api/handler/epoch.go b/api/handler/epoch.go
@@ -44,16 +44,20 @@ func EpochRefresh(c echo.Context) error {
 		return c.NoContent(http.StatusBadRequest)
 	}
 
-	epochStats, err := cc.StorageClient.GetEpochStats(cc.Storage, int64(id), cc.LayersPerEpoch)
-	if err != nil {
-		log.Warning("failed to get epoch stats: %v", err)
-		return c.NoContent(http.StatusInternalServerError)
-	}
+	go func() {
+		epochStats, err := cc.StorageClient.GetEpochStats(cc.Storage, int64(id), cc.LayersPerEpoch)
+		if err != nil {
+			log.Warning("failed to get epoch stats: %v", err)
+			return
+		}
 
-	if err = cc.Cache.Set(context.Background(), "epochStats"+c.Param("id"), epochStats); err != nil {
-		log.Warning("failed to cache epoch stats: %v", err)
-		return c.NoContent(http.StatusInternalServerError)
-	}
+		if err = cc.Cache.Set(context.Background(), "epochStats"+c.Param("id"), epochStats); err != nil {
+			log.Warning("failed to cache epoch stats: %v", err)
+			return
+		}
+
+		log.Info("epoch %d refreshed", id)
+	}()
 
 	return c.NoContent(http.StatusOK)
 }
@@ -91,16 +95,20 @@ func EpochDecentralRefresh(c echo.Context) error {
 		return c.NoContent(http.StatusBadRequest)
 	}
 
-	epochStats, err := cc.StorageClient.GetEpochDecentralRatio(cc.Storage, int64(id))
-	if err != nil {
-		log.Warning("failed to get epoch stats: %v", err)
-		return c.NoContent(http.StatusInternalServerError)
-	}
+	go func() {
+		epochStats, err := cc.StorageClient.GetEpochDecentralRatio(cc.Storage, int64(id))
+		if err != nil {
+			log.Warning("failed to get epoch stats: %v", err)
+			return
+		}
 
-	if err = cc.Cache.Set(context.Background(), "epochStatsDecentral"+c.Param("id"), epochStats); err != nil {
-		log.Warning("failed to cache epoch stats: %v", err)
-		return c.NoContent(http.StatusInternalServerError)
-	}
+		if err = cc.Cache.Set(context.Background(), "epochStatsDecentral"+c.Param("id"), epochStats); err != nil {
+			log.Warning("failed to cache epoch stats: %v", err)
+			return
+		}
+
+		log.Info("epoch decentral refreshed")
+	}()
 
 	return c.NoContent(http.StatusOK)
 }
diff --git a/api/handler/overview.go b/api/handler/overview.go
@@ -34,16 +34,20 @@ func Overview(c echo.Context) error {
 func OverviewRefresh(c echo.Context) error {
 	cc := c.(*ApiContext)
 
-	overview, err := cc.StorageClient.Overview(cc.Storage)
-	if err != nil {
-		log.Warning("failed to get overview: %v", err)
-		return c.NoContent(http.StatusInternalServerError)
-	}
-
-	if err = cc.Cache.Set(context.Background(), "overview", overview); err != nil {
-		log.Warning("failed to cache overview: %v", err)
-		return c.NoContent(http.StatusInternalServerError)
-	}
+	go func() {
+		overview, err := cc.StorageClient.Overview(cc.Storage)
+		if err != nil {
+			log.Warning("failed to get overview: %v", err)
+			return
+		}
+
+		if err = cc.Cache.Set(context.Background(), "overview", overview); err != nil {
+			log.Warning("failed to cache overview: %v", err)
+			return
+		}
+
+		log.Info("overview refreshed")
+	}()
 
 	return c.NoContent(http.StatusOK)
 }
diff --git a/api/handler/smesher.go b/api/handler/smesher.go
@@ -41,20 +41,24 @@ func Smeshers(c echo.Context) error {
 func SmeshersRefresh(c echo.Context) error {
 	cc := c.(*ApiContext)
 
-	smeshers, err := cc.StorageClient.GetSmeshers(cc.Storage, 1000, 0)
-	if err != nil {
-		log.Warning("failed to get smeshers: %v", err)
-		return c.NoContent(http.StatusInternalServerError)
-	}
+	go func() {
+		smeshers, err := cc.StorageClient.GetSmeshers(cc.Storage, 1000, 0)
+		if err != nil {
+			log.Warning("failed to get smeshers: %v", err)
+			return
+		}
 
-	for i := 0; i < len(smeshers.Smeshers); i += 20 {
-		if err = cc.Cache.Set(context.Background(), fmt.Sprintf("smeshers-%d-%d", 20, i), &storage.SmesherList{
-			Smeshers: smeshers.Smeshers[i : i+20],
-		}); err != nil {
-			log.Warning("failed to cache smeshers: %v", err)
-			return c.NoContent(http.StatusInternalServerError)
+		for i := 0; i < len(smeshers.Smeshers); i += 20 {
+			if err = cc.Cache.Set(context.Background(), fmt.Sprintf("smeshers-%d-%d", 20, i), &storage.SmesherList{
+				Smeshers: smeshers.Smeshers[i : i+20],
+			}); err != nil {
+				log.Warning("failed to cache smeshers: %v", err)
+				return
+			}
 		}
-	}
+
+		log.Info("smeshers refreshed")
+	}()
 
 	return c.NoContent(http.StatusOK)
 }
@@ -97,23 +101,27 @@ func SmeshersByEpochRefresh(c echo.Context) error {
 		return c.NoContent(http.StatusBadRequest)
 	}
 
-	smeshers, err := cc.StorageClient.GetSmeshersByEpoch(cc.Storage, 1000, 0, uint64(epochId))
-	if err != nil {
-		log.Warning("failed to get smeshers: %v", err)
-		return c.NoContent(http.StatusInternalServerError)
-	}
+	go func() {
+		smeshers, err := cc.StorageClient.GetSmeshersByEpoch(cc.Storage, 1000, 0, uint64(epochId))
+		if err != nil {
+			log.Warning("failed to get smeshers: %v", err)
+			return
+		}
 
-	for i := 0; i < len(smeshers.Smeshers); i += 20 {
-		if err = cc.Cache.Set(context.Background(),
-			fmt.Sprintf("smeshers-epoch-%d-%d-%d", epochId, 20, i), &storage.SmesherList{
-				Smeshers: smeshers.Smeshers[i : i+20],
-			}); err != nil {
-			log.Warning("failed to cache smeshers: %v", err)
-			return c.NoContent(http.StatusInternalServerError)
+		for i := 0; i < len(smeshers.Smeshers); i += 20 {
+			if err = cc.Cache.Set(context.Background(),
+				fmt.Sprintf("smeshers-epoch-%d-%d-%d", epochId, 20, i), &storage.SmesherList{
+					Smeshers: smeshers.Smeshers[i : i+20],
+				}); err != nil {
+				log.Warning("failed to cache smeshers: %v", err)
+				return
+			}
 		}
-	}
 
-	return c.JSON(http.StatusOK, smeshers)
+		log.Info("smeshers by epoch %d refreshed", epochId)
+	}()
+
+	return c.NoContent(http.StatusOK)
 }
 
 func Smesher(c echo.Context) error {

diff --git a/api/router/router.go b/api/router/router.go
@@ -23,7 +23,7 @@ func RefreshRouter(e *echo.Echo) {
 	e.Use(echoprometheus.NewMiddleware("spacemesh_explorer_stats_api_refresh"))
 	g := e.Group("/refresh")
 	g.GET("/epoch/:id", handler.EpochRefresh)
-	e.GET("/epoch/:id/decentral", handler.EpochDecentralRefresh)
+	g.GET("/epoch/:id/decentral", handler.EpochDecentralRefresh)
 	g.GET("/overview", handler.OverviewRefresh)
 	g.GET("/smeshers/:epoch", handler.SmeshersByEpochRefresh)
 	g.GET("/smeshers", handler.SmeshersRefresh)