From f04bbaca3307592a16ea5de9e3e1bbca50289e44 Mon Sep 17 00:00:00 2001 From: Srinivas Baride Date: Mon, 13 Nov 2023 23:53:41 +0530 Subject: [PATCH] Revert the temporary fix of method QuerySubscriptionsForAccount --- x/subscription/keeper/query_server.go | 12 ++++-------- 1 file changed, 4 insertions(+), 8 deletions(-) diff --git a/x/subscription/keeper/query_server.go b/x/subscription/keeper/query_server.go index 9642046e..c74d0047 100644 --- a/x/subscription/keeper/query_server.go +++ b/x/subscription/keeper/query_server.go @@ -96,23 +96,19 @@ func (q *queryServer) QuerySubscriptionsForAccount(c context.Context, req *types store = prefix.NewStore(q.Store(ctx), types.GetSubscriptionForAccountKeyPrefix(addr)) ) - pagination, err := query.FilteredPaginate(store, req.Pagination, func(key, _ []byte, accumulate bool) (bool, error) { - if !accumulate { - return false, nil - } - + pagination, err := query.Paginate(store, req.Pagination, func(key, _ []byte) error { v, found := q.GetSubscription(ctx, sdk.BigEndianToUint64(key)) if !found { - return false, nil + return fmt.Errorf("subscription for key %X does not exist", key) } item, err := codectypes.NewAnyWithValue(v) if err != nil { - return false, err + return err } items = append(items, item) - return true, nil + return nil }) if err != nil {