feat: add tun/tap for mac

__network/tuntapmac/src/main.rs

@@ -0,0 +1,51 @@
+use std::env;
+use std::io::Result;
+use std::net::SocketAddr;
+
+use futures::{Future, Stream};
+use tokio_core::net::{UdpCodec, UdpSocket};
+use tokio_core::reactor::Core;
+
+use tun_tap_mac::{Iface, Mode};
+use tun_tap_mac::r#async::Async;
+
+struct VecCodec(SocketAddr);
+
+impl UdpCodec for VecCodec {
+    type In = Vec<u8>;
+    type Out = Vec<u8>;
+    fn decode(&mut self, _src: &SocketAddr, buf: &[u8]) -> Result<Self::In> {
+        Ok(buf.to_owned())
+    }
+    fn encode(&mut self, msg: Self::Out, buf: &mut Vec<u8>) -> SocketAddr {
+        buf.extend(&msg);
+        self.0
+    }
+}
+
+fn main() {
+    let mut core = Core::new().unwrap();
+    let loc_address = env::args()
+        .nth(1)
+        .unwrap()
+        .parse()
+        .unwrap();
+    let rem_address = env::args()
+        .nth(2)
+        .unwrap()
+        .parse()
+        .unwrap();
+    let socket = UdpSocket::bind(&loc_address, &core.handle())
+        .unwrap();
+    let (sender, receiver) = socket.framed(VecCodec(rem_address))
+        .split();
+    let tun = Iface::new("vpn%d", Mode::Tun)
+        .unwrap();
+    let (sink, stream) = Async::new(tun, &core.handle())
+        .unwrap()
+        .split();
+    let reader = stream.forward(sender);
+    let writer = receiver.forward(sink);
+    core.run(reader.join(writer))
+        .unwrap();
+}