feat: update

Author: eastspire

frameworks/Rust/hyperlane/Cargo.lock

@@ -18,8 +18,8 @@ exclude = [
 ]
 
 [dependencies]
-hyperlane = "5.22.1"
-hyperlane-utils = "0.16.1"
+hyperlane = "5.25.1"
+hyperlane-utils = "0.17.0"
 rand = "0.9.1"
 serde = "1.0.219"
 sqlx = { version = "0.8.6", features = ["runtime-tokio", "postgres"] }

frameworks/Rust/hyperlane/Cargo.toml

@@ -9,8 +9,8 @@ pub(crate) mod server;
 pub(crate) mod r#type;
 pub(crate) mod utils;
 
-pub(crate) use db::*;
 pub(crate) use r#const::*;
+pub(crate) use db::*;
 pub(crate) use r#type::*;
 pub(crate) use utils::*;
 
@@ -29,11 +29,11 @@ pub(crate) use hyperlane_utils::{
     futures::{executor::block_on, future::join_all},
     once_cell::sync::Lazy,
     serde::*,
-    serde_json::{json, Value},
+    serde_json::{Value, json},
     *,
 };
 pub(crate) use lazy::*;
-pub(crate) use rand::{rng, rngs::SmallRng, Rng, SeedableRng};
+pub(crate) use rand::{Rng, SeedableRng, rng, rngs::SmallRng};
 pub(crate) use server::*;
 pub(crate) use sqlx::{
     postgres::{PgPoolOptions, PgRow},

frameworks/Rust/hyperlane/src/main.rs

@@ -1,11 +1,13 @@
 use super::*;
 
 pub async fn request(ctx: Context) {
-    ctx.set_response_header(CONNECTION, CONNECTION_KEEP_ALIVE)
+    ctx.set_response_header(CONNECTION, KEEP_ALIVE)
         .await
         .set_response_header(SERVER, HYPERLANE)
         .await
         .set_response_header(DATE, gmt())
+        .await
+        .set_response_status_code(200)
         .await;
     #[cfg(feature = "plaintext")]
     {

frameworks/Rust/hyperlane/src/request_middleware.rs

@@ -5,19 +5,23 @@ pub async fn json(ctx: Context) {
         "message": RESPONSEDATA_STR
     });
     let _ = ctx
-        .send_response(200, serde_json::to_string(&json).unwrap_or_default())
+        .set_response_body(serde_json::to_string(&json).unwrap_or_default())
+        .await
+        .send()
         .await;
 }
 
 pub async fn plaintext(ctx: Context) {
-    let _ = ctx.send_response(200, RESPONSEDATA_BIN).await;
+    let _ = ctx.set_response_body(RESPONSEDATA_BIN).await.send().await;
 }
 
 pub async fn db(ctx: Context) {
     let db_connection: &DbPoolConnection = get_db_connection();
     let query_row: QueryRow = random_world_row(db_connection).await;
     let _ = ctx
-        .send_response(200, serde_json::to_string(&query_row).unwrap_or_default())
+        .set_response_body(serde_json::to_string(&query_row).unwrap_or_default())
+        .await
+        .send()
         .await;
 }
 
@@ -32,7 +36,9 @@ pub async fn query(ctx: Context) {
     let db_pool: &DbPoolConnection = get_db_connection();
     let data: Vec<QueryRow> = get_some_row_id(queries, db_pool).await;
     let _ = ctx
-        .send_response(200, serde_json::to_string(&data).unwrap_or_default())
+        .set_response_body(serde_json::to_string(&data).unwrap_or_default())
+        .await
+        .send()
         .await;
 }
 
@@ -52,7 +58,7 @@ pub async fn fortunes(ctx: Context) {
     ));
     fortunes_list.sort_by(|it, next| it.message.cmp(&next.message));
     let res: String = FortunesTemplate::new(fortunes_list).to_string();
-    let _ = ctx.send_response(200, res).await;
+    let _ = ctx.set_response_body(res).await.send().await;
 }
 
 pub async fn update(ctx: Context) {
@@ -65,7 +71,9 @@ pub async fn update(ctx: Context) {
         .max(1);
     let res: Vec<QueryRow> = update_world_rows(queries).await;
     let _ = ctx
-        .send_response(200, serde_json::to_string(&res).unwrap_or_default())
+        .set_response_body(serde_json::to_string(&res).unwrap_or_default())
+        .await
+        .send()
         .await;
 }
 
@@ -79,6 +87,8 @@ pub async fn cached_query(ctx: Context) {
         .max(1);
     let res: Vec<QueryRow> = CACHE.iter().take(count as usize).cloned().collect();
     let _ = ctx
-        .send_response(200, serde_json::to_string(&res).unwrap_or_default())
+        .set_response_body(serde_json::to_string(&res).unwrap_or_default())
+        .await
+        .send()
         .await;
 }