feat: Configure a 10GB body limit for uploads and enhance attachment processing with a 100MB image size cap and improved error handling.

src/handlers/attachments.rs

@@ -35,7 +35,7 @@ pub struct AttachmentsTemplate<'a> {
 pub fn router() -> Router<Arc<AppState>> {
     Router::new()
         .route("/", get(list_attachments))
-        .route("/upload", post(upload_attachment))
+        .route("/upload", post(upload_attachment).layer(axum::extract::DefaultBodyLimit::max(10 * 1024 * 1024 * 1024)))
         .route("/delete/{id}", post(delete_attachment))
 }
 
@@ -90,11 +90,13 @@ pub async fn upload_attachment(
         drop(file);
 
         // 2. Process image/video in place if needed
-        if content_type.starts_with("image/") {
+        // Only process images smaller than 100MB to avoid OOM
-            let data = fs::read(&file_path).await.context("Failed to read image")?;
+        if content_type.starts_with("image/") && size < 100 * 1024 * 1024 {
-            if let Ok(processed_data) = process_image(&data, &content_type).await {
+            if let Ok(data) = fs::read(&file_path).await {
-                fs::write(&file_path, &processed_data).await.context("Failed to overwrite image")?;
+                if let Ok(processed_data) = process_image(&data, &content_type).await {
-                size = processed_data.len() as i64;
+                    let _ = fs::write(&file_path, &processed_data).await;
+                    size = processed_data.len() as i64;
+                }
             }
         } else if content_type.starts_with("video/") {
             let p_buf = file_path.clone();
@@ -107,7 +109,9 @@ pub async fn upload_attachment(
                 }
             }).await;
             
-            size = fs::metadata(&file_path).await.context("Failed to get size")?.len() as i64;
+            if let Ok(meta) = fs::metadata(&file_path).await {
+                size = meta.len() as i64;
+            }
         }
 
         sqlx::query("INSERT INTO attachments (id, filename, content_type, size, created_at) VALUES (?, ?, ?, ?, ?)")

src/main.rs

@@ -120,7 +120,8 @@ async fn main() {
         .route("/__attachments/{id}", get(handlers::attachments::serve_attachment))
         .nest("/__dungeon", handlers::router(&app_state)) // I'll create a single `handlers::router`
         .with_state(app_state.clone())
-        .layer(axum::extract::DefaultBodyLimit::disable())
+        .layer(axum::extract::DefaultBodyLimit::max(10 * 1024 * 1024 * 1024)) // 10GB limit to be safe
+
         .layer(tower_http::trace::TraceLayer::new_for_http());
 
     let listener = TcpListener::bind(&addr).await.unwrap();