Bump webhook max size to 5MB

hook-api/src/handlers/app.rs

@@ -1,4 +1,4 @@
-use axum::{routing, Router};
+use axum::{extract::DefaultBodyLimit, routing, Router};
 
 use hook_common::pgqueue::PgQueue;
 
@@ -9,7 +9,12 @@ pub fn add_routes(router: Router, pg_pool: PgQueue) -> Router {
         .route("/", routing::get(index))
         .route("/_readiness", routing::get(index))
         .route("/_liveness", routing::get(index)) // No async loop for now, just check axum health
-        .route("/webhook", routing::post(webhook::post).with_state(pg_pool))
+        .route(
+            "/webhook",
+            routing::post(webhook::post)
+                .with_state(pg_pool)
+                .layer(DefaultBodyLimit::disable()),
+        )
 }
 
 pub async fn index() -> &'static str {

hook-api/src/handlers/webhook.rs

@@ -9,7 +9,7 @@ use hook_common::pgqueue::{NewJob, PgQueue};
 use serde::Serialize;
 use tracing::{debug, error};
 
-const MAX_BODY_SIZE: usize = 1_000_000;
+pub const MAX_BODY_SIZE: usize = 5_000_000;
 
 #[derive(Serialize, Deserialize)]
 pub struct WebhookPostResponse {
@@ -252,7 +252,7 @@ mod tests {
 
         let app = add_routes(Router::new(), pg_queue);
 
-        let bytes: Vec<u8> = vec![b'a'; 1_000_000 * 2];
+        let bytes: Vec<u8> = vec![b'a'; 5_000_000 * 2];
         let long_string = String::from_utf8_lossy(&bytes);
 
         let response = app