Skip to content

Commit 88b4596

Browse files
committed
refactor: add resource utilization middleware to logstream routes, deleted middleware from the DELETE request
1 parent 0279f36 commit 88b4596

File tree

1 file changed

+6
-5
lines changed

1 file changed

+6
-5
lines changed

src/handlers/http/modal/server.rs

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -367,23 +367,24 @@ impl Server {
367367
.route(
368368
web::put()
369369
.to(logstream::put_stream)
370-
.authorize_for_stream(Action::CreateStream),
370+
.authorize_for_stream(Action::CreateStream)
371+
.wrap(from_fn(resource_check::check_resource_utilization_middleware)),
371372
)
372373
// POST "/logstream/{logstream}" ==> Post logs to given log stream
373374
.route(
374375
web::post()
375376
.to(ingest::post_event)
376-
.authorize_for_stream(Action::Ingest),
377+
.authorize_for_stream(Action::Ingest)
378+
.wrap(from_fn(resource_check::check_resource_utilization_middleware)),
377379
)
378380
// DELETE "/logstream/{logstream}" ==> Delete log stream
379381
.route(
380382
web::delete()
381383
.to(logstream::delete)
382384
.authorize_for_stream(Action::DeleteStream),
383385
)
384-
.app_data(web::JsonConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE))
385-
.wrap(from_fn(resource_check::check_resource_utilization_middleware)),
386-
)
386+
.app_data(web::JsonConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)),
387+
)
387388
.service(
388389
// GET "/logstream/{logstream}/info" ==> Get info for given log stream
389390
web::resource("/info").route(

0 commit comments

Comments
 (0)