feat: [#1495] expose new torrent-repositoru metrics via the REST API

These are the new metrics in JSON format:

http://localhost:1212/api/v1/metrics?token=MyAccessToken

```json
{
  "metrics": [
    {
      "kind": "counter",
      "name": "torrent_repository_persistent_torrents_downloads_total",
      "samples": []
    },
    {
      "kind": "counter",
      "name": "torrent_repository_runtime_torrents_downloads_total",
      "samples": []
    }
  ]
}
```

Author: josecelano

packages/axum-rest-tracker-api-server/src/environment.rs

@@ -189,6 +189,7 @@ impl EnvContainer {
         let udp_tracker_server_container = UdpTrackerServerContainer::initialize(&core_config);
 
         let tracker_http_api_core_container = TrackerHttpApiCoreContainer::initialize_from(
+            &torrent_repository_container,
             &tracker_core_container,
             &http_tracker_core_container,
             &udp_tracker_core_container,

packages/axum-rest-tracker-api-server/src/v1/context/stats/handlers.rs

@@ -69,6 +69,7 @@ pub async fn get_metrics_handler(
     State(state): State<(
         Arc<InMemoryTorrentRepository>,
         Arc<RwLock<BanService>>,
+        Arc<torrust_tracker_torrent_repository::statistics::repository::Repository>,
         Arc<bittorrent_http_tracker_core::statistics::repository::Repository>,
         Arc<bittorrent_udp_tracker_core::statistics::repository::Repository>,
         Arc<torrust_udp_tracker_server::statistics::repository::Repository>,
@@ -81,6 +82,7 @@ pub async fn get_metrics_handler(
         state.2.clone(),
         state.3.clone(),
         state.4.clone(),
+        state.5.clone(),
     )
     .await;
 

packages/axum-rest-tracker-api-server/src/v1/context/stats/routes.rs

@@ -28,6 +28,7 @@ pub fn add(prefix: &str, router: Router, http_api_container: &Arc<TrackerHttpApi
             get(get_metrics_handler).with_state((
                 http_api_container.tracker_core_container.in_memory_torrent_repository.clone(),
                 http_api_container.ban_service.clone(),
+                http_api_container.torrent_repository_container.stats_repository.clone(),
                 http_api_container.http_stats_repository.clone(),
                 http_api_container.udp_core_stats_repository.clone(),
                 http_api_container.udp_server_stats_repository.clone(),

packages/rest-tracker-api-core/src/container.rs

@@ -12,8 +12,17 @@ use torrust_udp_tracker_server::container::UdpTrackerServerContainer;
 
 pub struct TrackerHttpApiCoreContainer {
     pub http_api_config: Arc<HttpApi>,
+
+    // Torrent repository
+    pub torrent_repository_container: Arc<TorrentRepositoryContainer>,
+
+    // Tracker core
     pub tracker_core_container: Arc<TrackerCoreContainer>,
+
+    // HTTP tracker core
     pub http_stats_repository: Arc<bittorrent_http_tracker_core::statistics::repository::Repository>,
+
+    // UDP tracker core
     pub ban_service: Arc<RwLock<BanService>>,
     pub udp_core_stats_repository: Arc<bittorrent_udp_tracker_core::statistics::repository::Repository>,
     pub udp_server_stats_repository: Arc<torrust_udp_tracker_server::statistics::repository::Repository>,
@@ -43,6 +52,7 @@ impl TrackerHttpApiCoreContainer {
         let udp_tracker_server_container = UdpTrackerServerContainer::initialize(core_config);
 
         Self::initialize_from(
+            &torrent_repository_container,
             &tracker_core_container,
             &http_tracker_core_container,
             &udp_tracker_core_container,
@@ -53,23 +63,29 @@ impl TrackerHttpApiCoreContainer {
 
     #[must_use]
     pub fn initialize_from(
+        torrent_repository_container: &Arc<TorrentRepositoryContainer>,
         tracker_core_container: &Arc<TrackerCoreContainer>,
         http_tracker_core_container: &Arc<HttpTrackerCoreContainer>,
         udp_tracker_core_container: &Arc<UdpTrackerCoreContainer>,
         udp_tracker_server_container: &Arc<UdpTrackerServerContainer>,
         http_api_config: &Arc<HttpApi>,
     ) -> Arc<TrackerHttpApiCoreContainer> {
         Arc::new(TrackerHttpApiCoreContainer {
+            http_api_config: http_api_config.clone(),
+
+            // Torrent repository
+            torrent_repository_container: torrent_repository_container.clone(),
+
+            // Tracker core
             tracker_core_container: tracker_core_container.clone(),
 
+            // HTTP tracker core
             http_stats_repository: http_tracker_core_container.stats_repository.clone(),
 
+            // UDP tracker core
             ban_service: udp_tracker_core_container.ban_service.clone(),
             udp_core_stats_repository: udp_tracker_core_container.stats_repository.clone(),
-
             udp_server_stats_repository: udp_tracker_server_container.stats_repository.clone(),
-
-            http_api_config: http_api_config.clone(),
         })
     }
 }

packages/rest-tracker-api-core/src/statistics/services.rs

@@ -93,19 +93,25 @@ pub struct TrackerLabeledMetrics {
 pub async fn get_labeled_metrics(
     in_memory_torrent_repository: Arc<InMemoryTorrentRepository>,
     ban_service: Arc<RwLock<BanService>>,
+    swarms_stats_repository: Arc<torrust_tracker_torrent_repository::statistics::repository::Repository>,
     http_stats_repository: Arc<bittorrent_http_tracker_core::statistics::repository::Repository>,
     udp_stats_repository: Arc<bittorrent_udp_tracker_core::statistics::repository::Repository>,
     udp_server_stats_repository: Arc<udp_server_statistics::repository::Repository>,
 ) -> TrackerLabeledMetrics {
     let _torrents_metrics = in_memory_torrent_repository.get_aggregate_swarm_metadata();
     let _udp_banned_ips_total = ban_service.read().await.get_banned_ips_total();
 
+    let swarms_stats = swarms_stats_repository.get_metrics().await;
     let http_stats = http_stats_repository.get_stats().await;
     let udp_stats_repository = udp_stats_repository.get_stats().await;
     let udp_server_stats = udp_server_stats_repository.get_stats().await;
 
     // Merge all the metrics into a single collection
     let mut metrics = MetricCollection::default();
+
+    metrics
+        .merge(&swarms_stats.metric_collection)
+        .expect("msg: failed to merge torrent repository metrics");
     metrics
         .merge(&http_stats.metric_collection)
         .expect("msg: failed to merge HTTP core metrics");

src/container.rs

@@ -142,10 +142,15 @@ impl AppContainer {
     #[must_use]
     pub fn tracker_http_api_container(&self, http_api_config: &Arc<HttpApi>) -> Arc<TrackerHttpApiCoreContainer> {
         TrackerHttpApiCoreContainer {
-            tracker_core_container: self.tracker_core_container.clone(),
             http_api_config: http_api_config.clone(),
-            ban_service: self.udp_tracker_core_services.ban_service.clone(),
+
+            torrent_repository_container: self.torrent_repository_container.clone(),
+
+            tracker_core_container: self.tracker_core_container.clone(),
+
             http_stats_repository: self.http_tracker_core_services.stats_repository.clone(),
+
+            ban_service: self.udp_tracker_core_services.ban_service.clone(),
             udp_core_stats_repository: self.udp_tracker_core_services.stats_repository.clone(),
             udp_server_stats_repository: self.udp_tracker_server_container.stats_repository.clone(),
         }