chore: added subscription limits check

rpc/client/client.go

@@ -3,10 +3,13 @@
 import (
 	"context"
 	"errors"
+
 	"fmt"
 	"sort"
 	"time"
 
+	sdkerrors "github.com/cosmos/cosmos-sdk/types/errors"
+
 	rconfig "github.com/dymensionxyz/dymint/config"
 	abciconv "github.com/dymensionxyz/dymint/conv/abci"
 	"github.com/dymensionxyz/dymint/mempool"
@@ -97,10 +100,8 @@
 	// This code is a local client, so we can assume that subscriber is ""
 	subscriber := "" //ctx.RemoteAddr()
 
-	if c.EventBus.NumClients() >= c.config.MaxSubscriptionClients {
-		return nil, fmt.Errorf("max_subscription_clients %d reached", c.config.MaxSubscriptionClients)
-	} else if c.EventBus.NumClientSubscriptions(subscriber) >= c.config.MaxSubscriptionsPerClient {
-		return nil, fmt.Errorf("max_subscriptions_per_client %d reached", c.config.MaxSubscriptionsPerClient)
+	if err := c.IsSubscriptionAllowed(subscriber); err != nil {
+		return nil, sdkerrors.Wrap(err, "subscription not allowed")
 	}
 
 	// Subscribe to tx being committed in block.
@@ -878,6 +879,16 @@
 	return heightValue
 }
 
+func (c *Client) IsSubscriptionAllowed(subscriber string) error {
+	if c.EventBus.NumClients() >= c.config.MaxSubscriptionClients {
+		return fmt.Errorf("max_subscription_clients %d reached", c.config.MaxSubscriptionClients)
+	} else if c.EventBus.NumClientSubscriptions(subscriber) >= c.config.MaxSubscriptionsPerClient {
+		return fmt.Errorf("max_subscriptions_per_client %d reached", c.config.MaxSubscriptionsPerClient)
+	}
+
+	return nil
+}
+
 func validatePerPage(perPagePtr *int) int {
 	if perPagePtr == nil { // no per_page parameter
 		return defaultPerPage

rpc/json/service.go

@@ -9,6 +9,7 @@
 	"strconv"
 	"time"
 
+	"cosmossdk.io/errors"
 	"github.com/gorilla/rpc/v2/json2"
 	"github.com/tendermint/tendermint/libs/pubsub"
 	tmquery "github.com/tendermint/tendermint/libs/pubsub/query"
@@ -91,7 +92,9 @@
 func (s *service) Subscribe(req *http.Request, args *subscribeArgs, wsConn *wsConn, subscriptionID []byte) (*ctypes.ResultSubscribe, error) {
 	addr := req.RemoteAddr
 
-	// TODO(tzdybal): pass config and check subscriptions limits
+	if err := s.client.IsSubscriptionAllowed(addr); err != nil {
+		return nil, errors.Wrap(err, "subscription not allowed")
+	}
 
 	q, err := tmquery.New(args.Query)
 	if err != nil {