Skip to content

Commit 32416ee

Browse files
committed
refactor: [#670] changed DTOs and variable names
1 parent 5a529cc commit 32416ee

File tree

3 files changed

+26
-26
lines changed

3 files changed

+26
-26
lines changed

src/console/clients/udp/app.rs

+3-3
Original file line numberDiff line numberDiff line change
@@ -67,7 +67,7 @@ use torrust_tracker_primitives::info_hash::InfoHash as TorrustInfoHash;
6767
use url::Url;
6868

6969
use crate::console::clients::udp::checker;
70-
use crate::console::clients::udp::responses::dto::ResponseDto;
70+
use crate::console::clients::udp::responses::dto::SerializableResponse;
7171
use crate::console::clients::udp::responses::json::ToJson;
7272

7373
const ASSIGNED_BY_OS: u16 = 0;
@@ -117,8 +117,8 @@ pub async fn run() -> anyhow::Result<()> {
117117
} => handle_scrape(&tracker_socket_addr, &info_hashes).await?,
118118
};
119119

120-
let response_dto: ResponseDto = response.into();
121-
let response_json = response_dto.to_json_string()?;
120+
let response: SerializableResponse = response.into();
121+
let response_json = response.to_json_string()?;
122122

123123
print!("{response_json}");
124124

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

+21-21
Original file line numberDiff line numberDiff line change
@@ -6,33 +6,33 @@ use aquatic_udp_protocol::{AnnounceResponse, ConnectResponse, ErrorResponse, Ipv
66
use serde::Serialize;
77

88
#[derive(Serialize)]
9-
pub enum ResponseDto {
10-
Connect(ConnectResponseDto),
11-
AnnounceIpv4(AnnounceResponseDto),
12-
AnnounceIpv6(AnnounceResponseDto),
13-
Scrape(ScrapeResponseDto),
14-
Error(ErrorResponseDto),
9+
pub enum SerializableResponse {
10+
Connect(ConnectSerializableResponse),
11+
AnnounceIpv4(AnnounceSerializableResponse),
12+
AnnounceIpv6(AnnounceSerializableResponse),
13+
Scrape(ScrapeSerializableResponse),
14+
Error(ErrorSerializableResponse),
1515
}
1616

17-
impl From<Response> for ResponseDto {
17+
impl From<Response> for SerializableResponse {
1818
fn from(response: Response) -> Self {
1919
match response {
20-
Response::Connect(response) => ResponseDto::Connect(ConnectResponseDto::from(response)),
21-
Response::AnnounceIpv4(response) => ResponseDto::AnnounceIpv4(AnnounceResponseDto::from(response)),
22-
Response::AnnounceIpv6(response) => ResponseDto::AnnounceIpv6(AnnounceResponseDto::from(response)),
23-
Response::Scrape(response) => ResponseDto::Scrape(ScrapeResponseDto::from(response)),
24-
Response::Error(response) => ResponseDto::Error(ErrorResponseDto::from(response)),
20+
Response::Connect(response) => SerializableResponse::Connect(ConnectSerializableResponse::from(response)),
21+
Response::AnnounceIpv4(response) => SerializableResponse::AnnounceIpv4(AnnounceSerializableResponse::from(response)),
22+
Response::AnnounceIpv6(response) => SerializableResponse::AnnounceIpv6(AnnounceSerializableResponse::from(response)),
23+
Response::Scrape(response) => SerializableResponse::Scrape(ScrapeSerializableResponse::from(response)),
24+
Response::Error(response) => SerializableResponse::Error(ErrorSerializableResponse::from(response)),
2525
}
2626
}
2727
}
2828

2929
#[derive(Serialize)]
30-
pub struct ConnectResponseDto {
30+
pub struct ConnectSerializableResponse {
3131
transaction_id: i32,
3232
connection_id: i64,
3333
}
3434

35-
impl From<ConnectResponse> for ConnectResponseDto {
35+
impl From<ConnectResponse> for ConnectSerializableResponse {
3636
fn from(connect: ConnectResponse) -> Self {
3737
Self {
3838
transaction_id: connect.transaction_id.0.into(),
@@ -42,15 +42,15 @@ impl From<ConnectResponse> for ConnectResponseDto {
4242
}
4343

4444
#[derive(Serialize)]
45-
pub struct AnnounceResponseDto {
45+
pub struct AnnounceSerializableResponse {
4646
transaction_id: i32,
4747
announce_interval: i32,
4848
leechers: i32,
4949
seeders: i32,
5050
peers: Vec<String>,
5151
}
5252

53-
impl From<AnnounceResponse<Ipv4AddrBytes>> for AnnounceResponseDto {
53+
impl From<AnnounceResponse<Ipv4AddrBytes>> for AnnounceSerializableResponse {
5454
fn from(announce: AnnounceResponse<Ipv4AddrBytes>) -> Self {
5555
Self {
5656
transaction_id: announce.fixed.transaction_id.0.into(),
@@ -66,7 +66,7 @@ impl From<AnnounceResponse<Ipv4AddrBytes>> for AnnounceResponseDto {
6666
}
6767
}
6868

69-
impl From<AnnounceResponse<Ipv6AddrBytes>> for AnnounceResponseDto {
69+
impl From<AnnounceResponse<Ipv6AddrBytes>> for AnnounceSerializableResponse {
7070
fn from(announce: AnnounceResponse<Ipv6AddrBytes>) -> Self {
7171
Self {
7272
transaction_id: announce.fixed.transaction_id.0.into(),
@@ -83,12 +83,12 @@ impl From<AnnounceResponse<Ipv6AddrBytes>> for AnnounceResponseDto {
8383
}
8484

8585
#[derive(Serialize)]
86-
pub struct ScrapeResponseDto {
86+
pub struct ScrapeSerializableResponse {
8787
transaction_id: i32,
8888
torrent_stats: Vec<TorrentStats>,
8989
}
9090

91-
impl From<ScrapeResponse> for ScrapeResponseDto {
91+
impl From<ScrapeResponse> for ScrapeSerializableResponse {
9292
fn from(scrape: ScrapeResponse) -> Self {
9393
Self {
9494
transaction_id: scrape.transaction_id.0.into(),
@@ -106,12 +106,12 @@ impl From<ScrapeResponse> for ScrapeResponseDto {
106106
}
107107

108108
#[derive(Serialize)]
109-
pub struct ErrorResponseDto {
109+
pub struct ErrorSerializableResponse {
110110
transaction_id: i32,
111111
message: String,
112112
}
113113

114-
impl From<ErrorResponse> for ErrorResponseDto {
114+
impl From<ErrorResponse> for ErrorSerializableResponse {
115115
fn from(error: ErrorResponse) -> Self {
116116
Self {
117117
transaction_id: error.transaction_id.0.into(),

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

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
use anyhow::Context;
22
use serde::Serialize;
33

4-
use super::dto::ResponseDto;
4+
use super::dto::SerializableResponse;
55

66
pub trait ToJson {
77
///
@@ -21,4 +21,4 @@ pub trait ToJson {
2121
}
2222
}
2323

24-
impl ToJson for ResponseDto {}
24+
impl ToJson for SerializableResponse {}

0 commit comments

Comments
 (0)