WIP: Simple connect function

quinn-proto/src/endpoint.rs

@@ -1,7 +1,7 @@
 use std::{
     collections::{HashMap, VecDeque},
     convert::TryFrom,
-    fmt, iter,
+    fmt, io, iter,
     net::{IpAddr, SocketAddr},
     ops::{Index, IndexMut},
     sync::Arc,
@@ -844,6 +844,19 @@ pub enum ConnectError {
     UnsupportedVersion,
 }
 
+// For compatibility with API consumers
+impl From<ConnectError> for io::Error {
+    fn from(x: ConnectError) -> io::Error {
+        use ConnectError::*;
+        let kind = match x {
+            InvalidDnsName(_) | InvalidRemoteAddress(_) => io::ErrorKind::InvalidData,
+            EndpointStopping | TooManyConnections | NoDefaultClientConfig => io::ErrorKind::Other,
+            UnsupportedVersion => io::ErrorKind::InvalidInput,
+        };
+        io::Error::new(kind, x)
+    }
+}
+
 /// Reset Tokens which are associated with peer socket addresses
 ///
 /// The standard `HashMap` is used since both `SocketAddr` and `ResetToken` are

quinn/src/connect.rs

@@ -0,0 +1,21 @@
+use std::{
+    io,
+    net::{IpAddr, Ipv4Addr, Ipv6Addr, SocketAddr},
+};
+
+use crate::{ClientConfig, Connecting, Endpoint};
+
+/// Connect to `server_address`, authenticating it as `server_name`, using a new endpoint
+pub fn connect(
+    config: ClientConfig,
+    server_address: SocketAddr,
+    server_name: &str,
+) -> io::Result<Connecting> {
+    let bind_addr = match server_address {
+        SocketAddr::V6(_) => IpAddr::from(Ipv6Addr::UNSPECIFIED),
+        SocketAddr::V4(_) => IpAddr::from(Ipv4Addr::UNSPECIFIED),
+    };
+    let endpoint = Endpoint::client(SocketAddr::new(bind_addr, 0))?;
+    let fut = endpoint.connect_with(config, server_address, server_name)?;
+    Ok(fut)
+}

quinn/src/lib.rs

@@ -42,6 +42,7 @@
 use std::time::Duration;
 
 mod broadcast;
+mod connect;
 mod connection;
 mod endpoint;
 mod mutex;
@@ -55,6 +56,7 @@ pub use proto::{
     Transmit, TransportConfig, VarInt,
 };
 
+pub use crate::connect::connect;
 pub use crate::connection::{
     Connecting, Connection, Datagrams, IncomingBiStreams, IncomingUniStreams, NewConnection,
     OpenBi, OpenUni, SendDatagramError, ZeroRttAccepted,