refactor: [torrust#1395] rename send_stats_event to send_event

Events are now generic even if they are only used for stats for now.

Author: josecelano

packages/http-tracker-core/src/services/announce.rs

@@ -87,7 +87,7 @@ impl AnnounceService {
             .announce(&announce_request.info_hash, &mut peer, &remote_client_ip, &peers_wanted)
             .await?;
 
-        self.send_stats_event(remote_client_ip, opt_remote_client_port, *server_socket_addr)
+        self.send_event(remote_client_ip, opt_remote_client_port, *server_socket_addr)
             .await;
 
         Ok(announce_data)
@@ -138,7 +138,7 @@ impl AnnounceService {
         }
     }
 
-    async fn send_stats_event(&self, peer_ip: IpAddr, opt_peer_ip_port: Option<u16>, server_socket_addr: SocketAddr) {
+    async fn send_event(&self, peer_ip: IpAddr, opt_peer_ip_port: Option<u16>, server_socket_addr: SocketAddr) {
         if let Some(http_stats_event_sender) = self.opt_http_stats_event_sender.as_deref() {
             http_stats_event_sender
                 .send_event(Event::TcpAnnounce {

packages/http-tracker-core/src/services/scrape.rs

@@ -82,8 +82,7 @@ impl ScrapeService {
 
         let (remote_client_ip, opt_client_port) = self.resolve_remote_client_ip(client_ip_sources)?;
 
-        self.send_stats_event(remote_client_ip, opt_client_port, *server_socket_addr)
-            .await;
+        self.send_event(remote_client_ip, opt_client_port, *server_socket_addr).await;
 
         Ok(scrape_data)
     }
@@ -118,12 +117,7 @@ impl ScrapeService {
         Ok((ip, port))
     }
 
-    async fn send_stats_event(
-        &self,
-        original_peer_ip: IpAddr,
-        opt_original_peer_port: Option<u16>,
-        server_socket_addr: SocketAddr,
-    ) {
+    async fn send_event(&self, original_peer_ip: IpAddr, opt_original_peer_port: Option<u16>, server_socket_addr: SocketAddr) {
         if let Some(http_stats_event_sender) = self.opt_http_stats_event_sender.as_deref() {
             http_stats_event_sender
                 .send_event(Event::TcpScrape {

packages/udp-tracker-core/src/services/announce.rs

@@ -79,7 +79,7 @@ impl AnnounceService {
             .announce(&info_hash, &mut peer, &remote_client_ip, &peers_wanted)
             .await?;
 
-        self.send_stats_event(client_socket_addr, server_socket_addr).await;
+        self.send_event(client_socket_addr, server_socket_addr).await;
 
         Ok(announce_data)
     }
@@ -100,7 +100,7 @@ impl AnnounceService {
         self.whitelist_authorization.authorize(info_hash).await
     }
 
-    async fn send_stats_event(&self, client_socket_addr: SocketAddr, server_socket_addr: SocketAddr) {
+    async fn send_event(&self, client_socket_addr: SocketAddr, server_socket_addr: SocketAddr) {
         if let Some(udp_stats_event_sender) = self.opt_udp_core_stats_event_sender.as_deref() {
             udp_stats_event_sender
                 .send_event(Event::UdpAnnounce {

packages/udp-tracker-core/src/services/scrape.rs

@@ -61,7 +61,7 @@ impl ScrapeService {
             .scrape(&Self::convert_from_aquatic(&request.info_hashes))
             .await?;
 
-        self.send_stats_event(client_socket_addr, server_socket_addr).await;
+        self.send_event(client_socket_addr, server_socket_addr).await;
 
         Ok(scrape_data)
     }
@@ -82,7 +82,7 @@ impl ScrapeService {
         aquatic_infohashes.iter().map(|&x| x.into()).collect()
     }
 
-    async fn send_stats_event(&self, client_socket_addr: SocketAddr, server_socket_addr: SocketAddr) {
+    async fn send_event(&self, client_socket_addr: SocketAddr, server_socket_addr: SocketAddr) {
         if let Some(udp_stats_event_sender) = self.opt_udp_stats_event_sender.as_deref() {
             udp_stats_event_sender
                 .send_event(Event::UdpScrape {