Skip to content

Commit 9a8a0dc

Browse files
committed
refactor: [#1382] rename UDP server event enum variants
1 parent 27e2db4 commit 9a8a0dc

File tree

5 files changed

+11
-11
lines changed

5 files changed

+11
-11
lines changed

packages/udp-tracker-server/src/server/launcher.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -173,7 +173,7 @@ impl Launcher {
173173
if let Some(udp_server_stats_event_sender) = udp_tracker_server_container.udp_server_stats_event_sender.as_deref()
174174
{
175175
udp_server_stats_event_sender
176-
.send_event(statistics::event::Event::UdpIncomingRequest {
176+
.send_event(statistics::event::Event::UdpRequestReceived {
177177
context: ConnectionContext::new(client_socket_addr, server_socket_addr),
178178
})
179179
.await;

packages/udp-tracker-server/src/server/processor.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,7 @@ impl Processor {
108108
self.udp_tracker_server_container.udp_server_stats_event_sender.as_deref()
109109
{
110110
udp_server_stats_event_sender
111-
.send_event(statistics::event::Event::UdpResponse {
111+
.send_event(statistics::event::Event::UdpResponseSent {
112112
context: ConnectionContext::new(client_socket_addr, self.socket.address()),
113113
kind: udp_response_kind,
114114
req_processing_time,

packages/udp-tracker-server/src/statistics/event/handler.rs

+5-5
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,7 @@ pub async fn handle_event(event: Event, stats_repository: &Repository) {
1414
Event::UdpRequestBanned { .. } => {
1515
stats_repository.increase_udp_requests_banned().await;
1616
}
17-
Event::UdpIncomingRequest { context } => match context.client_socket_addr().ip() {
17+
Event::UdpRequestReceived { context } => match context.client_socket_addr().ip() {
1818
std::net::IpAddr::V4(_) => {
1919
stats_repository.increase_udp4_requests().await;
2020
}
@@ -48,7 +48,7 @@ pub async fn handle_event(event: Event, stats_repository: &Repository) {
4848
}
4949
},
5050
},
51-
Event::UdpResponse {
51+
Event::UdpResponseSent {
5252
context,
5353
kind,
5454
req_processing_time,
@@ -149,7 +149,7 @@ mod tests {
149149
let stats_repository = Repository::new();
150150

151151
handle_event(
152-
Event::UdpIncomingRequest {
152+
Event::UdpRequestReceived {
153153
context: ConnectionContext::new(
154154
SocketAddr::new(IpAddr::V4(Ipv4Addr::new(203, 0, 113, 195)), 8080),
155155
SocketAddr::new(IpAddr::V4(Ipv4Addr::new(203, 0, 113, 196)), 6969),
@@ -267,7 +267,7 @@ mod tests {
267267
let stats_repository = Repository::new();
268268

269269
handle_event(
270-
Event::UdpResponse {
270+
Event::UdpResponseSent {
271271
context: ConnectionContext::new(
272272
SocketAddr::new(IpAddr::V4(Ipv4Addr::new(203, 0, 113, 195)), 8080),
273273
SocketAddr::new(IpAddr::V4(Ipv4Addr::new(203, 0, 113, 196)), 6969),
@@ -374,7 +374,7 @@ mod tests {
374374
let stats_repository = Repository::new();
375375

376376
handle_event(
377-
Event::UdpResponse {
377+
Event::UdpResponseSent {
378378
context: ConnectionContext::new(
379379
SocketAddr::new(IpAddr::V6(Ipv6Addr::new(0, 0, 0, 0, 203, 0, 113, 195)), 8080),
380380
SocketAddr::new(IpAddr::V6(Ipv6Addr::new(0, 0, 0, 0, 203, 0, 113, 196)), 6969),

packages/udp-tracker-server/src/statistics/event/mod.rs

+3-3
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ pub mod sender;
88
/// An statistics event. It is used to collect tracker metrics.
99
#[derive(Debug, PartialEq, Eq, Clone)]
1010
pub enum Event {
11-
UdpIncomingRequest {
11+
UdpRequestReceived {
1212
context: ConnectionContext,
1313
},
1414
UdpRequestAborted {
@@ -21,7 +21,7 @@ pub enum Event {
2121
context: ConnectionContext,
2222
kind: UdpRequestKind,
2323
},
24-
UdpResponse {
24+
UdpResponseSent {
2525
context: ConnectionContext,
2626
kind: UdpResponseKind,
2727
req_processing_time: Duration,
@@ -44,7 +44,7 @@ pub enum UdpResponseKind {
4444
req_kind: UdpRequestKind,
4545
},
4646

47-
/// There was an error handling the requests. The error contains the request
47+
/// There was an error handling the request. The error contains the request
4848
/// kind if the request was parsed successfully.
4949
Error {
5050
opt_req_kind: Option<UdpRequestKind>,

packages/udp-tracker-server/src/statistics/keeper.rs

+1-1
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ mod tests {
7373
let event_sender = stats_tracker.run_event_listener();
7474

7575
let result = event_sender
76-
.send_event(Event::UdpIncomingRequest {
76+
.send_event(Event::UdpRequestReceived {
7777
context: ConnectionContext::new(
7878
SocketAddr::new(IpAddr::V6(Ipv6Addr::new(0, 0, 0, 0, 203, 0, 113, 195)), 8080),
7979
SocketAddr::new(IpAddr::V6(Ipv6Addr::new(0, 0, 0, 0, 203, 0, 113, 196)), 6969),

0 commit comments

Comments
 (0)