dev: work on udp tracker service

Author: da2ce7

.github/workflows/coverage.yaml

@@ -55,6 +55,9 @@ jobs:
         name: Run Build Checks
         run: cargo check --tests --benches --examples --workspace --all-targets --all-features
 
+      # Run Test Locally:
+      # RUSTFLAGS="-Z profile -C codegen-units=1 -C inline-threshold=0 -C link-dead-code -C overflow-checks=off -C panic=abort -Z panic_abort_tests" RUSTDOCFLAGS="-Z profile -C codegen-units=1 -C inline-threshold=0 -C link-dead-code -C overflow-checks=off -C panic=abort -Z panic_abort_tests" CARGO_INCREMENTAL="0" RUST_BACKTRACE=1 cargo test --tests --benches --examples --workspace --all-targets --all-features
+
       - id: test
         name: Run Unit Tests
         run: cargo test --tests --benches --examples --workspace --all-targets --all-features

.vscode/settings.json

@@ -2,6 +2,12 @@
   "[rust]": {
     "editor.formatOnSave": true
   },
+  "[ignore]": { "rust-analyzer.cargo.extraEnv" : {
+    "RUSTFLAGS": "-Z profile -C codegen-units=1 -C inline-threshold=0 -C link-dead-code -C overflow-checks=off -C panic=abort -Z panic_abort_tests",
+    "RUSTDOCFLAGS": "-Z profile -C codegen-units=1 -C inline-threshold=0 -C link-dead-code -C overflow-checks=off -C panic=abort -Z panic_abort_tests",
+    "CARGO_INCREMENTAL": "0",
+    "RUST_BACKTRACE": "1"
+  }},
   "rust-analyzer.checkOnSave": true,
   "rust-analyzer.check.command": "clippy",
   "rust-analyzer.check.allTargets": true,

Cargo.lock

@@ -39,11 +39,11 @@ binascii = "0"
 chrono = { version = "0", default-features = false, features = ["clock"] }
 config = "0"
 derive_more = "0"
-fern = "0"
 futures = "0"
 hyper = "1"
 lazy_static = "1"
-log = { version = "0", features = ["release_max_level_info"] }
+tracing = "0.1"
+tracing-subscriber = "0.3"
 multimap = "0"
 openssl = { version = "0", features = ["vendored"] }
 percent-encoding = "2"
@@ -55,6 +55,7 @@ reqwest = "0"
 serde = { version = "1", features = ["derive"] }
 serde_bencode = "0"
 serde_json = "1"
+ringbuf = "0.4.0-rc.2"
 serde_with = "3"
 tdyne-peer-id = "1"
 tdyne-peer-id-registry = "0"

Cargo.toml

@@ -94,8 +94,10 @@
         "reannounce",
         "Registar",
         "repr",
+        "reqs",
         "reqwest",
         "rerequests",
+        "ringbuf",
         "rngs",
         "routable",
         "rusqlite",

cSpell.json

@@ -15,7 +15,7 @@ rust-version.workspace = true
 version.workspace = true
 
 [dependencies]
-log = { version = "0", features = ["release_max_level_info"] }
+tracing = "0.1"
 
 [dev-dependencies]
 thiserror = "1"

packages/located-error/Cargo.toml

@@ -33,7 +33,7 @@ use std::error::Error;
 use std::panic::Location;
 use std::sync::Arc;
 
-use log::debug;
+use tracing::debug;
 
 pub type DynError = Arc<dyn std::error::Error + Send + Sync>;
 

packages/located-error/src/lib.rs

@@ -26,10 +26,10 @@ use std::net::SocketAddr;
 use std::sync::Arc;
 
 use derive_more::Constructor;
-use log::warn;
 use tokio::sync::Mutex;
 use tokio::task::JoinHandle;
 use torrust_tracker_configuration::Configuration;
+use tracing::warn;
 
 use crate::bootstrap::jobs::{health_check_api, http_tracker, torrent_cleanup, tracker_apis, udp_tracker};
 use crate::{core, servers};

src/app.rs

@@ -14,10 +14,10 @@
 //! Refer to the [configuration documentation](https://docs.rs/torrust-tracker-configuration)
 //! for the API configuration options.
 
-use log::info;
 use tokio::sync::oneshot;
 use tokio::task::JoinHandle;
 use torrust_tracker_configuration::HealthCheckApi;
+use tracing::debug;
 
 use super::Started;
 use crate::app::Registry;
@@ -46,18 +46,18 @@ pub async fn start_job(config: &HealthCheckApi, register: Registry) -> JoinHandl
 
     // Run the API server
     let join_handle = tokio::spawn(async move {
-        info!(target: "Health Check API", "Starting on: http://{}", bind_addr);
+        debug!(target: "Health Check API", "Starting on: http://{}", bind_addr);
 
         let handle = server::start(bind_addr, tx_start, rx_halt, register);
 
         if let Ok(()) = handle.await {
-            info!(target: "Health Check API", "Stopped server running on: http://{}", bind_addr);
+            debug!(target: "Health Check API", "Stopped server running on: http://{}", bind_addr);
         }
     });
 
     // Wait until the API server job is running
     match rx_start.await {
-        Ok(msg) => info!(target: "Health Check API", "Started on: http://{}", msg.address),
+        Ok(msg) => debug!(target: "Health Check API", "Started on: http://{}", msg.address),
         Err(e) => panic!("the Health Check API server was dropped: {e}"),
     }
 

src/bootstrap/jobs/health_check_api.rs

@@ -14,9 +14,9 @@ use std::net::SocketAddr;
 use std::sync::Arc;
 
 use axum_server::tls_rustls::RustlsConfig;
-use log::info;
 use tokio::task::JoinHandle;
 use torrust_tracker_configuration::HttpTracker;
+use tracing::debug;
 
 use super::make_rust_tls;
 use crate::app::RegistrationForm;
@@ -53,7 +53,7 @@ pub async fn start_job(
             Version::V1 => Some(start_v1(socket, tls, tracker.clone(), form).await),
         }
     } else {
-        info!("Note: Not loading Http Tracker Service, Not Enabled in Configuration.");
+        debug!("Note: Not loading Http Tracker Service, Not Enabled in Configuration.");
         None
     }
 }

src/bootstrap/jobs/http_tracker.rs

@@ -22,13 +22,13 @@ pub struct Started {
 
 pub async fn make_rust_tls(enabled: bool, cert: &Option<String>, key: &Option<String>) -> Option<Result<RustlsConfig, Error>> {
     if !enabled {
-        info!("TLS not enabled");
+        debug!("TLS not enabled");
         return None;
     }
 
     if let (Some(cert), Some(key)) = (cert, key) {
-        info!("Using https: cert path: {cert}.");
-        info!("Using https: key path: {cert}.");
+        debug!("Using https: cert path: {cert}.");
+        debug!("Using https: key path: {cert}.");
 
         Some(
             RustlsConfig::from_pem_file(cert, key)
@@ -77,9 +77,9 @@ use std::panic::Location;
 use std::sync::Arc;
 
 use axum_server::tls_rustls::RustlsConfig;
-use log::info;
 use thiserror::Error;
 use torrust_tracker_located_error::{DynError, LocatedError};
+use tracing::debug;
 
 /// Error returned by the Bootstrap Process.
 #[derive(Error, Debug)]