refactor: [torrust#670] new mod for responses logic and refactors to …

…json serialization trait

src/console/clients/udp/app.rs

@@ -67,11 +67,10 @@ use torrust_tracker_primitives::info_hash::InfoHash;
 use tracing::Level;
 
 use crate::console::clients::udp::checker;
-
+use crate::console::clients::udp::responses::dto::ResponseDto;
+use crate::console::clients::udp::responses::json::ToJson;
 use crate::console::clients::{parse_info_hash, parse_socket_addr, DEFAULT_TIMEOUT_SEC};
 
-use super::responses::{DtoToJson as _, ResponseDto};
-
 const RANDOM_TRANSACTION_ID: i32 = -888_840_697;
 
 #[derive(Parser, Debug)]
@@ -118,7 +117,11 @@ pub async fn run() -> anyhow::Result<()> {
     };
 
     let response_dto: ResponseDto = response.into();
-    response_dto.print_response()
+    let response_json = response_dto.to_json_string()?;
+
+    print!("{response_json}");
+
+    Ok(())
 }
 
 async fn handle_announce(addr: &SocketAddr, timeout: &Duration, info_hash: &InfoHash) -> anyhow::Result<Response> {

src/console/clients/udp/responses.rs → src/console/clients/udp/responses/dto.rs

@@ -1,27 +1,10 @@
 //! Aquatic responses are not serializable. These are the serializable wrappers.
 use std::net::{Ipv4Addr, Ipv6Addr};
 
-use anyhow::Context;
 use aquatic_udp_protocol::Response::{self};
 use aquatic_udp_protocol::{AnnounceResponse, ConnectResponse, ErrorResponse, Ipv4AddrBytes, Ipv6AddrBytes, ScrapeResponse};
 use serde::Serialize;
 
-pub trait DtoToJson {
-    /// # Errors
-    ///
-    /// Will return an error if serialization fails.
-    ///
-    fn print_response(&self) -> anyhow::Result<()>
-    where
-        Self: Serialize,
-    {
-        let pretty_json = serde_json::to_string_pretty(self).context("response JSON serialization")?;
-        println!("{pretty_json}");
-
-        Ok(())
-    }
-}
-
 #[derive(Serialize)]
 pub enum ResponseDto {
     Connect(ConnectResponseDto),
@@ -43,8 +26,6 @@ impl From<Response> for ResponseDto {
     }
 }
 
-impl DtoToJson for ResponseDto {}
-
 #[derive(Serialize)]
 pub struct ConnectResponseDto {
     transaction_id: i32,

src/console/clients/udp/responses/json.rs

@@ -0,0 +1,24 @@
+use anyhow::Context;
+use serde::Serialize;
+
+use super::dto::ResponseDto;
+
+pub trait ToJson {
+    ///
+    /// Returns a string with the JSON serialized version of the response
+    ///
+    /// # Errors
+    ///
+    /// Will return an error if serialization fails.
+    ///
+    fn to_json_string(&self) -> anyhow::Result<String>
+    where
+        Self: Serialize,
+    {
+        let pretty_json = serde_json::to_string_pretty(self).context("response JSON serialization")?;
+
+        Ok(pretty_json)
+    }
+}
+
+impl ToJson for ResponseDto {}

src/console/clients/udp/responses/mod.rs

@@ -0,0 +1,2 @@
+pub mod dto;
+pub mod json;