feat(transports/unix-stream): add

Ripped 100% off transports/tcp

Uses proposed encoding from multiformats/multiaddr#174 (comment)

Author: nabijaczleweli

CHANGELOG.md

@@ -31,6 +31,7 @@
 - [`libp2p-pnet` CHANGELOG](transports/pnet/CHANGELOG.md)
 - [`libp2p-quic` CHANGELOG](transports/quic/CHANGELOG.md)
 - [`libp2p-tcp` CHANGELOG](transports/tcp/CHANGELOG.md)
+- [`libp2p-unix-stream` CHANGELOG](transports/unix-stream/CHANGELOG.md)
 - [`libp2p-tls` CHANGELOG](transports/tls/CHANGELOG.md)
 - [`libp2p-uds` CHANGELOG](transports/uds/CHANGELOG.md)
 - [`libp2p-wasm-ext` CHANGELOG](transports/wasm-ext/CHANGELOG.md)

Cargo.lock

@@ -58,6 +58,7 @@ members = [
     "transports/pnet",
     "transports/quic",
     "transports/tcp",
+    "transports/unix-stream",
     "transports/tls",
     "transports/uds",
     "transports/webrtc-websys",
@@ -106,6 +107,7 @@ libp2p-swarm = { version = "0.47.0", path = "swarm" }
 libp2p-swarm-derive = { version = "=0.35.1", path = "swarm-derive" } # `libp2p-swarm-derive` may not be compatible with different `libp2p-swarm` non-breaking releases. E.g. `libp2p-swarm` might introduce a new enum variant `FromSwarm` (which is `#[non-exhaustive]`) in a non-breaking release. Older versions of `libp2p-swarm-derive` would not forward this enum variant within the `NetworkBehaviour` hierarchy. Thus the version pinning is required.
 libp2p-swarm-test = { version = "0.6.0", path = "swarm-test" }
 libp2p-tcp = { version = "0.43.0", path = "transports/tcp" }
+libp2p-unix-stream = { version = "0.43.0", path = "transports/unix-stream" }
 libp2p-tls = { version = "0.6.2", path = "transports/tls" }
 libp2p-uds = { version = "0.42.0", path = "transports/uds" }
 libp2p-upnp = { version = "0.4.1", path = "protocols/upnp" }

Cargo.toml

@@ -41,6 +41,7 @@ full = [
     "secp256k1",
     "serde",
     "tcp",
+    "unix-stream",
     "tls",
     "tokio",
     "uds",
@@ -53,7 +54,7 @@ full = [
     "upnp",
 ]
 
-async-std = ["libp2p-swarm/async-std", "libp2p-tcp?/async-io", "libp2p-dns?/async-std"]
+async-std = ["libp2p-swarm/async-std", "libp2p-tcp?/async-io", "libp2p-unix-stream?/async-io", "libp2p-dns?/async-std"]
 autonat = ["dep:libp2p-autonat"]
 cbor = ["libp2p-request-response?/cbor"]
 dcutr = ["dep:libp2p-dcutr", "libp2p-metrics?/dcutr"]
@@ -82,8 +83,9 @@ rsa = ["libp2p-identity/rsa"]
 secp256k1 = ["libp2p-identity/secp256k1"]
 serde = ["libp2p-core/serde", "libp2p-kad?/serde", "libp2p-gossipsub?/serde"]
 tcp = ["dep:libp2p-tcp"]
+unix-stream = ["dep:libp2p-unix-stream"]
 tls = ["dep:libp2p-tls"]
-tokio = ["libp2p-swarm/tokio", "libp2p-mdns?/tokio", "libp2p-tcp?/tokio", "libp2p-dns?/tokio", "libp2p-quic?/tokio", "libp2p-upnp?/tokio"]
+tokio = ["libp2p-swarm/tokio", "libp2p-mdns?/tokio", "libp2p-tcp?/tokio", "libp2p-unix-stream?/tokio", "libp2p-dns?/tokio", "libp2p-quic?/tokio", "libp2p-upnp?/tokio"]
 uds = ["dep:libp2p-uds"]
 wasm-bindgen = ["futures-timer/wasm-bindgen", "getrandom/js", "libp2p-swarm/wasm-bindgen", "libp2p-gossipsub?/wasm-bindgen"]
 webrtc-websys = ['dep:libp2p-webrtc-websys']
@@ -137,6 +139,7 @@ libp2p-mdns = { workspace = true, optional = true }
 libp2p-memory-connection-limits = { workspace = true, optional = true }
 libp2p-quic = { workspace = true, optional = true }
 libp2p-tcp = { workspace = true, optional = true }
+libp2p-unix-stream = { workspace = true, optional = true }
 libp2p-tls = { workspace = true, optional = true }
 libp2p-uds = { workspace = true, optional = true }
 libp2p-upnp = { workspace = true, optional = true }

libp2p/Cargo.toml

@@ -112,6 +112,11 @@ pub use libp2p_swarm as swarm;
 #[cfg_attr(docsrs, doc(cfg(feature = "tcp")))]
 #[doc(inline)]
 pub use libp2p_tcp as tcp;
+#[cfg(feature = "unix-stream")]
+#[cfg(unix)]
+#[cfg_attr(docsrs, doc(cfg(feature = "unix-stream")))]
+#[doc(inline)]
+pub use libp2p_unix_stream as unix_stream;
 #[cfg(feature = "tls")]
 #[cfg_attr(docsrs, doc(cfg(feature = "tls")))]
 #[cfg(not(target_arch = "wasm32"))]

libp2p/src/lib.rs

@@ -402,8 +402,7 @@ where
                 (Err(err), _) => return Err(err),
             };
 
-            let stream = T::new_stream(socket.into()).await?;
-            Ok(stream)
+            T::new_stream(socket.into()).await
         }
         .boxed())
     }

transports/tcp/src/lib.rs

@@ -0,0 +1,38 @@
+[package]
+name = "libp2p-unix-stream"
+edition.workspace = true
+rust-version = { workspace = true }
+description = "UNIX-domain stream socket transport protocol for libp2p"
+version = "0.43.0"
+authors = ["Parity Technologies <[email protected]>"]
+license = "MIT"
+repository = "https://github.com/libp2p/rust-libp2p"
+keywords = ["peer-to-peer", "libp2p", "networking"]
+categories = ["network-programming", "asynchronous"]
+
+[dependencies]
+async-io = { version = "2.3.3", optional = true }
+futures = { workspace = true }
+futures-timer = "3.0"
+libp2p-core = { workspace = true }
+percent-encoding-rfc3986 = "0.1"
+tokio = { workspace = true, default-features = false, features = ["net"], optional = true }
+tracing = { workspace = true }
+
+[features]
+tokio = ["dep:tokio"]
+async-io = ["dep:async-io"]
+
+[dev-dependencies]
+async-std = { version = "1.6.5", features = ["attributes"] }
+tokio = { workspace = true, features = ["full"] }
+tracing-subscriber = { workspace = true, features = ["env-filter"] }
+
+# Passing arguments to the docsrs builder in order to properly document cfg's.
+# More information: https://docs.rs/about/builds#cross-compiling
+[package.metadata.docs.rs]
+all-features = true
+
+
+[lints]
+workspace = true