feat: Add WebRTC transport

Cargo.toml

@@ -64,6 +64,7 @@ websocket = ["libp2p-websocket"]
 yamux = ["libp2p-yamux"]
 secp256k1 = ["libp2p-core/secp256k1"]
 serde = ["libp2p-core/serde", "libp2p-kad/serde", "libp2p-gossipsub/serde"]
+webrtc = ["libp2p-webrtc"]
 
 [package.metadata.docs.rs]
 all-features = true
@@ -97,6 +98,7 @@ libp2p-swarm-derive = { version = "0.27.0", path = "swarm-derive" }
 libp2p-uds = { version = "0.32.0", path = "transports/uds", optional = true }
 libp2p-wasm-ext = { version = "0.33.0", path = "transports/wasm-ext", default-features = false, optional = true }
 libp2p-yamux = { version = "0.37.0", path = "muxers/yamux", optional = true }
+libp2p-webrtc = { version = "0.1.0", path = "transports/webrtc", optional = true }
 multiaddr = { version = "0.14.0" }
 parking_lot = "0.12.0"
 pin-project = "1.0.0"

transports/webrtc/Cargo.toml

@@ -0,0 +1,35 @@
+[package]
+name = "libp2p-webrtc"
+version = "0.1.0"
+authors = ["Parity Technologies <[email protected]>"]
+description = "WebRTC transport for libp2p"
+repository = "https://github.com/libp2p/rust-libp2p"
+license = ""
+edition = "2021"
+keywords = ["peer-to-peer", "libp2p", "networking"]
+categories = ["network-programming", "asynchronous"]
+rust-version = "1.56.1"
+
+[dependencies]
+bytes = "1"
+env_logger = "0.9.0"
+futures = "0.3.17"
+hex = "0.4"
+libp2p-core = { version = "0.33.0", path = "../../core", default-features = false  }
+log = "0.4.14"
+serde = { version = "1.0", features = ["derive"] }
+thiserror = "1"
+tinytemplate = "1.2"
+tokio-crate = { package = "tokio", version = "1.17.0", default-features = false, features = ["net"]}
+webrtc = { version = "0.4.0", git = "https://github.com/melekes/webrtc", branch = "anton/168-allow-persistent-certificates" }
+webrtc-ice = "0.6.6"
+webrtc-data = "0.3.3"
+webrtc-sctp = "0.4.3"
+if-watch = "0.2.2"
+futures-timer = "3.0"
+stun = "0.4.2"
+webrtc-util = { version = "0.5.3", default-features = false, features = ["conn", "vnet", "sync"] }
+async-trait = "0.1.52"
+
+[dev-dependencies]
+rcgen = "0.8.14"

transports/webrtc/src/connection/mod.rs

@@ -0,0 +1,78 @@
+// Copyright 2022 Parity Technologies (UK) Ltd.
+//
+// Permission is hereby granted, free of charge, to any person obtaining a
+// copy of this software and associated documentation files (the "Software"),
+// to deal in the Software without restriction, including without limitation
+// the rights to use, copy, modify, merge, publish, distribute, sublicense,
+// and/or sell copies of the Software, and to permit persons to whom the
+// Software is furnished to do so, subject to the following conditions:
+//
+// The above copyright notice and this permission notice shall be included in
+// all copies or substantial portions of the Software.
+//
+// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
+// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+// AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+// LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING
+// FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
+// DEALINGS IN THE SOFTWARE.
+
+mod poll_data_channel;
+
+use futures::prelude::*;
+use webrtc::peer_connection::RTCPeerConnection;
+use webrtc_data::data_channel::DataChannel;
+
+use std::io;
+use std::pin::Pin;
+use std::sync::Arc;
+use std::task::{Context, Poll};
+
+use poll_data_channel::PollDataChannel;
+
+/// A WebRTC connection over a single data channel. See lib documentation for
+/// the reasoning as to why a single data channel is being used.
+pub struct Connection<'a> {
+    /// `RTCPeerConnection` to the remote peer.
+    pub inner: RTCPeerConnection,
+    /// A data channel.
+    pub data_channel: PollDataChannel<'a>,
+}
+
+impl Connection<'_> {
+    pub fn new(peer_conn: RTCPeerConnection, data_channel: Arc<DataChannel>) -> Self {
+        Self {
+            inner: peer_conn,
+            data_channel: PollDataChannel::new(data_channel),
+        }
+    }
+}
+
+impl AsyncRead for Connection<'_> {
+    fn poll_read(
+        mut self: Pin<&mut Self>,
+        cx: &mut Context<'_>,
+        buf: &mut [u8],
+    ) -> Poll<io::Result<usize>> {
+        Pin::new(&mut self.data_channel).poll_read(cx, buf)
+    }
+}
+
+impl AsyncWrite for Connection<'_> {
+    fn poll_write(
+        mut self: Pin<&mut Self>,
+        cx: &mut Context<'_>,
+        buf: &[u8],
+    ) -> Poll<io::Result<usize>> {
+        Pin::new(&mut self.data_channel).poll_write(cx, buf)
+    }
+
+    fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> {
+        Pin::new(&mut self.data_channel).poll_flush(cx)
+    }
+
+    fn poll_close(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> {
+        Pin::new(&mut self.data_channel).poll_close(cx)
+    }
+}