feat: update

Author: eastspire

frameworks/Rust/hyperlane/src/main.rs

@@ -2,7 +2,6 @@ pub(crate) mod constant;
 pub(crate) mod db;
 pub(crate) mod lazy;
 pub(crate) mod request_middleware;
-pub(crate) mod response_middleware;
 pub(crate) mod route;
 pub(crate) mod server;
 pub(crate) mod r#type;
@@ -21,7 +20,6 @@ pub(crate) use hyperlane::{
 pub(crate) use lazy::*;
 pub(crate) use rand::{Rng, SeedableRng, rng, rngs::SmallRng};
 pub(crate) use request_middleware::*;
-pub(crate) use response_middleware::*;
 pub(crate) use route::*;
 pub(crate) use server::*;
 pub(crate) use sqlx::{

frameworks/Rust/hyperlane/src/request_middleware.rs

@@ -9,7 +9,5 @@ pub async fn request(ctx: Context) {
         .set_response_header(SERVER, HYPERLANE)
         .await
         .set_response_header(DATE, gmt())
-        .await
-        .set_response_status_code(200)
         .await;
 }

frameworks/Rust/hyperlane/src/response_middleware.rs

@@ -5,23 +5,23 @@ pub async fn json(ctx: Context) {
         "message": RESPONSEDATA_STR
     });
     let _ = ctx
-        .set_response_body(serde_json::to_string(&json).unwrap_or_default())
+        .send_response(200, serde_json::to_string(&json).unwrap_or_default())
         .await;
 }
 
 pub async fn plaintext(ctx: Context) {
     let _ = ctx
         .set_response_header(CONTENT_TYPE, TEXT_PLAIN)
         .await
-        .set_response_body(RESPONSEDATA_BIN)
+        .send_response(200, RESPONSEDATA_BIN)
         .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
-        .set_response_body(serde_json::to_string(&query_row).unwrap_or_default())
+        .send_response(200, serde_json::to_string(&query_row).unwrap_or_default())
         .await;
 }
 
@@ -36,7 +36,7 @@ pub async fn queries(ctx: Context) {
     let db_pool: &DbPoolConnection = get_db_connection();
     let data: Vec<QueryRow> = get_some_row_id(queries, db_pool).await;
     let _ = ctx
-        .set_response_body(serde_json::to_string(&data).unwrap_or_default())
+        .send_response(200, serde_json::to_string(&data).unwrap_or_default())
         .await;
 }
 
@@ -56,9 +56,10 @@ 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();
-    ctx.set_response_header(CONTENT_TYPE, content_type_charset(TEXT_HTML, UTF8))
+    let _ = ctx
+        .set_response_header(CONTENT_TYPE, content_type_charset(TEXT_HTML, UTF8))
         .await
-        .set_response_body(res)
+        .send_response(200, res)
         .await;
 }
 
@@ -72,7 +73,7 @@ pub async fn updates(ctx: Context) {
         .max(1);
     let res: Vec<QueryRow> = update_world_rows(queries).await;
     let _ = ctx
-        .set_response_body(serde_json::to_string(&res).unwrap_or_default())
+        .send_response(200, serde_json::to_string(&res).unwrap_or_default())
         .await;
 }
 
@@ -86,6 +87,6 @@ pub async fn cached_queries(ctx: Context) {
         .max(1);
     let res: Vec<QueryRow> = CACHE.iter().take(count as usize).cloned().collect();
     let _ = ctx
-        .set_response_body(serde_json::to_string(&res).unwrap_or_default())
+        .send_response(200, serde_json::to_string(&res).unwrap_or_default())
         .await;
 }

frameworks/Rust/hyperlane/src/route.rs

@@ -21,17 +21,16 @@ async fn init_server() {
     server.disable_log().await;
     server.disable_inner_log().await;
     server.disable_inner_print().await;
-    server.http_line_buffer_size(512).await;
-    server.websocket_buffer_size(512).await;
+    server.http_line_buffer_size(256).await;
+    server.websocket_buffer_size(256).await;
+    server.request_middleware(request).await;
     server.route("/plaintext", plaintext).await;
     server.route("/json", json).await;
     server.route("/cached-quer", cached_queries).await;
     server.route("/db", db).await;
     server.route("/query", queries).await;
     server.route("/fortunes", fortunes).await;
     server.route("/upda", updates).await;
-    server.request_middleware(request).await;
-    server.response_middleware(response).await;
     server.listen().await.unwrap();
 }