feat: upgraded deps, rust version and edition

Author: andrew-james-dev

frameworks/Rust/axum/Cargo.lock

@@ -2,7 +2,7 @@
 name = "axum-techempower"
 version = "0.2.1"
 authors = ["Dragos Varovici <[email protected]>"]
-edition = "2021"
+edition = "2024"
 
 [[bin]]
 name = "axum"
@@ -39,49 +39,49 @@ simd-json = [
 ]
 
 [dependencies]
-axum = { version = "0.7.9", default-features = false, features = [
+axum = { version = "0.8.3", default-features = false, features = [
     "json",
     "query",
     "http1",
     "tokio",
 ] }
-deadpool = { version = "0.12.1", features = ["rt_tokio_1", "serde", "managed"] }
+deadpool = { version = "0.12.2", features = ["rt_tokio_1", "serde", "managed"] }
 deadpool-postgres = { version = "0.14.1", features = ["rt_tokio_1", "serde"] }
 dotenv = "0.15.0"
 futures = "0.3.31"
 futures-util = "0.3.31"
-mongodb = { version = "3.1.1", features = [
+mongodb = { version = "3.2.3", features = [
     "zstd-compression",
     "snappy-compression",
     "zlib-compression",
 ] }
 num_cpus = "1.16.0"
-rand = { version = "0.8.5", features = ["small_rng"] }
-serde = { version = "1.0.216", features = ["derive"] }
-serde_json = "1.0.134"
-sqlx = { version = "0.8.2", features = [
+rand = { version = "0.9.0", features = ["small_rng"] }
+serde = { version = "1.0.219", features = ["derive"] }
+serde_json = "1.0.140"
+sqlx = { version = "0.8.3", features = [
     "postgres",
     "macros",
     "runtime-tokio",
     "tls-rustls",
 ] }
-tokio = { version = "1.42.0", features = ["full"] }
+tokio = { version = "1.44.2", features = ["full"] }
 tokio-pg-mapper = { version = "0.2.0" }
 tokio-pg-mapper-derive = { version = "0.2.0" }
-tokio-postgres = { version = "0.7.12" }
+tokio-postgres = { version = "0.7.13" }
 tower = { version = "0.5.2", features = ["util"] }
 tower-http = { version = "0.6.2", features = ["set-header"] }
 yarte = "0.15.7"
-simd-json = { version = "0.14.3", optional = true }
-axum-core = { version = "0.4.5", optional = true }
+simd-json = { version = "0.15.0", optional = true }
+axum-core = { version = "0.5.2", optional = true }
 mime = { version = "0.3.17", optional = true }
-bytes = { version = "1.9.0", optional = true }
-serde_path_to_error = { version = "0.1.16", optional = true }
-socket2 = "0.5.8"
-hyper = { version = "1.5", features = ["server", "http1"] }
+bytes = { version = "1.10.1", optional = true }
+serde_path_to_error = { version = "0.1.17", optional = true }
+socket2 = "0.5.9"
+hyper = { version = "1.6", features = ["server", "http1"] }
 hyper-util = { version = "0.1", features = ["tokio", "server-auto", "http1"] }
-quick_cache = "0.6.9"
-mimalloc = "0.1.43"
+quick_cache = "0.6.12"
+mimalloc = "0.1.45"
 
 
 [profile.release]

frameworks/Rust/axum/Cargo.toml

@@ -1,7 +1,7 @@
 use std::{env, str::FromStr};
 
 use core::fmt::Debug;
-use rand::{distributions::Uniform, rngs::SmallRng, Rng};
+use rand::{distr::Uniform, rngs::SmallRng, Rng};
 pub mod models;
 pub mod utils;
 
@@ -37,13 +37,13 @@ where
 #[allow(dead_code)]
 #[inline(always)]
 pub fn random_id(rng: &mut SmallRng) -> i32 {
-    rng.gen_range(1..10_001)
+    rng.random_range(1..=10_000)
 }
 
 /// Generate an iterator of integers in the range 1 to 10,000 (inclusive)
 #[allow(dead_code)]
 #[inline(always)]
 pub fn random_ids(rng: &mut SmallRng, count: usize) -> impl Iterator<Item = i32> + use<'_> {
-    rng.sample_iter(Uniform::new(1, 10_001))
+    rng.sample_iter(Uniform::new_inclusive(1, 10_000).unwrap())
         .take(count)
 }

frameworks/Rust/axum/src/common/mod.rs

@@ -21,7 +21,7 @@ use mongodb::{
     options::{ClientOptions, Compressor},
     Client,
 };
-use rand::{rngs::SmallRng, thread_rng, Rng, SeedableRng};
+use rand::{rngs::SmallRng, rng, Rng, SeedableRng};
 use yarte::Template;
 use mimalloc::MiMalloc;
 
@@ -43,9 +43,9 @@ pub struct FortunesTemplate<'a> {
 }
 
 async fn db(DatabaseConnection(db): DatabaseConnection) -> impl IntoResponse {
-    let mut rng = SmallRng::from_rng(&mut thread_rng()).unwrap();
+    let mut rng = SmallRng::from_rng(&mut rng());
 
-    let random_id = (rng.gen::<u32>() % 10_000 + 1) as i32;
+    let random_id = rng.random_range(1..=10_000) as i32;
 
     let world = find_world_by_id(db, random_id)
         .await
@@ -60,7 +60,7 @@ async fn queries(
 ) -> impl IntoResponse {
     let q = parse_params(params);
 
-    let mut rng = SmallRng::from_rng(&mut thread_rng()).unwrap();
+    let mut rng = SmallRng::from_rng(&mut rng());
     let worlds = find_worlds(db, &mut rng, q).await;
     let results = worlds.expect("worlds could not be retrieved");
 
@@ -73,7 +73,7 @@ async fn updates(
 ) -> impl IntoResponse {
     let q = parse_params(params);
 
-    let mut rng = SmallRng::from_rng(&mut thread_rng()).unwrap();
+    let mut rng = SmallRng::from_rng(&mut rng());
 
     let worlds = find_worlds(db.clone(), &mut  rng, q)
         .await

frameworks/Rust/axum/src/main_mongo.rs

@@ -32,10 +32,10 @@ use mongodb::{
     options::{ClientOptions, Compressor},
     Client,
 };
-use rand::{rngs::SmallRng, thread_rng, SeedableRng};
+use rand::{rngs::SmallRng, rng, SeedableRng};
 
 async fn db(DatabaseConnection(db): DatabaseConnection) -> impl IntoResponse {
-    let mut rng = SmallRng::from_rng(&mut thread_rng()).unwrap();
+    let mut rng = SmallRng::from_rng(&mut rng());
 
     let random_id = random_id(&mut rng);
 
@@ -52,7 +52,7 @@ async fn queries(
 ) -> impl IntoResponse {
     let q = parse_params(params);
 
-    let mut rng = SmallRng::from_rng(&mut thread_rng()).unwrap();
+    let mut rng = SmallRng::from_rng(&mut rng());
     let worlds = find_worlds(db, &mut rng, q).await;
     let results = worlds.expect("worlds could not be retrieved");
 
@@ -65,7 +65,7 @@ async fn updates(
 ) -> impl IntoResponse {
     let q = parse_params(params);
 
-    let mut rng = SmallRng::from_rng(&mut thread_rng()).unwrap();
+    let mut rng = SmallRng::from_rng(&mut rng());
 
     let worlds = find_worlds(db.clone(), &mut rng, q)
         .await

frameworks/Rust/axum/src/main_mongo_raw.rs

@@ -5,7 +5,7 @@ use axum::{
     extract::Query, http::StatusCode, response::IntoResponse, routing::get, Router,
 };
 use dotenv::dotenv;
-use rand::{rngs::SmallRng, thread_rng, SeedableRng};
+use rand::{rngs::SmallRng, rng, SeedableRng};
 use yarte::Template;
 use mimalloc::MiMalloc;
 
@@ -33,7 +33,7 @@ pub struct FortunesTemplate<'a> {
 }
 
 async fn db(DatabaseConnection(conn): DatabaseConnection) -> impl IntoResponse {
-    let mut rng = SmallRng::from_rng(&mut thread_rng()).unwrap();
+    let mut rng = SmallRng::from_rng(&mut rng());
 
     let world = conn
         .fetch_world_by_id(random_id(&mut rng))

frameworks/Rust/axum/src/main_pg.rs

@@ -13,7 +13,7 @@ use common::simd_json::Json;
 use common::{random_ids, SELECT_ALL_FORTUNES, SELECT_WORLD_BY_ID, UPDATE_WORLDS};
 use dotenv::dotenv;
 use futures_util::{stream::FuturesUnordered, TryStreamExt};
-use rand::{rngs::SmallRng, thread_rng, SeedableRng};
+use rand::{rngs::SmallRng, rng, SeedableRng};
 use yarte::Template;
 use mimalloc::MiMalloc;
 
@@ -38,7 +38,7 @@ pub struct FortunesTemplate<'a> {
 }
 
 async fn db(DatabaseClient(client): DatabaseClient) -> impl IntoResponse {
-    let mut rng = SmallRng::from_rng(&mut thread_rng()).unwrap();
+    let mut rng = SmallRng::from_rng(&mut rng());
     let random_id = random_id(&mut rng);
 
     let select = &client.prepare_cached(SELECT_WORLD_BY_ID).await.unwrap();
@@ -55,7 +55,7 @@ async fn queries(
 ) -> impl IntoResponse {
     let q = parse_params(params);
 
-    let mut rng = SmallRng::from_rng(&mut thread_rng()).unwrap();
+    let mut rng = SmallRng::from_rng(&mut rng());
     let select = &client.prepare_cached(SELECT_WORLD_BY_ID).await.unwrap();
     let future_worlds = FuturesUnordered::new();
 
@@ -98,7 +98,7 @@ async fn updates(
 ) -> impl IntoResponse {
     let q = parse_params(params);
 
-    let mut rng = SmallRng::from_entropy();
+    let mut rng = SmallRng::from_rng(&mut rng());
     let select = &client.prepare_cached(SELECT_WORLD_BY_ID).await.unwrap();
     let update = &client.prepare_cached(UPDATE_WORLDS).await.unwrap();
 

frameworks/Rust/axum/src/main_pg_pool.rs

@@ -13,7 +13,7 @@ use axum::{
 };
 use dotenv::dotenv;
 use quick_cache::sync::Cache;
-use rand::{rngs::SmallRng, thread_rng, SeedableRng};
+use rand::{rngs::SmallRng, rng, SeedableRng};
 use sqlx::models::World;
 use yarte::Template;
 use mimalloc::MiMalloc;
@@ -42,7 +42,7 @@ pub struct FortunesTemplate<'a> {
 }
 
 async fn db(State(AppState { db, .. }): State<AppState>) -> impl IntoResponse {
-    let mut rng = SmallRng::from_rng(&mut thread_rng()).unwrap();
+    let mut rng = SmallRng::from_rng(&mut rng());
 
     let world: World = ::sqlx::query_as(common::SELECT_WORLD_BY_ID)
         .bind(random_id(&mut rng))
@@ -57,7 +57,7 @@ async fn queries(
     State(AppState { db, .. }): State<AppState>,
     Query(params): Query<Params>,
 ) -> impl IntoResponse {
-    let mut rng = SmallRng::from_rng(&mut thread_rng()).unwrap();
+    let mut rng = SmallRng::from_rng(&mut rng());
     let count = parse_params(params);
     let mut worlds: Vec<World> = Vec::with_capacity(count);
 
@@ -100,7 +100,7 @@ async fn cache(
     Query(params): Query<Params>,
 ) -> impl IntoResponse {
     let count = parse_params(params);
-    let mut rng = SmallRng::from_rng(&mut thread_rng()).unwrap();
+    let mut rng = SmallRng::from_rng(&mut rng());
     let mut worlds: Vec<Option<World>> = Vec::with_capacity(count);
 
     for id in random_ids(&mut rng, count) {

frameworks/Rust/axum/src/main_sqlx.rs

@@ -1,6 +1,6 @@
 use std::{convert::Infallible, io};
 
-use axum::{async_trait, extract::FromRequestParts, http::request::Parts};
+use axum::{extract::FromRequestParts, http::request::Parts};
 use futures_util::{stream::FuturesUnordered, StreamExt, TryStreamExt};
 use mongodb::{bson::doc, Database};
 use rand::rngs::SmallRng;
@@ -9,7 +9,6 @@ use crate::common::{models::{Fortune, World}, random_ids};
 
 pub struct DatabaseConnection(pub Database);
 
-#[async_trait]
 impl FromRequestParts<Database> for DatabaseConnection {
     type Rejection = Infallible;
 

frameworks/Rust/axum/src/mongo/database.rs

@@ -1,6 +1,6 @@
 use std::{convert::Infallible, io};
 
-use axum::{async_trait, extract::FromRequestParts, http::request::Parts};
+use axum::{extract::FromRequestParts, http::request::Parts};
 use futures_util::{stream::FuturesUnordered, TryStreamExt};
 use mongodb::{
     bson::{doc, RawDocumentBuf},
@@ -12,7 +12,6 @@ use crate::common::{models::World, random_ids};
 
 pub struct DatabaseConnection(pub Database);
 
-#[async_trait]
 impl FromRequestParts<Database> for DatabaseConnection {
     type Rejection = Infallible;