fix(api): add ingest limits to connect push requests (#4586)

* fix(api): add ingest limits to connect push requests

* Revert "fix(api): add ingest limits to connect push requests"

This reverts commit ba4c2a6.

* fix(api): add ingest limits to connect push requests

* fmt

Author: korniltsev-grafanista

pkg/api/connect_options.go

@@ -4,8 +4,10 @@ import (
 	"connectrpc.com/connect"
 
 	connectapi "github.com/grafana/pyroscope/pkg/api/connect"
+	"github.com/grafana/pyroscope/pkg/tenant"
 	"github.com/grafana/pyroscope/pkg/util"
 	"github.com/grafana/pyroscope/pkg/util/delayhandler"
+	"github.com/grafana/pyroscope/pkg/validation"
 )
 
 func connectInterceptorRecovery() connect.HandlerOption {
@@ -32,8 +34,15 @@ func (a *API) connectOptionsAuthRecovery() []connect.HandlerOption {
 	return append(connectapi.DefaultHandlerOptions(), a.connectInterceptorAuth(), connectInterceptorRecovery())
 }
 
-func (a *API) connectOptionsAuthDelayRecovery(limits delayhandler.Limits) []connect.HandlerOption {
-	return append(connectapi.DefaultHandlerOptions(), a.connectInterceptorAuth(), a.connectInterceptorDelay(limits), connectInterceptorRecovery())
+func (a *API) connectOptionsAuthDelayRecovery(limits *validation.Overrides) []connect.HandlerOption {
+	// no per tenant overrides implemented for connect requests
+	messageLimit := int(limits.IngestionBodyLimitBytes(tenant.DefaultTenantID))
+	return append(connectapi.DefaultHandlerOptions(),
+		a.connectInterceptorAuth(),
+		connect.WithReadMaxBytes(messageLimit),
+		a.connectInterceptorDelay(limits),
+		connectInterceptorRecovery(),
+	)
 }
 
 func (a *API) connectOptionsAuthLogRecovery() []connect.HandlerOption {