rate limit snapshot creation

tellor-io · Dec 4, 2024 · e21ac0f · e21ac0f
1 parent 3c1aac9
commit e21ac0f
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/x/bridge/keeper/keeper.go b/x/bridge/keeper/keeper.go
@@ -782,7 +782,11 @@ func (k Keeper) GetValidatorDidSignCheckpoint(ctx context.Context, operatorAddr
 func (k Keeper) CreateNewReportSnapshots(ctx context.Context) error {
 	sdkCtx := sdk.UnwrapSDKContext(ctx)
 	blockHeight := sdkCtx.BlockHeight()
-
+	snapshotlimit, err := k.SnapshotLimit.Get(ctx)
+	if err != nil {
+		k.Logger(ctx).Info("Error getting snapshot limit", "error", err)
+		return err
+	}
 	reports := k.oracleKeeper.GetAggregatedReportsByHeight(ctx, uint64(blockHeight))
 	for _, report := range reports {
 		queryId := report.QueryId
@@ -795,6 +799,10 @@ func (k Keeper) CreateNewReportSnapshots(ctx context.Context) error {
 		if err != nil {
 			return err
 		}
+		if snapshotlimit.Limit == 0 {
+			break
+		}
+		snapshotlimit.Limit--
 	}
 	return nil
 }