Update hyperlane

frameworks/Rust/hyperlane/Cargo.toml

@@ -12,14 +12,14 @@ categories = ["network-programming", "web-programming"]
 exclude = ["target", "Cargo.lock", "sh", ".github", "logs", "**/*.log"]
 
 [dependencies]
+rand = "0.9.2"
 futures = "0.3.31"
-hyperlane = "10.34.5"
-hyperlane-time = "0.7.16"
 num_cpus = "1.17.0"
 once_cell = "1.21.3"
-rand = "0.9.2"
-serde = "1.0.228"
-serde_json = "1.0.148"
+hyperlane = "10.35.1"
+serde_json = "1.0.149"
+hyperlane-time = "0.7.16"
+serde = { version = "1.0.228", features = ["derive"] }
 sqlx = { version = "0.8.6", features = ["runtime-tokio", "postgres"] }
 
 [profile.dev]

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

@@ -6,6 +6,7 @@ impl ServerHook for JsonRoute {
     }
 
     async fn handle(self, ctx: &Context) {
+        let request_config: RequestConfig = *REQUEST_CONFIG;
         let json: Value = json!({
             KEY_MESSAGE: RESPONSEDATA_STR
         });
@@ -15,7 +16,7 @@ impl ServerHook for JsonRoute {
             ctx.send().await;
         };
         run().await;
-        while ctx.http_from_stream(RequestConfig::default()).await.is_ok() {
+        while ctx.http_from_stream(request_config).await.is_ok() {
             run().await;
         }
         ctx.closed().await;
@@ -28,13 +29,14 @@ impl ServerHook for PlaintextRoute {
     }
 
     async fn handle(self, ctx: &Context) {
+        let request_config: RequestConfig = *REQUEST_CONFIG;
         ctx.set_response_header(CONTENT_TYPE, TEXT_PLAIN).await;
         ctx.set_response_body(&RESPONSEDATA_BIN).await;
         let run = || async {
             ctx.send().await;
         };
         run().await;
-        while ctx.http_from_stream(RequestConfig::default()).await.is_ok() {
+        while ctx.http_from_stream(request_config).await.is_ok() {
             run().await;
         }
         ctx.closed().await;
@@ -47,6 +49,7 @@ impl ServerHook for DbRoute {
     }
 
     async fn handle(self, ctx: &Context) {
+        let request_config: RequestConfig = *REQUEST_CONFIG;
         let db_connection: &DbPoolConnection = get_db_connection();
         let run = || async {
             let query_row: QueryRow = random_world_row(db_connection).await;
@@ -56,7 +59,7 @@ impl ServerHook for DbRoute {
                 .await;
         };
         run().await;
-        while ctx.http_from_stream(RequestConfig::default()).await.is_ok() {
+        while ctx.http_from_stream(request_config).await.is_ok() {
             run().await;
         }
         ctx.closed().await;
@@ -69,6 +72,7 @@ impl ServerHook for QueryRoute {
     }
 
     async fn handle(self, ctx: &Context) {
+        let request_config: RequestConfig = *REQUEST_CONFIG;
         let run = || async {
             let queries: Queries = ctx
                 .try_get_request_query(QUERY_DB_QUERY_KEY)
@@ -85,7 +89,7 @@ impl ServerHook for QueryRoute {
                 .await;
         };
         run().await;
-        while ctx.http_from_stream(RequestConfig::default()).await.is_ok() {
+        while ctx.http_from_stream(request_config).await.is_ok() {
             run().await;
         }
         ctx.closed().await;
@@ -98,6 +102,7 @@ impl ServerHook for FortunesRoute {
     }
 
     async fn handle(self, ctx: &Context) {
+        let request_config: RequestConfig = *REQUEST_CONFIG;
         ctx.set_response_header(
             CONTENT_TYPE,
             &ContentType::format_content_type_with_charset(TEXT_HTML, UTF8),
@@ -121,7 +126,7 @@ impl ServerHook for FortunesRoute {
             ctx.set_response_body(&res).await.send().await;
         };
         run().await;
-        while ctx.http_from_stream(RequestConfig::default()).await.is_ok() {
+        while ctx.http_from_stream(request_config).await.is_ok() {
             run().await;
         }
         ctx.closed().await;
@@ -134,6 +139,7 @@ impl ServerHook for UpdateRoute {
     }
 
     async fn handle(self, ctx: &Context) {
+        let request_config: RequestConfig = *REQUEST_CONFIG;
         let run = || async {
             let queries: Queries = ctx
                 .try_get_request_query(UPDATE_DB_QUERY_KEY)
@@ -149,7 +155,7 @@ impl ServerHook for UpdateRoute {
                 .await;
         };
         run().await;
-        while ctx.http_from_stream(RequestConfig::default()).await.is_ok() {
+        while ctx.http_from_stream(request_config).await.is_ok() {
             run().await;
         }
         ctx.closed().await;
@@ -162,6 +168,7 @@ impl ServerHook for CachedQueryRoute {
     }
 
     async fn handle(self, ctx: &Context) {
+        let request_config: RequestConfig = *REQUEST_CONFIG;
         let run = || async {
             let count: Queries = ctx
                 .try_get_request_query(CACHE_QUERY_KEY)
@@ -177,7 +184,7 @@ impl ServerHook for CachedQueryRoute {
                 .await;
         };
         run().await;
-        while ctx.http_from_stream(RequestConfig::default()).await.is_ok() {
+        while ctx.http_from_stream(request_config).await.is_ok() {
             run().await;
         }
         ctx.closed().await;

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

@@ -1,6 +1,8 @@
 pub(crate) mod r#impl;
+pub(crate) mod r#static;
 pub(crate) mod r#struct;
 
+pub(crate) use r#static::*;
 pub(crate) use r#struct::*;
 
 use super::*;

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

@@ -0,0 +1,3 @@
+use super::*;
+
+pub static REQUEST_CONFIG: Lazy<RequestConfig> = Lazy::new(RequestConfig::default);