2 months ago · c0a29055d3
--- a/frameworks/Rust/hyperlane/Cargo.lock
+++ b/frameworks/Rust/hyperlane/Cargo.lock
--- a/frameworks/Rust/hyperlane/Cargo.toml
+++ b/frameworks/Rust/hyperlane/Cargo.toml
@@ -18,10 +18,14 @@ exclude = [
 
				 ]
			
 
				 
			
 
				 [dependencies]
			
 
				-hyperlane = "5.32.1"
			
 
				-hyperlane-utils = "0.18.0"
			
 
				+futures = "0.3.31"
			
 
				+hyperlane = "5.39.0"
			
 
				+hyperlane-time = "0.5.5"
			
 
				+num_cpus = "1.17.0"
			
 
				+once_cell = "1.21.3"
			
 
				 rand = "0.9.1"
			
 
				 serde = "1.0.219"
			
 
				+serde_json = "1.0.140"
			
 
				 sqlx = { version = "0.8.6", features = ["runtime-tokio", "postgres"] }
			
 
				 
			
 
				 [profile.dev]
			
--- a/frameworks/Rust/hyperlane/src/main.rs
+++ b/frameworks/Rust/hyperlane/src/main.rs
@@ -16,6 +16,7 @@ pub(crate) use utils::*;
 
				 
			
 
				 pub(crate) use std::{fmt, hint::black_box, sync::Arc};
			
 
				 
			
 
				+pub(crate) use futures::{executor::block_on, future::join_all};
			
 
				 pub(crate) use hyperlane::{
			
 
				     tokio::{
			
 
				         runtime::{Builder, Runtime},
			
@@ -25,15 +26,12 @@ pub(crate) use hyperlane::{
 
				     },
			
 
				     *,
			
 
				 };
			
 
				-pub(crate) use hyperlane_utils::{
			
 
				-    futures::{executor::block_on, future::join_all},
			
 
				-    once_cell::sync::Lazy,
			
 
				-    serde::*,
			
 
				-    serde_json::{Value, json},
			
 
				-    *,
			
 
				-};
			
 
				+pub(crate) use hyperlane_time::*;
			
 
				 pub(crate) use lazy::*;
			
 
				+pub(crate) use once_cell::sync::Lazy;
			
 
				 pub(crate) use rand::{Rng, SeedableRng, rng, rngs::SmallRng};
			
 
				+pub(crate) use serde::*;
			
 
				+pub(crate) use serde_json::{Value, json};
			
 
				 pub(crate) use server::*;
			
 
				 pub(crate) use sqlx::{
			
 
				     postgres::{PgPoolOptions, PgRow},
			
--- a/frameworks/Rust/hyperlane/src/server.rs
+++ b/frameworks/Rust/hyperlane/src/server.rs
@@ -17,8 +17,8 @@ async fn init_server() {
 
				     server.port(8080).await;
			
 
				     server.disable_linger().await;
			
 
				     server.disable_nodelay().await;
			
 
				-    server.error_handler(|_: String| {}).await;
			
 
				-    server.http_line_buffer_size(256).await;
			
 
				+    server.error_handler(async |_: PanicInfo| {}).await;
			
 
				+    server.http_buffer_size(256).await;
			
 
				     server.ws_buffer_size(256).await;
			
 
				     server.request_middleware(request_middleware::request).await;
			
 
				     #[cfg(any(feature = "dev", feature = "plaintext"))]
			
--- a/frameworks/Rust/hyperlane/src/utils.rs
+++ b/frameworks/Rust/hyperlane/src/utils.rs
@@ -1,5 +1,9 @@
 
				 use super::*;
			
 
				 
			
 
				+pub fn get_thread_count() -> usize {
			
 
				+    num_cpus::get().max(1)
			
 
				+}
			
 
				+
			
 
				 pub fn escape_html(input: &str) -> String {
			
 
				     let mut result: String = String::new();
			
 
				     for ch in input.chars() {