TechEmpower
diff --git a/‎frameworks/Rust/hyperlane/Cargo.lock
Lines changed: 37 additions & 20 deletions b/‎frameworks/Rust/hyperlane/Cargo.lock
Lines changed: 37 additions & 20 deletions
diff --git a/‎frameworks/Rust/hyperlane/Cargo.toml
Lines changed: 3 additions & 3 deletions b/‎frameworks/Rust/hyperlane/Cargo.toml
Lines changed: 3 additions & 3 deletions
diff --git a/‎frameworks/Rust/hyperlane/src/db.rs renamed to ‎frameworks/Rust/hyperlane/src/db/fn.rs
Lines changed: 10 additions & 10 deletions b/‎frameworks/Rust/hyperlane/src/db.rs renamed to ‎frameworks/Rust/hyperlane/src/db/fn.rs
Lines changed: 10 additions & 10 deletions
diff --git a/‎frameworks/Rust/hyperlane/src/db/mod.rs
Lines changed: 9 additions & 0 deletions b/‎frameworks/Rust/hyperlane/src/db/mod.rs
Lines changed: 9 additions & 0 deletions
diff --git a/‎frameworks/Rust/hyperlane/src/lazy.rs renamed to ‎frameworks/Rust/hyperlane/src/db/static.rs b/‎frameworks/Rust/hyperlane/src/lazy.rs renamed to ‎frameworks/Rust/hyperlane/src/db/static.rs
diff --git a/‎frameworks/Rust/hyperlane/src/db/type.rs
Lines changed: 3 additions & 0 deletions b/‎frameworks/Rust/hyperlane/src/db/type.rs
Lines changed: 3 additions & 0 deletions
diff --git a/‎frameworks/Rust/hyperlane/src/main.rs
Lines changed: 5 additions & 13 deletions b/‎frameworks/Rust/hyperlane/src/main.rs
Lines changed: 5 additions & 13 deletions
diff --git a/‎frameworks/Rust/hyperlane/src/request_middleware.rs renamed to ‎frameworks/Rust/hyperlane/src/middleware/fn.rs b/‎frameworks/Rust/hyperlane/src/request_middleware.rs renamed to ‎frameworks/Rust/hyperlane/src/middleware/fn.rs
diff --git a/‎frameworks/Rust/hyperlane/src/middleware/mod.rs
Lines changed: 5 additions & 0 deletions b/‎frameworks/Rust/hyperlane/src/middleware/mod.rs
Lines changed: 5 additions & 0 deletions
diff --git a/‎frameworks/Rust/hyperlane/src/route.rs renamed to ‎frameworks/Rust/hyperlane/src/route/fn.rs
Lines changed: 4 additions & 4 deletions b/‎frameworks/Rust/hyperlane/src/route.rs renamed to ‎frameworks/Rust/hyperlane/src/route/fn.rs
Lines changed: 4 additions & 4 deletions
@@ -20,13 +20,13 @@ exclude = [
 
 [dependencies]
 futures = "0.3.31"
-hyperlane = "7.6.1"
-hyperlane-time = "0.7.7"
+hyperlane = "8.1.2"
+hyperlane-time = "0.7.8"
 num_cpus = "1.17.0"
 once_cell = "1.21.3"
 rand = "0.9.2"
 serde = "1.0.219"
-serde_json = "1.0.142"
+serde_json = "1.0.143"
 sqlx = { version = "0.8.6", features = ["runtime-tokio", "postgres"] }
 
 [profile.dev]
 
@@ -7,23 +7,23 @@ pub fn get_db_connection() -> &'static DbPoolConnection {
 #[cfg(feature = "dev")]
 pub async fn create_database() {
     let db_pool: &DbPoolConnection = get_db_connection();
-    let _ = query(&format!("CREATE DATABASE {};", DATABASE_NAME))
+    let _ = db_query(&format!("CREATE DATABASE {};", DATABASE_NAME))
         .execute(db_pool)
         .await;
 }
 
 #[cfg(feature = "dev")]
 pub async fn create_table() {
     let db_pool: &DbPoolConnection = get_db_connection();
-    let _ = query(&format!(
+    let _ = db_query(&format!(
         "CREATE TABLE IF NOT EXISTS {} (
             id SERIAL PRIMARY KEY, randomNumber INT NOT NULL
         );",
         TABLE_NAME_WORLD
     ))
     .execute(db_pool)
     .await;
-    let _ = query(&format!(
+    let _ = db_query(&format!(
         "CREATE TABLE IF NOT EXISTS {} (
             id SERIAL PRIMARY KEY, message VARCHAR NOT NULL
         );",
@@ -36,7 +36,7 @@ pub async fn create_table() {
 #[cfg(feature = "dev")]
 pub async fn insert_records() {
     let db_pool: &DbPoolConnection = get_db_connection();
-    let row: PgRow = query(&format!("SELECT COUNT(*) FROM {}", TABLE_NAME_WORLD))
+    let row: PgRow = db_query(&format!("SELECT COUNT(*) FROM {}", TABLE_NAME_WORLD))
         .fetch_one(db_pool)
         .await
         .unwrap();
@@ -56,7 +56,7 @@ pub async fn insert_records() {
         TABLE_NAME_WORLD,
         values.join(",")
     );
-    let _ = query(&sql).execute(db_pool).await;
+    let _ = db_query(&sql).execute(db_pool).await;
     let mut values: Vec<String> = Vec::new();
     for _ in 0..missing_count {
         let random_number: i32 = get_random_id();
@@ -67,7 +67,7 @@ pub async fn insert_records() {
         TABLE_NAME_FORTUNE,
         values.join(",")
     );
-    let _ = query(&sql).execute(db_pool).await;
+    let _ = db_query(&sql).execute(db_pool).await;
 }
 
 pub async fn init_cache() -> Vec<QueryRow> {
@@ -77,7 +77,7 @@ pub async fn init_cache() -> Vec<QueryRow> {
         "SELECT id, randomNumber FROM {} LIMIT {}",
         TABLE_NAME_WORLD, RANDOM_MAX
     );
-    if let Ok(rows) = query(&sql).fetch_all(db_pool).await {
+    if let Ok(rows) = db_query(&sql).fetch_all(db_pool).await {
         for row in rows {
             let id: i32 = row.get(KEY_ID);
             let random_number: i32 = row.get(KEY_RANDOM_NUMBER);
@@ -146,7 +146,7 @@ pub async fn random_world_row(db_pool: &DbPoolConnection) -> QueryRow {
 
 pub async fn query_world_row(db_pool: &DbPoolConnection, id: Queries) -> QueryRow {
     let sql: &str = "SELECT id, randomNumber FROM World WHERE id = $1";
-    if let Ok(rows) = query(sql).bind(id).fetch_one(db_pool).await {
+    if let Ok(rows) = db_query(sql).bind(id).fetch_one(db_pool).await {
         let random_number: i32 = rows.get(KEY_RANDOM_NUMBER);
         return QueryRow::new(id as i32, random_number);
     }
@@ -161,7 +161,7 @@ pub async fn update_world_rows(limit: Queries) -> Vec<QueryRow> {
     for (id, random_number) in id_list.into_iter().zip(random_numbers.into_iter()) {
         let db_pool: Pool<Postgres> = db_pool.clone();
         tasks.push(spawn(async move {
-            query(sql)
+            db_query(sql)
                 .bind(random_number)
                 .bind(id)
                 .execute(&db_pool)
@@ -175,7 +175,7 @@ pub async fn update_world_rows(limit: Queries) -> Vec<QueryRow> {
 pub async fn all_world_row() -> Vec<PgRow> {
     let db_pool: &DbPoolConnection = get_db_connection();
     let sql: String = format!("SELECT id, message FROM {}", TABLE_NAME_FORTUNE);
-    let res: Vec<PgRow> = query(&sql).fetch_all(db_pool).await.unwrap_or_default();
+    let res: Vec<PgRow> = db_query(&sql).fetch_all(db_pool).await.unwrap_or_default();
     return res;
 }
 
 
@@ -0,0 +1,9 @@
+pub(crate) mod r#fn;
+pub(crate) mod r#static;
+pub(crate) mod r#type;
+
+pub use r#fn::*;
+pub use r#static::*;
+pub use r#type::*;
+
+use super::*;
@@ -0,0 +1,3 @@
+use super::*;
+
+pub type DbPoolConnection = Pool<Postgres>;
@@ -1,41 +1,33 @@
-#![allow(dead_code)]
-#![allow(unused_imports)]
-pub(crate) mod r#const;
 pub(crate) mod db;
-pub(crate) mod lazy;
-pub(crate) mod request_middleware;
+pub(crate) mod middleware;
 pub(crate) mod route;
 pub(crate) mod server;
-pub(crate) mod r#type;
 pub(crate) mod utils;
 
-pub(crate) use r#const::*;
 pub(crate) use db::*;
-pub(crate) use r#type::*;
+pub(crate) use server::*;
 pub(crate) use utils::*;
 
-pub(crate) use std::{fmt, hint::black_box, sync::Arc};
+pub(crate) use std::fmt;
 
 pub(crate) use futures::{executor::block_on, future::join_all};
 pub(crate) use hyperlane::{
     tokio::{
         runtime::{Builder, Runtime},
         spawn,
-        sync::{AcquireError, OwnedSemaphorePermit, Semaphore},
         task::JoinHandle,
     },
     *,
 };
 pub(crate) use hyperlane_time::*;
-pub(crate) use lazy::*;
 pub(crate) use once_cell::sync::Lazy;
 pub(crate) use rand::{Rng, SeedableRng, rng, rngs::SmallRng};
 pub(crate) use serde::*;
 pub(crate) use serde_json::{Value, json};
-pub(crate) use server::*;
 pub(crate) use sqlx::{
+    Pool, Postgres, Row,
     postgres::{PgPoolOptions, PgRow},
-    *,
+    query as db_query,
 };
 
 fn main() {
 
@@ -0,0 +1,5 @@
+pub(crate) mod r#fn;
+
+pub use r#fn::*;
+
+use super::*;
@@ -49,7 +49,7 @@ pub async fn db(ctx: Context) {
 pub async fn query(ctx: Context) {
     let run = || async {
         let queries: Queries = ctx
-            .get_request_query("q")
+            .try_get_request_query(QUERY_DB_QUERY_KEY)
             .await
             .and_then(|queries| queries.parse::<Queries>().ok())
             .unwrap_or_default()
@@ -104,7 +104,7 @@ pub async fn fortunes(ctx: Context) {
 pub async fn update(ctx: Context) {
     let run = || async {
         let queries: Queries = ctx
-            .get_request_query("q")
+            .try_get_request_query(UPDATE_DB_QUERY_KEY)
             .await
             .and_then(|queries| queries.parse::<Queries>().ok())
             .unwrap_or_default()
@@ -127,13 +127,13 @@ pub async fn update(ctx: Context) {
 pub async fn cached_query(ctx: Context) {
     let run = || async {
         let count: Queries = ctx
-            .get_request_query("c")
+            .try_get_request_query(CACHE_QUERY_KEY)
             .await
             .and_then(|queries| queries.parse::<Queries>().ok())
             .unwrap_or_default()
             .min(ROW_LIMIT as Queries)
             .max(1);
-        let res: Vec<QueryRow> = CACHE.iter().take(count as usize).cloned().collect();
+        let res: Vec<&QueryRow> = CACHE.iter().take(count as usize).collect();
         ctx.set_response_body(serde_json::to_string(&res).unwrap_or_default())
             .await
             .send()
Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,3 @@`
	`1`	`+use super::*;`
	`2`	`+`
	`3`	`+pub type DbPoolConnection = Pool<Postgres>;`