Skip to content

Commit 23e3ea9

Browse files
author
Sergey
committed
fix: use of requestStreamParams middleware in streaming routes (#345)
1 parent 71fb08c commit 23e3ea9

File tree

1 file changed

+3
-6
lines changed

1 file changed

+3
-6
lines changed

gateway/rest/router.go

Lines changed: 3 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -172,19 +172,16 @@ func newRouter(log log.Logger, addr sdk.Address, pclient provider.Client, ctxCon
172172
leaseStatusHandler(log, pclient.Cluster(), ctxConfig)).
173173
Methods(http.MethodGet)
174174

175-
streamRouter := lrouter.NewRoute().Subrouter()
176-
streamRouter.Use(requestStreamParams)
177-
178-
mrouter = streamRouter.NewRoute().Subrouter()
179-
mrouter.Use(requireEndpointScopeForLeaseID(ajwt.PermissionScopeEvents))
175+
mrouter = lrouter.NewRoute().Subrouter()
176+
mrouter.Use(requestStreamParams, requireEndpointScopeForLeaseID(ajwt.PermissionScopeEvents))
180177

181178
// GET /lease/<lease-id>/kubeevents
182179
mrouter.HandleFunc("/kubeevents",
183180
leaseKubeEventsHandler(log, pclient.Cluster())).
184181
Methods("GET")
185182

186183
mrouter = lrouter.NewRoute().Subrouter()
187-
mrouter.Use(requireEndpointScopeForLeaseID(ajwt.PermissionScopeLogs))
184+
mrouter.Use(requestStreamParams, requireEndpointScopeForLeaseID(ajwt.PermissionScopeLogs))
188185

189186
// GET /lease/<lease-id>/logs
190187
mrouter.HandleFunc("/logs",

0 commit comments

Comments
 (0)