feat: add memoffset package and update nix dependency features; refactor TunAsyncDevice methods

Author: spacemeowx2

Cargo.lock

@@ -37,7 +37,7 @@ windows-sys = { version = "0.61.2", features = [
 ] }
 
 [target.'cfg(unix)'.dependencies]
-nix = "0.31.0"
+nix = { version = "0.31.0", features = ["net"] }
 
 [features]
 default = []

protocol/raw/Cargo.toml

@@ -13,7 +13,7 @@ use tokio_smoltcp::{
     smoltcp::{phy::Checksum, wire::IpAddress},
 };
 use tokio_util::codec::Framed;
-use tun_crate::{create_as_async, Configuration, Device, TunPacket, TunPacketCodec};
+use tun_crate::{create_as_async, AbstractDevice, Configuration, TunPacketCodec};
 
 pub struct TunAsyncDevice {
     device_name: String,
@@ -37,11 +37,11 @@ pub fn get_tun(cfg: TunTapSetup) -> Result<TunAsyncDevice> {
         .up();
 
     if let Some(name) = &cfg.name {
-        config.name(name);
+        config.tun_name(name);
     }
 
     let dev = create_as_async(&config).map_err(map_other)?;
-    let device_name = dev.get_ref().name().to_string();
+    let device_name = dev.tun_name().map_err(map_other)?;
     let dev = dev.into_framed();
 
     tracing::info!("tun created: {}", device_name);
@@ -68,7 +68,8 @@ impl Stream for TunAsyncDevice {
     fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
         let p = ready!(self.dev.poll_next_unpin(cx));
 
-        Poll::Ready(p.map(|i| i.map(|p| p.get_bytes().to_vec())))
+        // TunPacketCodec yields Vec<u8>
+        Poll::Ready(p.map(|i| i.map(|p| p)))
     }
 }
 
@@ -80,7 +81,7 @@ impl Sink<Packet> for TunAsyncDevice {
     }
 
     fn start_send(mut self: Pin<&mut Self>, item: Packet) -> Result<(), Self::Error> {
-        self.dev.start_send_unpin(TunPacket::new(item))
+        self.dev.start_send_unpin(item)
     }
 
     fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> {

protocol/raw/src/device/unix.rs

@@ -142,7 +142,7 @@ impl LocalNetConfig {
                     return Err(io::Error::last_os_error().into());
                 }
 
-                socket.bind_device_by_index(std::num::NonZeroU32::new(idx))?;
+                socket.bind_device_by_index_v4(std::num::NonZeroU32::new(idx))?;
             }
         }