allow the message to be mutated

cdn-broker/src/tasks/broker/handler.rs

@@ -131,10 +131,10 @@ impl<Def: RunDef> Inner<Def> {
             let raw_message = connection.recv_message_raw().await?;
 
             // Attempt to deserialize the message
-            let message = Message::deserialize(&raw_message)?;
+            let mut message = Message::deserialize(&raw_message)?;
 
             // Call the hook for the broker and handle the result
-            match local_message_hook.on_message_received(&message) {
+            match local_message_hook.on_message_received(&mut message) {
                 Ok(HookResult::SkipMessage) => continue,
                 Ok(HookResult::ProcessMessage) => (),
                 Err(err) => {

cdn-broker/src/tasks/user/handler.rs

@@ -105,10 +105,10 @@ impl<Def: RunDef> Inner<Def> {
             let raw_message = connection.recv_message_raw().await?;
 
             // Attempt to deserialize the message
-            let message = Message::deserialize(&raw_message)?;
+            let mut message = Message::deserialize(&raw_message)?;
 
             // Call the hook for the user and handle the result
-            match local_message_hook.on_message_received(&message) {
+            match local_message_hook.on_message_received(&mut message) {
                 Ok(HookResult::SkipMessage) => continue,
                 Ok(HookResult::ProcessMessage) => (),
                 Err(err) => {

cdn-proto/src/def.rs

@@ -80,7 +80,7 @@ pub trait MessageHookDef: Send + Sync + 'static + Clone {
     ///
     /// # Errors
     /// Is supposed to return an error if the other end should be disconnected.
-    fn on_message_received(&self, _message: &Message) -> AnyhowResult<HookResult> {
+    fn on_message_received(&self, _message: &mut Message) -> AnyhowResult<HookResult> {
         Ok(HookResult::ProcessMessage)
     }
 }