feat: toml

Author: eastspire

frameworks/Rust/hyperlane/Cargo.lock

@@ -20,13 +20,13 @@ exclude = [
 
 [dependencies]
 futures = "0.3.31"
-hyperlane = "8.1.6"
+hyperlane = "9.3.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.143"
+serde = "1.0.221"
+serde_json = "1.0.144"
 sqlx = { version = "0.8.6", features = ["runtime-tokio", "postgres"] }
 
 [profile.dev]

frameworks/Rust/hyperlane/Cargo.toml

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

frameworks/Rust/hyperlane/src/middleware/fn.rs

@@ -5,7 +5,7 @@ pub async fn json(ctx: Context) {
         "message": RESPONSEDATA_STR
     });
     let run = || async {
-        ctx.set_response_body(serde_json::to_string(&json).unwrap_or_default())
+        ctx.set_response_body(&serde_json::to_vec(&json).unwrap_or_default())
             .await;
         ctx.send().await.unwrap();
     };
@@ -18,7 +18,7 @@ pub async fn json(ctx: Context) {
 
 pub async fn plaintext(ctx: Context) {
     ctx.set_response_header(CONTENT_TYPE, TEXT_PLAIN).await;
-    ctx.set_response_body(RESPONSEDATA_BIN).await;
+    ctx.set_response_body(&RESPONSEDATA_BIN).await;
     let run = || async {
         ctx.send().await.unwrap();
     };
@@ -33,7 +33,7 @@ pub async fn db(ctx: Context) {
     let db_connection: &DbPoolConnection = get_db_connection();
     let run = || async {
         let query_row: QueryRow = random_world_row(db_connection).await;
-        ctx.set_response_body(serde_json::to_string(&query_row).unwrap_or_default())
+        ctx.set_response_body(&serde_json::to_vec(&query_row).unwrap_or_default())
             .await
             .send()
             .await
@@ -57,7 +57,7 @@ pub async fn query(ctx: Context) {
             .max(1);
         let db_pool: &DbPoolConnection = get_db_connection();
         let data: Vec<QueryRow> = get_some_row_id(queries, db_pool).await;
-        ctx.set_response_body(serde_json::to_string(&data).unwrap_or_default())
+        ctx.set_response_body(&serde_json::to_vec(&data).unwrap_or_default())
             .await
             .send()
             .await
@@ -73,7 +73,7 @@ pub async fn query(ctx: Context) {
 pub async fn fortunes(ctx: Context) {
     ctx.set_response_header(
         CONTENT_TYPE,
-        ContentType::format_content_type_with_charset(TEXT_HTML, UTF8),
+        &ContentType::format_content_type_with_charset(TEXT_HTML, UTF8),
     )
     .await;
     let run = || async {
@@ -92,7 +92,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();
-        ctx.set_response_body(res).await.send().await.unwrap();
+        ctx.set_response_body(&res).await.send().await.unwrap();
     };
     run().await;
     while let Ok(_) = ctx.http_from_stream(HTTP_BUFFER).await {
@@ -111,7 +111,7 @@ pub async fn update(ctx: Context) {
             .min(ROW_LIMIT as Queries)
             .max(1);
         let res: Vec<QueryRow> = update_world_rows(queries).await;
-        ctx.set_response_body(serde_json::to_string(&res).unwrap_or_default())
+        ctx.set_response_body(&serde_json::to_vec(&res).unwrap_or_default())
             .await
             .send()
             .await
@@ -134,7 +134,7 @@ pub async fn cached_query(ctx: Context) {
             .min(ROW_LIMIT as Queries)
             .max(1);
         let res: Vec<&QueryRow> = CACHE.iter().take(count as usize).collect();
-        ctx.set_response_body(serde_json::to_string(&res).unwrap_or_default())
+        ctx.set_response_body(&serde_json::to_vec(&res).unwrap_or_default())
             .await
             .send()
             .await

frameworks/Rust/hyperlane/src/route/fn.rs

@@ -13,59 +13,38 @@ fn runtime() -> Runtime {
 
 async fn init_server() {
     let config: ServerConfig = ServerConfig::new().await;
-    config.host("0.0.0.0").await;
-    config.port(8080).await;
-    config.disable_nodelay().await;
-    config.http_buffer(256).await;
-    config.ws_buffer(256).await;
-
-    let server: Server = Server::from(config).await;
-
-    server.request_middleware(middleware::request).await;
-
-    server
-        .disable_http_hook("/plaintext")
+    config
+        .host("0.0.0.0")
         .await
-        .route("/plaintext", route::plaintext)
+        .port(8080)
+        .await
+        .disable_nodelay()
+        .await
+        .buffer(256)
         .await;
-
-    server
-        .disable_http_hook("/json")
+    Server::from(config)
+        .await
+        .request_middleware(middleware::request)
+        .await
+        .route("/plaintext", route::plaintext)
         .await
         .route("/json", route::json)
-        .await;
-
-    server
-        .disable_http_hook("/cached-quer")
         .await
         .route("/cached-quer", route::cached_query)
-        .await;
-
-    server
-        .disable_http_hook("/db")
         .await
         .route("/db", route::db)
-        .await;
-
-    server
-        .disable_http_hook("/query")
         .await
         .route("/query", route::query)
-        .await;
-
-    server
-        .disable_http_hook("/fortunes")
         .await
         .route("/fortunes", route::fortunes)
-        .await;
-
-    server
-        .disable_http_hook("/upda")
         .await
         .route("/upda", route::update)
+        .await
+        .run()
+        .await
+        .unwrap()
+        .wait()
         .await;
-
-    server.run().await.unwrap().wait().await;
 }
 
 async fn init() {