feat: return snap_name in chart data

Cargo.toml

@@ -18,6 +18,7 @@ skip_cache = []
 cached = { version = "0.54.0", features = ["async"] }
 dotenvy = "0.15"
 envy = "0.4"
+futures = "0.3"
 http = "1.1.0"
 jsonwebtoken = "9.2"
 prost = "0.13.3"

proto/ratings_features_common.proto

@@ -6,6 +6,7 @@ message Rating {
   string snap_id = 1;
   uint64 total_votes = 2;
   RatingsBand ratings_band = 3;
+  string snap_name = 4;
 }
 
 enum RatingsBand {

src/grpc/app.rs

@@ -40,13 +40,15 @@ impl App for RatingService {
                     snap_id,
                     total_votes,
                     ratings_band,
+                    snap_name,
                 } = Rating::from(votes);
 
                 Ok(Response::new(GetRatingResponse {
                     rating: Some(PbRating {
                         snap_id,
                         total_votes,
                         ratings_band: ratings_band as i32,
+                        snap_name,
                     }),
                 }))
             }

src/grpc/charts.rs

@@ -89,7 +89,7 @@ async fn get_chart_cached(
 ) -> Result<Chart, Box<dyn std::error::Error>> {
     let summaries = VoteSummary::get_for_timeframe(timeframe, category, conn!()).await?;
 
-    Ok(Chart::new(timeframe, summaries))
+    Ok(Chart::new(timeframe, summaries, ctx).await?)
 }
 
 impl From<ChartData> for PbChartData {
@@ -107,6 +107,7 @@ impl From<Rating> for PbRating {
             snap_id: r.snap_id,
             total_votes: r.total_votes,
             ratings_band: r.ratings_band as i32,
+            snap_name: r.snap_name,
         }
     }
 }
@@ -117,6 +118,7 @@ impl From<PbRating> for Rating {
             snap_id: r.snap_id,
             total_votes: r.total_votes,
             ratings_band: RatingsBand::from_repr(r.ratings_band).unwrap(),
+            snap_name: r.snap_name,
         }
     }
 }

src/proto/ratings.features.common.rs

@@ -8,6 +8,8 @@ pub struct Rating {
     pub total_votes: u64,
     #[prost(enumeration = "RatingsBand", tag = "3")]
     pub ratings_band: i32,
+    #[prost(string, tag = "4")]
+    pub snap_name: ::prost::alloc::string::String,
 }
 #[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, PartialOrd, Ord, ::prost::Enumeration)]
 #[repr(i32)]

src/ratings/charts.rs

@@ -1,7 +1,14 @@
 //! Struct definitions for the charting feature for ratings.
+use futures::future::try_join_all;
+
 use crate::{
     db::{Timeframe, VoteSummary},
-    ratings::rating::{calculate_band, Rating},
+    ratings::{
+        get_snap_name,
+        rating::{calculate_band, Rating},
+        Error,
+    },
+    Context,
 };
 use std::cmp::Ordering;
 
@@ -12,8 +19,22 @@ pub struct Chart {
 }
 
 impl Chart {
-    pub fn new(timeframe: Timeframe, data: Vec<VoteSummary>) -> Self {
-        let mut data: Vec<ChartData> = data.into_iter().map(Into::into).collect();
+    pub async fn new(
+        timeframe: Timeframe,
+        data: Vec<VoteSummary>,
+        ctx: &Context,
+    ) -> Result<Self, Error> {
+        let mut data: Vec<ChartData> = try_join_all(data.into_iter().map(|vote_summary| async {
+            let snap_name = get_snap_name(
+                &vote_summary.snap_id,
+                &ctx.config.snapcraft_io_uri,
+                &ctx.http_client,
+            )
+            .await?;
+
+            Result::<ChartData, Error>::Ok(ChartData::new(vote_summary, &snap_name))
+        }))
+        .await?;
 
         data.sort_by(|a, b| {
             b.raw_rating
@@ -22,10 +43,10 @@ impl Chart {
         });
 
         // Take only the first 20 elements from the sorted chart_data
-        Chart {
+        Ok(Self {
             timeframe,
             data: data.into_iter().take(20).collect(),
-        }
+        })
     }
 }
 
@@ -35,13 +56,14 @@ pub struct ChartData {
     pub rating: Rating,
 }
 
-impl From<VoteSummary> for ChartData {
-    fn from(vote_summary: VoteSummary) -> Self {
+impl ChartData {
+    pub fn new(vote_summary: VoteSummary, snap_name: &str) -> Self {
         let (raw_rating, ratings_band) = calculate_band(&vote_summary);
         let rating = Rating {
             snap_id: vote_summary.snap_id,
             total_votes: vote_summary.total_votes as u64,
             ratings_band,
+            snap_name: snap_name.into(),
         };
         let raw_rating = raw_rating.unwrap_or(0.0) as f32;
 

src/ratings/rating.rs

@@ -68,6 +68,8 @@ pub struct Rating {
     /// The descriptive indicator of "how good" this snap is based
     /// on aggregated ratings.
     pub ratings_band: RatingsBand,
+    /// The unique name of the snap.
+    pub snap_name: String,
 }
 
 impl From<VoteSummary> for Rating {
@@ -78,6 +80,7 @@ impl From<VoteSummary> for Rating {
             snap_id: votes.snap_id,
             total_votes: votes.total_votes as u64,
             ratings_band,
+            snap_name: "".into(),
         }
     }
 }