feat(smol): add uds connector

smol/Cargo.toml

@@ -29,6 +29,8 @@ signal-hook-async-std = "0.2.2"
 
 [dev-dependencies]
 env_logger = "0.11.0"
+tempfile = "3.10.1"
+test-harness = "0.2.0"
 trillium-client = { path = "../client" }
 trillium-logger = { path = "../logger" }
 trillium-testing = { path = "../testing" }

smol/src/client.rs

@@ -82,3 +82,18 @@ impl Connector for ClientConfig {
         Ok(tcp)
     }
 }
+
+#[cfg(unix)]
+impl Connector for SmolTransport<async_net::unix::UnixStream> {
+    type Transport = Self;
+
+    type Runtime = SmolRuntime;
+
+    async fn connect(&self, _url: &Url) -> Result<Self::Transport> {
+        Ok(self.clone())
+    }
+
+    fn runtime(&self) -> Self::Runtime {
+        SmolRuntime::default()
+    }
+}

smol/src/transport.rs

@@ -43,3 +43,10 @@ impl Transport for SmolTransport<TcpStream> {
 
 #[cfg(unix)]
 impl Transport for SmolTransport<async_net::unix::UnixStream> {}
+#[cfg(unix)]
+impl SmolTransport<async_net::unix::UnixStream> {
+    /// connnect to the provided path as a unix domain socket
+    pub async fn connect_unix(path: impl AsRef<std::path::Path>) -> Result<Self> {
+        async_net::unix::UnixStream::connect(path).await.map(Self)
+    }
+}

smol/tests/unix_stream.rs

@@ -0,0 +1,21 @@
+#![cfg(unix)]
+use test_harness::test;
+use trillium_client::Client;
+use trillium_smol::{config, SmolTransport};
+use trillium_testing::harness;
+
+#[test(harness)]
+async fn smoke() {
+    let temp_dir = tempfile::tempdir().unwrap();
+    let path = temp_dir.path().join("socket");
+
+    let handle = config().with_host(path.to_str().unwrap()).spawn("ok");
+    handle.info().await;
+
+    let stream = SmolTransport::connect_unix(path).await.unwrap();
+    let mut conn = Client::new(stream).get("http://localhost/").await.unwrap();
+
+    assert_eq!(conn.status().unwrap(), 200);
+    assert_eq!(conn.response_body().read_string().await.unwrap(), "ok");
+    handle.shut_down().await;
+}