Browse Source

Upgrade hyperlane (#9923)

* feat: update & fortune

* feat: randomNumber

* feat: max row 500

* feat: update

* feat: Fortune

* feat: fortunes

* feat: update

* feat: update

* feat: update

* feat: update

* feat: fortunes

* feat: fortunes

* feat: fortunes

* feat: fortunes

* feat: fortunes

* feat: fortunes

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: cache

* feat: cache

* feat: config

* feat: config

* feat: config

* feat: v4.36.1

* docs: readme

* feat: remove dyn

* docs: readme

* feat: lock

* feat: lock

* feat: lock

* feat: lock

* feat: db pool

* feat: db pool

* feat: lock

* feat: lock

* feat: db

* feat: db

* feat: db

* feat: db

* feat: db

* feat: db

* feat: db

* feat: db

* feat: rand

* feat: rand

* feat: rand

* feat: rand

* feat: rand

* feat: port

* feat: port

* feat: port

* feat: db

* feat: db

* feat: db

* feat: lock

* feat: lock

* feat: v4.41.0

* feat: v4.42.0

* Merge remote-tracking branch 'upstream/master'

* Merge remote-tracking branch 'upstream/master'

* feat: inline

* feat: dockerfile

* feat: v4.52.1

* feat: remove key

* remove: log

* remove: log

* feat: async

* remove: empty loop

* feat: utf8

* change: pool_size

* remove: utf8

* feat: log

* feat: log

* feat: v3.14.1

* feat: 4.56.3

* feat: 4.56.4

* feat: 4.56.5

* feat:  rename

* Merge branch 'master' of github.com:TechEmpower/FrameworkBenchmarks

* feat: speed

* feat: speed

* lock: toml

* lock: toml

* lock: toml

* lock: toml

* lock: toml

* lock: toml

* lock: toml

* lock: toml

* lock: toml

* lock: toml

* lock: toml

* lock: toml

* lock: toml

* feat: runtime

* feat: runtime

* feat: runtime

* lock: toml

* lock: toml

* lock: toml

* lock: toml

* lock: toml

* lock: toml

* lock: toml

* lock: toml

* feat: update

* Merge remote-tracking branch 'upstream/master'

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* Merge remote-tracking branch 'upstream/master'

* feat: hyperlane

* feat: update

* docs: readme

* feat: update

* Merge remote-tracking branch 'upstream/master'

* feat: update

* feat: update

* feat: update

* Merge remote-tracking branch 'upstream/master'

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: lock

* feat: use super

* feat: update lock

* feat: update

* feat: update lock

* feat: update lock

* feat: update lock

* feat: lock

* feat: update lock

* feat: update lock

* feat: update lock

* feat: update lock

* feat: update lock

* feat: update lock

* feat: update lock

* feat: update lock

* feat: update lock

* feat: update lock

* feat: update lock

* feat: update lock

* feat: update lock

* Merge remote-tracking branch 'upstream/master'

* feat: update

* feat: utf8

* feat: utf8

* feat: lock

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* update: code

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

* feat: update

---------

Co-authored-by: 尤雨东 <[email protected]>
尤雨东 2 months ago
parent
commit
a56307a1f8

File diff suppressed because it is too large
+ 617 - 36
frameworks/Rust/hyperlane/Cargo.lock


+ 2 - 2
frameworks/Rust/hyperlane/Cargo.toml

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

+ 3 - 1
frameworks/Rust/hyperlane/src/request_middleware.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")]
     {

+ 17 - 7
frameworks/Rust/hyperlane/src/route.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;
 }

+ 2 - 2
frameworks/Rust/hyperlane/src/server.rs

@@ -17,9 +17,9 @@ async fn init_server() {
     server.port(8080).await;
     server.disable_linger().await;
     server.disable_nodelay().await;
-    server.error_handle(|_: String| {}).await;
+    server.error_handler(|_: String| {}).await;
     server.http_line_buffer_size(256).await;
-    server.websocket_buffer_size(256).await;
+    server.ws_buffer_size(256).await;
     server.request_middleware(request_middleware::request).await;
     #[cfg(any(feature = "dev", feature = "plaintext"))]
     server.route("/plaintext", route::plaintext).await;

Some files were not shown because too many files changed in this diff