fixing open files! (#466)

JackalLabs · Jul 24, 2024 · b13c69d · b13c69d
2 parents ba7aee0 + 875a0ee
commit b13c69d
Showing 1 changed file with 11 additions and 2 deletions.
diff --git a/x/storage/keeper/grpc_query_active_deals.go b/x/storage/keeper/grpc_query_active_deals.go
@@ -142,9 +142,16 @@ func (k Keeper) OpenFiles(c context.Context, req *types.QueryOpenFiles) (*types.
 	var files []types.UnifiedFile
 	ctx := sdk.UnwrapSDKContext(c)
 
+	reverse := false
+	var limit uint64 = 100
+	if req.Pagination != nil { // HERE IS THE FIX
+		reverse = req.Pagination.Reverse
+		limit = req.Pagination.Limit
+	}
+
 	var i uint64
-	k.IterateFilesByMerkle(ctx, req.Pagination.Reverse, func(_ []byte, val []byte) bool {
-		if i >= req.Pagination.Limit {
+	k.IterateFilesByMerkle(ctx, reverse, func(_ []byte, val []byte) bool {
+		if i >= limit {
 			return true
 		}
 
@@ -155,6 +162,8 @@ func (k Keeper) OpenFiles(c context.Context, req *types.QueryOpenFiles) (*types.
 
 		if len(file.Proofs) < int(file.MaxProofs) {
 			files = append(files, file)
+		} else {
+			return false
 		}
 
 		i++