List recent matches endpoint

Author: jorgeberrex

src/database/mod.rs

@@ -2,6 +2,7 @@ use std::{str::FromStr, time::Duration};
 use std::collections::HashSet;
 
 use mars_api_rs_macro::IdentifiableDocument;
+use mongodb::options::FindOptions;
 use mongodb::{options::{ClientOptions, FindOneOptions, UpdateOptions}, Client, Collection, bson::{doc, oid::ObjectId}, Cursor, results::DeleteResult};
 use models::tag::Tag;
 use rand::Rng;
@@ -202,6 +203,12 @@ impl Database {
         where R: CollectionOwner<R> + Serialize + IdentifiableDocument + DeserializeOwned + Unpin + Send + Sync {
         R::get_collection(&self).find_one(doc! { "nameLower": name.to_lowercase() }, None).await.unwrap_or(None)
     }
+
+    pub async fn get_recent_matches(&self, limit: i64) -> Vec<Match> {
+        let opts = FindOptions::builder().sort(doc! { "loadedAt": -1 }).limit(limit).build();
+        let cursor = self.matches.find(doc! {}, Some(opts)).await.ok();
+        Self::consume_cursor_into_owning_vec_option(cursor).await
+    }
 }
 
 const DB_NAME: &'static str = "mars-api";

src/http/match/mod.rs

@@ -15,6 +15,16 @@ pub async fn matches(
     Ok(JsonResponder::ok(cached_match))
 }
 
+#[get("/?<limit>")]
+pub async fn recent_matches(
+    state: &State<MarsAPIState>,
+    limit: Option<i64>,
+) -> Result<JsonResponder<Vec<Match>>, ApiErrorResponder> {
+    let limit = limit.unwrap_or(5).min(10);
+    let matches = state.database.get_recent_matches(limit).await;
+    Ok(JsonResponder::ok(matches))
+}
+
 pub fn mount(rocket_build: Rocket<Build>) -> Rocket<Build> {
-    rocket_build.mount("/mc/matches", routes![matches])
+    rocket_build.mount("/mc/matches", routes![matches, recent_matches])
 }