Ws server optimization

Cargo.toml

@@ -37,6 +37,8 @@ ws = [
     "dep:hyper",
     "dep:hyper-util",
     "dep:http-body-util",
+    "dep:httpdate",
+    "dep:webpki-roots",
     # "dep:",
 ]
 database = [
@@ -77,7 +79,7 @@ log_throttling = ["dep:tracing-throttle"]
 
 [dependencies]
 serde = { version = "1.0", features = ["derive"] }
-serde_json = "1.0"
+serde_json = { version = "1.0", features = ["raw_value"] }
 eyre = "0.6"
 convert_case = "0.6"
 itertools = "0.12"
@@ -127,10 +129,12 @@ regex = { version = "1.5", optional = true }
 rev_lines = { version = "0.3", optional = true }
 lazy_static = { version = "1.5", optional = true }
 async-trait = { version = "0.1", optional = true }
-hyper = { version = "1", features = ["http1", "server"], optional = true }
-hyper-util = { version = "0.1", features = ["tokio"], optional = true }
+hyper = { version = "1", features = ["http1", "http2", "server", "client"], optional = true }
+hyper-util = { version = "0.1", features = ["tokio", "server-auto"], optional = true }
 http-body-util = { version = "0.1", optional = true }
+httpdate = { version = "1.0", optional = true }
 tracing-throttle = { version = "0.4", features = ["async"], optional = true }
+webpki-roots = { version = "0.26", optional = true }
 
 # OpenTelemetry dependencies (default feature)
 opentelemetry = { version = "0.31", features = ["logs"] }

src/libs/ws/basics.rs

@@ -1,6 +1,8 @@
 use parking_lot::RwLock;
 use serde::*;
 use serde_json::Value;
+use serde_json::value::RawValue;
+use std::collections::HashSet;
 use std::fmt::Debug;
 use std::net::SocketAddr;
 use std::sync::Arc;
@@ -43,9 +45,8 @@ impl WsConnection {
         self.user_id.load(std::sync::atomic::Ordering::Acquire)
     }
 
-    pub fn get_roles(&self) -> Vec<u32> {
-        let roles = self.roles.read();
-        roles.as_ref().clone()
+    pub fn get_roles(&self) -> Arc<Vec<u32>> {
+        self.roles.read().clone()
     }
 
     pub fn set_user_id(&self, user_id: u64) {
@@ -59,8 +60,8 @@ impl WsConnection {
     }
 }
 
-pub type WsSuccessResponse = WsSuccessResponseGeneric<Value>;
-pub type WsStreamResponse = WsStreamResponseGeneric<Value>;
+pub type WsSuccessResponse = WsSuccessResponseGeneric<Box<RawValue>>;
+pub type WsStreamResponse = WsStreamResponseGeneric<Box<RawValue>>;
 
 #[derive(Debug, Serialize, Deserialize, Clone)]
 pub struct WsForwardedResponse {
@@ -101,11 +102,12 @@ pub enum WsResponseGeneric<Resp> {
     Close,
 }
 
-pub type WsResponseValue = WsResponseGeneric<Value>;
+pub type WsResponseValue = WsResponseGeneric<Box<RawValue>>;
 
 pub struct WsEndpoint {
     pub schema: EndpointSchema,
     pub handler: Arc<dyn RequestHandlerErased>,
+    pub allowed_roles: HashSet<u32>,
 }
 
 pub fn internal_error_to_resp(