From 0a4af3948a3d82f2ccbb4b914ad18cd82229436c Mon Sep 17 00:00:00 2001 From: Sergey Date: Thu, 3 Jul 2025 17:04:03 +0700 Subject: [PATCH] fix: use of requestStreamParams middleware in streaming routes (#302) --- gateway/rest/router.go | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/gateway/rest/router.go b/gateway/rest/router.go index 9d8f0969a..eed5a2b4d 100644 --- a/gateway/rest/router.go +++ b/gateway/rest/router.go @@ -172,11 +172,8 @@ func newRouter(log log.Logger, addr sdk.Address, pclient provider.Client, ctxCon leaseStatusHandler(log, pclient.Cluster(), ctxConfig)). Methods(http.MethodGet) - streamRouter := lrouter.NewRoute().Subrouter() - streamRouter.Use(requestStreamParams) - - mrouter = streamRouter.NewRoute().Subrouter() - mrouter.Use(requireEndpointScopeForLeaseID(ajwt.PermissionScopeEvents)) + mrouter = lrouter.NewRoute().Subrouter() + mrouter.Use(requestStreamParams, requireEndpointScopeForLeaseID(ajwt.PermissionScopeEvents)) // GET /lease//kubeevents mrouter.HandleFunc("/kubeevents", @@ -184,7 +181,7 @@ func newRouter(log log.Logger, addr sdk.Address, pclient provider.Client, ctxCon Methods("GET") mrouter = lrouter.NewRoute().Subrouter() - mrouter.Use(requireEndpointScopeForLeaseID(ajwt.PermissionScopeLogs)) + mrouter.Use(requestStreamParams, requireEndpointScopeForLeaseID(ajwt.PermissionScopeLogs)) // GET /lease//logs mrouter.HandleFunc("/logs",