fix(core): avoid reverse DNS lookup in socket address formatting

- Replace socket_addr.to_string() calls with explicit format!() to prevent reverse DNS lookups
- Add socket_addr parameter to MultiplexedConnection::new_with_stream() for accurate address tracking
- Update address_string construction in PushManager initialization to use actual socket address when available
- Pass socket_addr through client connection flow to cluster async module

Signed-off-by: affonsov <67347924+affonsov@users.noreply.github.com>

Author: affonsov

glide-core/redis-rs/redis/src/aio/multiplexed_connection.rs

@@ -25,6 +25,7 @@ use pin_project_lite::pin_project;
 use std::collections::VecDeque;
 use std::fmt;
 use std::fmt::Debug;
+use std::net::SocketAddr;
 use std::pin::Pin;
 use std::sync::atomic::{AtomicBool, Ordering};
 use std::sync::Arc;
@@ -605,6 +606,7 @@ impl MultiplexedConnection {
             stream,
             std::time::Duration::MAX,
             glide_connection_options,
+            None, // No socket_addr available in this path
         )
         .await
     }
@@ -616,6 +618,7 @@ impl MultiplexedConnection {
         stream: C,
         response_timeout: std::time::Duration,
         glide_connection_options: GlideConnectionOptions,
+        socket_addr: Option<SocketAddr>,
     ) -> RedisResult<(Self, impl Future<Output = ()>)>
     where
         C: Unpin + AsyncRead + AsyncWrite + Send + 'static,
@@ -626,10 +629,17 @@ impl MultiplexedConnection {
         let (mut pipeline, driver) =
             Pipeline::new(codec, glide_connection_options.disconnect_notifier);
         let driver = Box::pin(driver);
+
+        // Use the actual socket address if available, otherwise fall back to connection_info.addr
+        let address_string = if let Some(socket_addr) = socket_addr {
+            format!("{}:{}", socket_addr.ip(), socket_addr.port())
+        } else {
+            connection_info.addr.to_string()
+        };
         let pm = PushManager::new(
             glide_connection_options.push_sender,
             glide_connection_options.pubsub_synchronizer,
-            Some(connection_info.addr.to_string()),
+            Some(address_string),
         );
 
         pipeline.set_push_manager(pm.clone());

glide-core/redis-rs/redis/src/client.rs

@@ -445,6 +445,7 @@ impl Client {
             con,
             response_timeout,
             glide_connection_options,
+            socket_addr,
         )
         .await
         .map(|res| (res.0, res.1, ip))

glide-core/redis-rs/redis/src/cluster_async/mod.rs

@@ -1290,7 +1290,9 @@ where
                     .await
                     .get_node();
                     let node_address = if let Some(socket_addr) = socket_addr {
-                        socket_addr.to_string()
+                        // Use format! to avoid reverse DNS lookup that socket_addr.to_string() performs
+                        let addr = format!("{}:{}", socket_addr.ip(), socket_addr.port());
+                        addr
                     } else {
                         node_addr
                     };
@@ -2250,7 +2252,12 @@ where
                                         let conn_lock =
                                             inner.conn_lock.read().expect(MUTEX_READ_ERR);
                                         socket_addresses.find_map(|socket_addr| {
-                                            conn_lock.node_for_address(&socket_addr.to_string())
+                                            let addr_str = format!(
+                                                "{}:{}",
+                                                socket_addr.ip(),
+                                                socket_addr.port()
+                                            );
+                                            conn_lock.node_for_address(&addr_str)
                                         })
                                     },
                                 );