add possibility to bind the tcp socket to a given socket address befo…

…re connecting to a target

crates/sip-core/src/transport/native_tls.rs

@@ -16,7 +16,7 @@ impl StreamingFactory for TlsConnector {
     async fn connect<A: ToSocketAddrs + Send>(
         &self,
         uri_info: &UriInfo,
-        addr: A,
+        addr: SocketAddr,
     ) -> io::Result<Self::Transport> {
         // Best effort to guess the domain. If the `Host` a valid domain this will work,
         // but sometimes it might be an IP address or invalid domain. In that case this might succeed anyway

crates/sip-core/src/transport/rustls.rs

@@ -18,7 +18,7 @@ impl StreamingFactory for TlsConnector {
     async fn connect<A: ToSocketAddrs + Send>(
         &self,
         uri_info: &UriInfo,
-        addr: A,
+        addr: SocketAddr,
     ) -> io::Result<Self::Transport> {
         let server_name = match uri_info.host_port.host {
             Host::Name(ref name) => ServerName::try_from(name.as_str())

crates/sip-core/src/transport/streaming/mod.rs

@@ -54,7 +54,7 @@ pub trait StreamingFactory: Send + Sync + 'static {
     async fn connect<A: ToSocketAddrs + Send>(
         &self,
         uri_info: &UriInfo,
-        addr: A,
+        addr: SocketAddr,
     ) -> io::Result<Self::Transport>;
 }
 
@@ -171,7 +171,7 @@ where
     ) -> io::Result<TpHandle> {
         log::trace!("{} trying to connect to {}", self.name(), addr);
 
-        let stream = self.connect(uri_info, addr).await?;
+        let stream = self.connect::<SocketAddr>(uri_info, addr).await?;
         let local = stream.local_addr()?;
         let remote = stream.peer_addr()?;
 

crates/sip-core/src/transport/tcp.rs

@@ -4,19 +4,27 @@ use super::streaming::{
 use sip_types::uri::UriInfo;
 use std::io;
 use std::net::SocketAddr;
-use tokio::net::{TcpListener as TokioTcpListener, TcpStream, ToSocketAddrs};
+use tokio::net::{TcpListener as TokioTcpListener, TcpStream, TcpSocket, ToSocketAddrs};
 
 // ==== Connector
 
 #[derive(Default)]
 pub struct TcpConnector {
     _priv: (),
+    bind_addr: Option<SocketAddr>,
 }
 
 impl TcpConnector {
     pub fn new() -> Self {
         Self::default()
     }
+
+    pub fn new_with_bind(bind_addr: SocketAddr) -> Self {
+        Self {
+            bind_addr: Some(bind_addr),
+            ..Self::default()
+        }
+    }
 }
 
 #[async_trait::async_trait]
@@ -26,9 +34,19 @@ impl StreamingFactory for TcpConnector {
     async fn connect<A: ToSocketAddrs + Send>(
         &self,
         _: &UriInfo,
-        addr: A,
+        addr: SocketAddr,
     ) -> io::Result<Self::Transport> {
-        TcpStream::connect(addr).await
+        if let Some(bind_addr) = self.bind_addr {
+            let socket = match bind_addr {
+                SocketAddr::V4(_) => TcpSocket::new_v4()?,
+                SocketAddr::V6(_) => TcpSocket::new_v6()?,
+            };
+            socket.bind(bind_addr)?;
+            let stream = socket.connect(addr).await?;
+            Ok(stream)
+        } else {
+            TcpStream::connect(addr).await
+        }
     }
 }