feat: add competition ranking to leaderboard

Cargo.toml

@@ -31,7 +31,7 @@ doc = false
 
 
 [dependencies]
-momento-protos = { version = "0.120.0" }
+momento-protos = { version = "0.122.1" }
 log = "0.4"
 hyper = { version = "0.14" }
 h2 = { version = "0.3" }

src/leaderboard/leaderboard_resource.rs

@@ -4,6 +4,9 @@ use crate::leaderboard::messages::data::delete::{DeleteRequest, DeleteResponse};
 use crate::leaderboard::messages::data::fetch::FetchResponse;
 use crate::leaderboard::messages::data::fetch_by_rank::{FetchByRankRequest, RankRange};
 use crate::leaderboard::messages::data::fetch_by_score::{FetchByScoreRequest, ScoreRange};
+use crate::leaderboard::messages::data::get_competition_rank::{
+    GetCompetitionRankRequest, GetCompetitionRankResponse,
+};
 use crate::leaderboard::messages::data::get_rank::{GetRankRequest, GetRankResponse};
 use crate::leaderboard::messages::data::length::{LengthRequest, LengthResponse};
 use crate::leaderboard::messages::data::remove_elements::{
@@ -103,6 +106,14 @@ impl Leaderboard {
         request.send(self).await
     }
 
+    pub async fn get_competition_rank(
+        &self,
+        ids: impl IntoIterator<Item = u32>,
+    ) -> MomentoResult<GetCompetitionRankResponse> {
+        let request = GetCompetitionRankRequest::new(ids);
+        request.send(self).await
+    }
+
     /* helper fns */
     pub(crate) fn new(
         data_clients: Vec<

src/leaderboard/messages/data/delete.rs

@@ -27,7 +27,6 @@ impl LeaderboardRequest for DeleteRequest {
             cache_name,
             leaderboard.client_timeout(),
             momento_protos::leaderboard::DeleteLeaderboardRequest {
-                cache_name: cache_name.to_string(),
                 leaderboard: leaderboard.leaderboard_name().to_string(),
             },
         )?;

src/leaderboard/messages/data/fetch_by_rank.rs

@@ -101,7 +101,6 @@ impl LeaderboardRequest for FetchByRankRequest {
             cache_name,
             leaderboard.client_timeout(),
             momento_protos::leaderboard::GetByRankRequest {
-                cache_name: cache_name.to_string(),
                 leaderboard: leaderboard.leaderboard_name().to_string(),
                 rank_range: Some(self.rank_range.into()),
                 order: self.order.into_proto() as i32,

src/leaderboard/messages/data/fetch_by_score.rs

@@ -145,7 +145,6 @@ impl LeaderboardRequest for FetchByScoreRequest {
             cache_name,
             leaderboard.client_timeout(),
             momento_protos::leaderboard::GetByScoreRequest {
-                cache_name: cache_name.to_string(),
                 leaderboard: leaderboard.leaderboard_name().to_string(),
                 score_range: Some(self.score_range.into()),
                 offset: self.offset.unwrap_or(0),

src/leaderboard/messages/data/get_competition_rank.rs

@@ -0,0 +1,64 @@
+use super::{Order, RankedElement};
+use crate::leaderboard::LeaderboardRequest;
+use crate::utils::prep_leaderboard_request_with_timeout;
+use crate::{Leaderboard, MomentoResult};
+
+pub struct GetCompetitionRankRequest {
+    ids: Vec<u32>,
+    order: Order,
+}
+
+impl GetCompetitionRankRequest {
+    pub fn new(ids: impl IntoIterator<Item = u32>) -> Self {
+        Self {
+            ids: ids.into_iter().collect(),
+            order: Order::Descending,
+        }
+    }
+
+    pub fn order(mut self, order: Order) -> Self {
+        self.order = order;
+        self
+    }
+}
+
+impl LeaderboardRequest for GetCompetitionRankRequest {
+    type Response = GetCompetitionRankResponse;
+
+    async fn send(self, leaderboard: &Leaderboard) -> MomentoResult<Self::Response> {
+        let cache_name = leaderboard.cache_name();
+        let request = prep_leaderboard_request_with_timeout(
+            cache_name,
+            leaderboard.client_timeout(),
+            momento_protos::leaderboard::GetCompetitionRankRequest {
+                leaderboard: leaderboard.leaderboard_name().to_string(),
+                ids: self.ids,
+                order: Some(self.order.into_proto() as i32),
+            },
+        )?;
+
+        let response = leaderboard
+            .next_data_client()
+            .get_competition_rank(request)
+            .await?
+            .into_inner();
+
+        Ok(Self::Response {
+            elements: response.elements.iter().map(|v| v.into()).collect(),
+        })
+    }
+}
+
+pub struct GetCompetitionRankResponse {
+    elements: Vec<RankedElement>,
+}
+
+impl GetCompetitionRankResponse {
+    pub fn elements(&self) -> &[RankedElement] {
+        &self.elements
+    }
+
+    pub fn into_elements(self) -> Vec<RankedElement> {
+        self.elements
+    }
+}

src/leaderboard/messages/data/get_rank.rs

@@ -39,7 +39,6 @@ impl LeaderboardRequest for GetRankRequest {
             cache_name,
             leaderboard.client_timeout(),
             momento_protos::leaderboard::GetRankRequest {
-                cache_name: cache_name.to_string(),
                 leaderboard: leaderboard.leaderboard_name().to_string(),
                 ids: self.ids,
                 order: self.order.into_proto() as i32,

src/leaderboard/messages/data/length.rs

@@ -27,7 +27,6 @@ impl LeaderboardRequest for LengthRequest {
             cache_name,
             leaderboard.client_timeout(),
             momento_protos::leaderboard::GetLeaderboardLengthRequest {
-                cache_name: cache_name.to_string(),
                 leaderboard: leaderboard.leaderboard_name().to_string(),
             },
         )?;

src/leaderboard/messages/data/mod.rs

@@ -9,6 +9,7 @@ pub mod fetch_by_rank;
 /// Contains the request and response types for requesting elements from a
 /// leaderboard by score.
 pub mod fetch_by_score;
+pub mod get_competition_rank;
 /// Contains the request and response types for requesting elements from a
 /// leaderboard using their element ids.
 pub mod get_rank;

src/leaderboard/messages/data/remove_elements.rs

@@ -26,7 +26,6 @@ impl LeaderboardRequest for RemoveElementsRequest {
             cache_name,
             leaderboard.client_timeout(),
             momento_protos::leaderboard::RemoveElementsRequest {
-                cache_name: cache_name.to_string(),
                 leaderboard: leaderboard.leaderboard_name().to_string(),
                 ids: self.ids,
             },

src/leaderboard/messages/data/upsert.rs

@@ -61,7 +61,6 @@ where
             cache_name,
             leaderboard.client_timeout(),
             momento_protos::leaderboard::UpsertElementsRequest {
-                cache_name: cache_name.to_string(),
                 leaderboard: leaderboard.leaderboard_name().to_string(),
                 elements: self
                     .elements