Rollup stats tvl;

cmd/api/handler/rollup.go

@@ -329,7 +329,7 @@ func (handler RollupHandler) GetBlobs(c echo.Context) error {
 type rollupStatsRequest struct {
 	Id         uint64 `example:"1"          param:"id"        swaggertype:"integer" validate:"required,min=1"`
 	Timeframe  string `example:"hour"       param:"timeframe" swaggertype:"string"  validate:"required,oneof=hour day month"`
-	SeriesName string `example:"tps"        param:"name"      swaggertype:"string"  validate:"required,oneof=blobs_count size size_per_blob fee"`
+	SeriesName string `example:"tps"        param:"name"      swaggertype:"string"  validate:"required,oneof=blobs_count size size_per_blob fee tvl"`
 	From       int64  `example:"1692892095" query:"from"      swaggertype:"integer" validate:"omitempty,min=1"`
 	To         int64  `example:"1692892095" query:"to"        swaggertype:"integer" validate:"omitempty,min=1"`
 }
@@ -341,7 +341,7 @@ type rollupStatsRequest struct {
 //	@Tags			rollup
 //	@ID				get-rollup-stats
 //	@Param			id			path	integer	true	"Internal identity"				mininum(1)
-//	@Param			name		path	string	true	"Series name"					Enums(blobs_count, size, size_per_blob, fee)
+//	@Param			name		path	string	true	"Series name"					Enums(blobs_count, size, size_per_blob, fee, tvl)
 //	@Param			timeframe	path	string	true	"Timeframe"						Enums(hour, day, month)
 //	@Param			from		query	integer	false	"Time from in unix timestamp"	mininum(1)
 //	@Param			to			query	integer	false	"Time to in unix timestamp"		mininum(1)
@@ -356,13 +356,24 @@ func (handler RollupHandler) Stats(c echo.Context) error {
 		return badRequestError(c, err)
 	}
 
-	histogram, err := handler.rollups.Series(
-		c.Request().Context(),
-		req.Id,
-		req.Timeframe,
-		req.SeriesName,
-		storage.NewSeriesRequest(req.From, req.To),
-	)
+	var histogram []storage.HistogramItem
+	if req.SeriesName == "tvl" {
+		histogram, err = handler.rollups.Tvl(
+			c.Request().Context(),
+			req.Id,
+			req.Timeframe,
+			storage.NewSeriesRequest(req.From, req.To),
+		)
+	} else {
+		histogram, err = handler.rollups.Series(
+			c.Request().Context(),
+			req.Id,
+			req.Timeframe,
+			req.SeriesName,
+			storage.NewSeriesRequest(req.From, req.To),
+		)
+	}
+
 	if err != nil {
 		return handleError(c, err, handler.rollups)
 	}

database/views/25_rollup_tvl_by_month.sql

@@ -0,0 +1,10 @@
+CREATE MATERIALIZED VIEW IF NOT EXISTS rollup_tvl_by_month
+WITH (timescaledb.continuous, timescaledb.materialized_only=false) AS
+    select
+        time_bucket('1 month'::interval, logs.time) AS time,
+        logs.rollup_id as rollup_id,
+        sum(logs.value) as value
+    from tvl as logs
+    group by 1, 2
+    with no data;
+CALL add_view_refresh_job('rollup_tvl_by_month', NULL, INTERVAL '1 hour');

internal/storage/postgres/rollup.go

@@ -220,6 +220,36 @@ func (r *Rollup) ById(ctx context.Context, rollupId uint64) (rollup storage.Roll
 	return
 }
 
+func (r *Rollup) Tvl(ctx context.Context, rollupId uint64, timeframe string, req storage.SeriesRequest) (items []storage.HistogramItem, err error) {
+	query := r.DB().NewSelect().
+		ColumnExpr("value, time as bucket").
+		Where("rollup_id = ?", rollupId).
+		Limit(100).
+		Order("time desc")
+
+	switch timeframe {
+	case "hour":
+		return nil, errors.Errorf("unavailable data for this timeframe: %s", timeframe)
+	case "day":
+		query = query.Table("tvl")
+	case "month":
+		query = query.Table(storage.ViewRollupTvlByMonth)
+	default:
+		return nil, errors.Errorf("invalid timeframe: %s", timeframe)
+	}
+
+	if !req.From.IsZero() {
+		query = query.Where("time >= ?", req.From)
+	}
+	if !req.To.IsZero() {
+		query = query.Where("time < ?", req.To)
+	}
+
+	err = query.Scan(ctx, &items)
+
+	return
+}
+
 func (r *Rollup) Distribution(ctx context.Context, rollupId uint64, series, groupBy string) (items []storage.DistributionItem, err error) {
 	providers, err := r.Providers(ctx, rollupId)
 	if err != nil {

internal/storage/postgres/tvl_test.go

@@ -1,3 +1,6 @@
+// SPDX-FileCopyrightText: 2024 PK Lab AG <[email protected]>
+// SPDX-License-Identifier: MIT
+
 package postgres
 
 import (

internal/storage/rollup.go

@@ -39,6 +39,7 @@ type IRollup interface {
 	ById(ctx context.Context, rollupId uint64) (RollupWithStats, error)
 	Series(ctx context.Context, rollupId uint64, timeframe, column string, req SeriesRequest) (items []HistogramItem, err error)
 	AllSeries(ctx context.Context) ([]RollupHistogramItem, error)
+	Tvl(ctx context.Context, rollupId uint64, timeframe string, req SeriesRequest) (items []HistogramItem, err error)
 	Count(ctx context.Context) (int64, error)
 	Distribution(ctx context.Context, rollupId uint64, series, groupBy string) (items []DistributionItem, err error)
 	BySlug(ctx context.Context, slug string) (RollupWithStats, error)

internal/storage/views.go

@@ -24,4 +24,5 @@ const (
 	ViewRollupStatsByHour     = "rollup_stats_by_hour"
 	ViewRollupStatsByDay      = "rollup_stats_by_day"
 	ViewRollupStatsByMonth    = "rollup_stats_by_month"
+	ViewRollupTvlByMonth      = "rollup_tvl_by_month"
 )