fix: limit JSON payload size to 10MB (#1133)

Devdutt Shenoi · web-flow · commit 5a39e22570ac · 2025-01-24T18:02:59.000+05:30
Since #1100 we are using the Json extractor, which uses JsonConfig, not PayloadConfig
diff --git a/src/handlers/http/modal/ingest_server.rs b/src/handlers/http/modal/ingest_server.rs
@@ -249,7 +249,7 @@ impl IngestServer {
                             web::put()
                                 .to(ingestor_logstream::put_stream)
                                 .authorize_for_stream(Action::CreateStream),
-                        ),
+                        )
                 )
                 .service(
                     // GET "/logstream/{logstream}/info" ==> Get info for given log stream
diff --git a/src/handlers/http/modal/query_server.rs b/src/handlers/http/modal/query_server.rs
@@ -275,7 +275,7 @@ impl QueryServer {
                                     .to(querier_logstream::delete)
                                     .authorize_for_stream(Action::DeleteStream),
                             )
-                            .app_data(web::PayloadConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)),
+                            .app_data(web::JsonConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)),
                     )
                     .service(
                         // GET "/logstream/{logstream}/info" ==> Get info for given log stream
diff --git a/src/handlers/http/modal/server.rs b/src/handlers/http/modal/server.rs
@@ -318,7 +318,7 @@ impl Server {
                                     .to(logstream::delete)
                                     .authorize_for_stream(Action::DeleteStream),
                             )
-                            .app_data(web::PayloadConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)),
+                            .app_data(web::JsonConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)),
                     )
                     .service(
                         // GET "/logstream/{logstream}/info" ==> Get info for given log stream
@@ -404,7 +404,7 @@ impl Server {
                     .to(ingest::ingest)
                     .authorize_for_stream(Action::Ingest),
             )
-            .app_data(web::PayloadConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE))
+            .app_data(web::JsonConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE))
     }
 
     // /v1/logs endpoint to be used for OTEL log ingestion only
@@ -417,7 +417,7 @@ impl Server {
                             .to(ingest::handle_otel_logs_ingestion)
                             .authorize_for_stream(Action::Ingest),
                     )
-                    .app_data(web::PayloadConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)),
+                    .app_data(web::JsonConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)),
             )
             .service(
                 web::resource("/metrics")
@@ -426,7 +426,7 @@ impl Server {
                             .to(ingest::handle_otel_metrics_ingestion)
                             .authorize_for_stream(Action::Ingest),
                     )
-                    .app_data(web::PayloadConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)),
+                    .app_data(web::JsonConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)),
             )
             .service(
                 web::resource("/traces")
@@ -435,7 +435,7 @@ impl Server {
                             .to(ingest::handle_otel_traces_ingestion)
                             .authorize_for_stream(Action::Ingest),
                     )
-                    .app_data(web::PayloadConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)),
+                    .app_data(web::JsonConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)),
             )
     }
 

Original file line number	Diff line number	Diff line change
`@@ -249,7 +249,7 @@ impl IngestServer {`
`249`	`249`	`web::put()`
`250`	`250`	`.to(ingestor_logstream::put_stream)`
`251`	`251`	`.authorize_for_stream(Action::CreateStream),`
`252`		`- ),`
	`252`	`+ )`
`253`	`253`	`)`
`254`	`254`	`.service(`
`255`	`255`	`// GET "/logstream/{logstream}/info" ==> Get info for given log stream`
Original file line number	Diff line number	Diff line change
`@@ -275,7 +275,7 @@ impl QueryServer {`
`275`	`275`	`.to(querier_logstream::delete)`
`276`	`276`	`.authorize_for_stream(Action::DeleteStream),`
`277`	`277`	`)`
`278`		`- .app_data(web::PayloadConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)),`
	`278`	`+ .app_data(web::JsonConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)),`
`279`	`279`	`)`
`280`	`280`	`.service(`
`281`	`281`	`// GET "/logstream/{logstream}/info" ==> Get info for given log stream`
Original file line number	Diff line number	Diff line change
`@@ -318,7 +318,7 @@ impl Server {`
`318`	`318`	`.to(logstream::delete)`
`319`	`319`	`.authorize_for_stream(Action::DeleteStream),`
`320`	`320`	`)`
`321`		`- .app_data(web::PayloadConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)),`
	`321`	`+ .app_data(web::JsonConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)),`
`322`	`322`	`)`
`323`	`323`	`.service(`
`324`	`324`	`// GET "/logstream/{logstream}/info" ==> Get info for given log stream`
`@@ -404,7 +404,7 @@ impl Server {`
`404`	`404`	`.to(ingest::ingest)`
`405`	`405`	`.authorize_for_stream(Action::Ingest),`
`406`	`406`	`)`
`407`		`- .app_data(web::PayloadConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE))`
	`407`	`+ .app_data(web::JsonConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE))`
`408`	`408`	`}`
`409`	`409`
`410`	`410`	`// /v1/logs endpoint to be used for OTEL log ingestion only`
`@@ -417,7 +417,7 @@ impl Server {`
`417`	`417`	`.to(ingest::handle_otel_logs_ingestion)`
`418`	`418`	`.authorize_for_stream(Action::Ingest),`
`419`	`419`	`)`
`420`		`- .app_data(web::PayloadConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)),`
	`420`	`+ .app_data(web::JsonConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)),`
`421`	`421`	`)`
`422`	`422`	`.service(`
`423`	`423`	`web::resource("/metrics")`
`@@ -426,7 +426,7 @@ impl Server {`
`426`	`426`	`.to(ingest::handle_otel_metrics_ingestion)`
`427`	`427`	`.authorize_for_stream(Action::Ingest),`
`428`	`428`	`)`
`429`		`- .app_data(web::PayloadConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)),`
	`429`	`+ .app_data(web::JsonConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)),`
`430`	`430`	`)`
`431`	`431`	`.service(`
`432`	`432`	`web::resource("/traces")`
`@@ -435,7 +435,7 @@ impl Server {`
`435`	`435`	`.to(ingest::handle_otel_traces_ingestion)`
`436`	`436`	`.authorize_for_stream(Action::Ingest),`
`437`	`437`	`)`
`438`		`- .app_data(web::PayloadConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)),`
	`438`	`+ .app_data(web::JsonConfig::default().limit(MAX_EVENT_PAYLOAD_SIZE)),`
`439`	`439`	`)`
`440`	`440`	`}`
`441`	`441`