feat: added chat req and resp

Author: Bordi00

src/routing_handler.rs

@@ -277,6 +277,8 @@ impl RoutingHandler {
     }
 
     /// Send a packet to the first hop in its route
+    /// # Errors
+    /// Returns an error if send fails
     fn send_packet_to_first_hop(&self, packet: Packet) -> Result<(), NetworkError> {
         if packet.routing_header.hops.len() > 1 {
             let first_hop = packet.routing_header.hops[1];

src/types.rs

@@ -1,8 +1,45 @@
+use serde::{Deserialize, Serialize};
 use wg_internal::{network::NodeId, packet::Packet};
 use crossbeam_channel::Sender;
 
 pub type Bytes = Vec<u8>;
 
+#[derive(Serialize, Deserialize, Debug)]
+#[serde(tag = "message_type")]
+pub enum ChatRequest {
+    #[serde(rename = "server_type?")]
+    ServerTypeQuery,
+
+    #[serde(rename = "registration_to_chat")]
+    RegistrationToChat { client_id: NodeId },
+
+    #[serde(rename = "client_list?")]
+    ClientListQuery,
+
+    #[serde(rename = "message_for?")]
+    MessageFor { client_id: NodeId, message: String },
+}
+
+#[derive(Serialize, Deserialize, Debug)]
+#[serde(tag = "response_type")]
+pub enum ChatResponse {
+    #[serde(rename = "server_type!")]
+    ServerTypeResponse { server_type: String },
+
+    #[serde(rename = "client_list!")]
+    ClientListResponse { list_of_client_ids: Vec<NodeId> },
+
+    #[serde(rename = "message_from!")]
+    MessageFrom { client_id: NodeId, message: String },
+
+    #[serde(rename = "error_wrong_client_id!")]
+    ErrorWrongClientId,
+
+    // Custom response for successful registration
+    #[serde(rename = "registration_success")]
+    RegistrationSuccess,
+}
+
 
 pub enum ChatClientCommand {
     NodeCommand(NodeCommand)