new players

Author: hry-gh

src/main.rs

@@ -23,6 +23,7 @@ mod admin;
 mod byond;
 mod connections;
 mod logging;
+mod new_players;
 mod player;
 mod stickyban;
 mod ticket;
@@ -99,7 +100,7 @@ fn rocket() -> _ {
                 player::new_note,
                 player::applied_notes,
                 player::get_playtime,
-                player::get_recent_playtime
+                player::get_recent_playtime,
             ],
         )
         .mount(
@@ -137,4 +138,8 @@ fn rocket() -> _ {
             format!("{base_url}/Whitelist"),
             routes![whitelist::get_all_whitelistees],
         )
+        .mount(
+            format!{"{}/NewPlayers", base_url},
+            routes![new_players::get_new_players],
+        )
 }

src/new_players.rs

@@ -0,0 +1,24 @@
+use rocket::serde::json::Json;
+use rocket_db_pools::Connection;
+use sqlx::query_as;
+
+use crate::{player::Player, Cmdb};
+
+#[get("/<minutes>")]
+pub async fn get_new_players(mut db: Connection<Cmdb>, minutes: i64) -> Json<Vec<Player>> {
+    let time_ago = format!(
+        "{}",
+        (chrono::Utc::now() - chrono::Duration::minutes(minutes)).format("%Y-%m-%d %H:%M:%S")
+    );
+
+    match query_as("SELECT * FROM players WHERE first_join_date <> \"UNKNOWN\" AND first_join_date > ? ORDER BY first_join_date ASC")
+        .bind(time_ago)
+        .fetch_all(&mut **db)
+        .await
+    {
+        Ok(result) => Json(result),
+        Err(_) => {
+            Json(Vec::new())
+        }
+    }
+}