diff --git a/src/modes/server/api/item.rs b/src/modes/server/api/item.rs index f203d89..21bcdd3 100644 --- a/src/modes/server/api/item.rs +++ b/src/modes/server/api/item.rs @@ -269,17 +269,17 @@ async fn handle_as_meta_response_with_metadata( pub async fn handle_post_item( State(_state): State, ) -> Result>, StatusCode> { - + // This is a simplified implementation // In a real implementation, you'd need to properly parse multipart/form-data // or JSON payload with the item data - + let response = ApiResponse:: { success: false, data: None, error: Some("POST /api/item/ not yet implemented".to_string()), }; - + Ok(Json(response)) } diff --git a/src/services/async_item_service.rs b/src/services/async_item_service.rs index ae582b7..e5db7fb 100644 --- a/src/services/async_item_service.rs +++ b/src/services/async_item_service.rs @@ -54,7 +54,7 @@ impl AsyncItemService { f(&conn, &item_service) }) .await - .unwrap() + .map_err(|e| CoreError::Other(anyhow::anyhow!("Blocking task failed: {}", e)))? } pub async fn get_item(&self, id: i64) -> Result { @@ -186,7 +186,7 @@ impl AsyncItemService { ).map(|(reader, _, _)| reader) }) .await - .unwrap()? + .map_err(|e| CoreError::Other(anyhow::anyhow!("Blocking task failed: {}", e)))? }; // Convert the reader into an async stream manually diff --git a/src/services/item_service.rs b/src/services/item_service.rs index 3a6539a..d6ad259 100644 --- a/src/services/item_service.rs +++ b/src/services/item_service.rs @@ -59,7 +59,7 @@ impl Read for FilteringReader { } // Process through the filter chain if it exists - if let Some(chain) = &mut self.filter_chain { + if let Some(ref mut chain) = self.filter_chain { // Use a cursor to read the input data let mut input_cursor = std::io::Cursor::new(&temp_buf[..bytes_read]); // Write filtered output to our buffer