feat: v18.0.0

Author: eastspire

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "hyperlane"
-version = "17.3.7"
+version = "18.0.0"
 readme = "README.md"
 edition = "2024"
 authors = ["root@ltpp.vip"]

src/context/impl.rs

@@ -321,105 +321,6 @@ impl Context {
         !self.get_closed() && keep_alive
     }
 
-    /// Retrieves the remote socket address of the connection.
-    ///
-    /// # Returns
-    ///
-    /// - `Option<SocketAddr>` - The socket address of the remote peer if available.
-    pub async fn try_get_socket_addr(&self) -> Option<SocketAddr> {
-        self.try_get_stream()
-            .as_ref()?
-            .read()
-            .await
-            .peer_addr()
-            .ok()
-    }
-
-    /// Retrieves the remote socket address.
-    ///
-    /// # Returns
-    ///
-    /// - `SocketAddr` - The socket address of the remote peer.
-    ///
-    /// # Panics
-    ///
-    /// - If the socket address is not found.
-    pub async fn get_socket_addr(&self) -> SocketAddr {
-        self.try_get_socket_addr().await.unwrap()
-    }
-
-    /// Retrieves the remote socket address as a string.
-    ///
-    /// # Returns
-    ///
-    /// - `Option<String>` - The string representation of the socket address if available.
-    pub async fn try_get_socket_addr_string(&self) -> Option<String> {
-        self.try_get_socket_addr()
-            .await
-            .map(|data| data.to_string())
-    }
-
-    /// Retrieves the remote socket address as a string.
-    ///
-    /// # Returns
-    ///
-    /// - `String` - The string representation of the socket address.
-    ///
-    /// # Panics
-    ///
-    /// - If the socket address is not found.
-    pub async fn get_socket_addr_string(&self) -> String {
-        self.get_socket_addr().await.to_string()
-    }
-
-    /// Retrieves the IP address part of the remote socket address.
-    ///
-    /// # Returns
-    ///
-    /// - `Option<SocketHost>` - The IP address of the remote peer.
-    pub async fn try_get_socket_host(&self) -> Option<SocketHost> {
-        self.try_get_socket_addr()
-            .await
-            .map(|socket_addr: SocketAddr| socket_addr.ip())
-    }
-
-    /// Retrieves the IP address part of the remote socket address.
-    ///
-    /// # Returns
-    ///
-    /// - `SocketHost` - The IP address of the remote peer.
-    ///
-    /// # Panics
-    ///
-    /// - If the socket address is not found.
-    pub async fn get_socket_host(&self) -> SocketHost {
-        self.try_get_socket_host().await.unwrap()
-    }
-
-    /// Retrieves the port number part of the remote socket address.
-    ///
-    /// # Returns
-    ///
-    /// - `Option<SocketPort>` - The port number of the remote peer if available.
-    pub async fn try_get_socket_port(&self) -> Option<SocketPort> {
-        self.try_get_socket_addr()
-            .await
-            .map(|socket_addr: SocketAddr| socket_addr.port())
-    }
-
-    /// Retrieves the port number part of the remote socket address.
-    ///
-    /// # Returns
-    ///
-    /// - `SocketPort` - The port number of the remote peer.
-    ///
-    /// # Panics
-    ///
-    /// - If the socket address is not found.
-    pub async fn get_socket_port(&self) -> SocketPort {
-        self.try_get_socket_port().await.unwrap()
-    }
-
     /// Attempts to retrieve a specific route parameter by its name.
     ///
     /// # Arguments

src/context/struct.rs

@@ -13,9 +13,8 @@ pub struct Context {
     #[get(type(copy))]
     pub(super) closed: bool,
     /// The underlying network stream for the connection.
-    #[get(pub(crate))]
     #[get_mut(skip)]
-    #[set(pub(crate))]
+    #[set(pub(super))]
     pub(super) stream: Option<ArcRwLockStream>,
     /// The incoming HTTP request.
     #[get_mut(skip)]

src/lib.rs

@@ -31,7 +31,6 @@ use std::{
     future::Future,
     hash::{Hash, Hasher},
     io::{self, Write, stderr, stdout},
-    net::SocketAddr,
     pin::Pin,
     sync::{Arc, OnceLock},
 };

src/server/test.rs

@@ -222,7 +222,16 @@ struct RequestMiddleware {
 
 impl ServerHook for RequestMiddleware {
     async fn new(ctx: &mut Context) -> Self {
-        let socket_addr: String = ctx.get_socket_addr_string().await;
+        let mut socket_addr: String = String::new();
+        if let Some(stream) = ctx.try_get_stream().as_ref() {
+            socket_addr = stream
+                .read()
+                .await
+                .peer_addr()
+                .ok()
+                .map(|data| data.to_string())
+                .unwrap_or_default();
+        }
         Self { socket_addr }
     }