feat: remove dyn

Author: eastspire

frameworks/Rust/hyperlane/src/db.rs

@@ -158,7 +158,7 @@ pub async fn init_db() {
 }
 
 #[inline]
-pub async fn random_world_row(db_pool: &DbPoolConnection) -> Result<QueryRow, Box<dyn Error>> {
+pub async fn random_world_row(db_pool: &DbPoolConnection) -> QueryRow {
     let random_id: i32 = rand::rng().random_range(1..=RANDOM_MAX);
     let sql: String = format!(
         "SELECT id, randomNumber FROM {} WHERE id = {}",
@@ -167,19 +167,19 @@ pub async fn random_world_row(db_pool: &DbPoolConnection) -> Result<QueryRow, Bo
     if let Ok(rows) = sqlx::query(&sql).fetch_one(db_pool).await {
         let id: i32 = rows.get(KEY_ID);
         let random_number: i32 = rows.get(KEY_RANDOM_NUMBER);
-        return Ok(QueryRow::new(id, random_number));
+        return QueryRow::new(id, random_number);
     }
-    return Ok(QueryRow::new(1, 1));
+    QueryRow::new(1, 1)
 }
 
 #[inline]
-pub async fn update_world_rows(limit: Queries) -> Result<Vec<QueryRow>, Box<dyn Error>> {
+pub async fn update_world_rows(limit: Queries) -> Vec<QueryRow> {
     let db_pool: DbPoolConnection = get_db_connection().await;
     let (sql, data) = get_update_data(limit).await;
     spawn(async move {
         let _ = sqlx::query(&sql).execute(&db_pool).await;
     });
-    Ok(data)
+    data
 }
 
 #[inline]
@@ -197,7 +197,7 @@ pub async fn all_world_row() -> Vec<PgRow> {
 pub async fn get_some_row_id(limit: Queries, db_pool: &DbPoolConnection) -> Vec<QueryRow> {
     let mut res: Vec<QueryRow> = Vec::with_capacity(limit as usize);
     for _ in 0..limit {
-        let tem: QueryRow = random_world_row(db_pool).await.unwrap_or_default();
+        let tem: QueryRow = random_world_row(db_pool).await;
         res.push(tem);
     }
     res

frameworks/Rust/hyperlane/src/main.rs

@@ -31,7 +31,7 @@ pub(crate) use sqlx::{
     postgres::{PgPoolOptions, PgRow},
     Pool, Postgres, Row,
 };
-pub(crate) use std::{error::Error, fmt, sync::Arc};
+pub(crate) use std::{fmt, sync::Arc};
 pub(crate) use utils::*;
 
 #[tokio::main]

frameworks/Rust/hyperlane/src/route.rs

@@ -22,7 +22,7 @@ pub async fn plaintext(controller_data: ControllerData) {
 #[inline]
 pub async fn db(controller_data: ControllerData) {
     let db_connection: DbPoolConnection = get_db_connection().await;
-    let query_row: QueryRow = random_world_row(&db_connection).await.unwrap();
+    let query_row: QueryRow = random_world_row(&db_connection).await;
     let _ = controller_data
         .set_response_body(serde_json::to_string(&query_row).unwrap_or_default())
         .await;
@@ -40,9 +40,8 @@ pub async fn queries(controller_data: ControllerData) {
     let mut data: Vec<QueryRow> = Vec::with_capacity(queries as usize);
     let db_pool: DbPoolConnection = get_db_connection().await;
     for _ in 0..queries {
-        let _ = random_world_row(&db_pool).await.map(|row| {
-            data.push(row);
-        });
+        let row: QueryRow = random_world_row(&db_pool).await;
+        data.push(row);
     }
     let _ = controller_data
         .set_response_body(serde_json::to_string(&data).unwrap_or_default())
@@ -82,7 +81,7 @@ pub async fn updates(controller_data: ControllerData) {
         .unwrap_or_default()
         .min(ROW_LIMIT as Queries)
         .max(1);
-    let res: Vec<QueryRow> = update_world_rows(queries).await.unwrap();
+    let res: Vec<QueryRow> = update_world_rows(queries).await;
     let _ = controller_data
         .set_response_body(serde_json::to_string(&res).unwrap_or_default())
         .await;