feat(network) : implement network service to manage channel connection and protocol command (dev-sys-do#4)

* feat(command): implement CommandError enum and CommandService trait with CommandServiceImpl

* feat(network): add network service impl with mpsc channel buffer

* chore(dependencies): update dependencies in Cargo.toml

* feat(main): refactor main function to use async/await and integrate network service

* feat(network): fix reject other connection and send message to sender

* fix(command): return correct block index in OkHousten response

Author: jorisvilardell

Cargo.lock

@@ -4,4 +4,6 @@ version = "0.0.0"
 edition = "2024"
 
 [dependencies]
+async-trait = "0.1.89"
 clap = "4.5.50"
+tokio = { version = "1", features = ["net", "rt-multi-thread", "rt", "fs", "io-util", "sync", "macros"] }

Cargo.toml

@@ -0,0 +1,5 @@
+#[derive(Debug)]
+pub enum CommandError {
+    InvalidCommand,
+    ExecutionFailed(String),
+}

src/core/domain/command/entities.rs

@@ -0,0 +1,3 @@
+pub mod entities;
+pub mod ports;
+pub mod services;

src/core/domain/command/mod.rs

@@ -0,0 +1,8 @@
+use crate::core::domain::{command::entities::CommandError, network::entities::ProtocolMessage};
+
+pub trait CommandService: Send + Sync {
+    fn execute_protocol_command(
+        &self,
+        msg: &ProtocolMessage,
+    ) -> impl Future<Output = Result<ProtocolMessage, CommandError>> + Send;
+}

src/core/domain/command/ports.rs

@@ -0,0 +1,37 @@
+use crate::core::domain::{
+    command::{entities::CommandError, ports::CommandService},
+    network::entities::ProtocolMessage,
+};
+
+#[derive(Clone)]
+pub struct CommandServiceImpl {}
+
+impl CommandServiceImpl {
+    pub fn new() -> Self {
+        CommandServiceImpl {}
+    }
+}
+
+impl CommandService for CommandServiceImpl {
+    async fn execute_protocol_command(
+        &self,
+        msg: &ProtocolMessage,
+    ) -> Result<ProtocolMessage, CommandError> {
+        match msg {
+            ProtocolMessage::Hello { filename, filesize } => {
+                // Démarrer la logique de préparation de réception
+                Ok(ProtocolMessage::Ok)
+            }
+            ProtocolMessage::Yeet {
+                block_index,
+                block_size,
+                check_sum,
+            } => {
+                // Logique pour gérer la réception d'un bloc de données
+                Ok(ProtocolMessage::OkHousten(block_index.clone()))
+            }
+            // ... autres commandes
+            _ => Err(CommandError::InvalidCommand),
+        }
+    }
+}