init

src/routes/message/handlers.rs

@@ -1,10 +1,10 @@
+use super::dto::{CreateMessageRequest, MessageFilters, MessageResponse, UpdateMessageRequest};
 use crate::core::state::AppState;
 use crate::http::context::CurrentUser;
 use crate::http::error::HTTPError;
-use crate::routes::message::dto::{CreateMessageRequest, MessageResponse, UpdateMessageRequest};
 use crate::routes::message::mapper;
 use axum::{
-    extract::{Path, State},
+    extract::{Path, Query, State},
     http::StatusCode,
     Json,
 };
@@ -18,12 +18,24 @@ use uuid::Uuid;
         (status = 200, description = "Liste des messages récupérée avec succès", body = [MessageResponse]),
         (status = 500, description = "Erreur interne du serveur")
     ),
+    params(
+        MessageFilters
+    ),
     tag = "Messages"
 )]
 pub async fn get_all(
     State(state): State<AppState>,
+    Query(filters): Query<MessageFilters>,
 ) -> Result<Json<Vec<MessageResponse>>, HTTPError> {
-    let messages = state.repositories.message.get_all().await?;
+    let messages = if let Some(channel_id) = filters.channel_id {
+        state
+            .repositories
+            .message
+            .get_by_channel(channel_id)
+            .await?
+    } else {
+        state.repositories.message.get_all().await?
+    };
     Ok(Json(
         messages
             .into_iter()