wip

Author: Itsusinn

Cargo.lock

@@ -6,7 +6,7 @@ members = [
 ]
 
 [workspace.package]
-version = "0.7.6"
+version = "0.1.0"
 repository = "https://github.com/zephry-works/wind"
 edition = "2024"
 description = "Placeholder"

Cargo.toml

@@ -4,4 +4,9 @@ version.workspace = true
 repository.workspace = true
 edition.workspace = true
 description.workspace = true
-license = "MIT OR Apache-2.0"
+license = "MIT OR Apache-2.0"
+
+[dependencies]
+tokio = { version = "*", default-features = false }
+
+serde = { version = "*", features = ["derive"] }

crates/wind-core/Cargo.toml

@@ -0,0 +1,59 @@
+use std::net::{IpAddr, Ipv4Addr, Ipv6Addr, SocketAddr};
+
+use serde::{Deserialize, Serialize};
+
+#[derive(Serialize, Deserialize, Debug, Clone)]
+pub struct Iface {
+   pub name:  String,
+   pub ipv4:  Option<Ipv4Addr>,
+   pub ipv6:  Option<Ipv6Addr>,
+   pub index: u32,
+}
+
+#[derive(Debug, Clone, Default)]
+pub enum Stack {
+   #[default]
+   V4,
+   V6,
+}
+impl From<&SocketAddr> for Stack {
+   fn from(value: &SocketAddr) -> Self {
+      match value {
+         SocketAddr::V4(..) => Self::V4,
+         SocketAddr::V6(..) => Self::V6,
+      }
+   }
+}
+impl From<&IpAddr> for Stack {
+   fn from(value: &IpAddr) -> Self {
+      match value {
+         IpAddr::V4(..) => Self::V4,
+         IpAddr::V6(..) => Self::V6,
+      }
+   }
+}
+
+#[derive(Serialize, Debug, Clone, Copy)]
+pub enum Network {
+   TCP,
+   UDP,
+   ICMPv4,
+   ICMPv6,
+}
+
+#[derive(Debug, Clone, Copy)]
+pub enum StackPrefer {
+   V4,
+   V6,
+   V4V6,
+   V6V4,
+}
+
+impl StackPrefer {
+   pub fn support_v6(&self) -> bool {
+      match self {
+         StackPrefer::V4 => false,
+         _ => true,
+      }
+   }
+}

crates/wind-core/src/interface.rs

@@ -0,0 +1,5 @@
+mod interface;
+mod outbound;
+
+pub use interface::*;
+pub use outbound::*;

crates/wind-core/src/lib.rs

@@ -0,0 +1,12 @@
+use tokio::io::{AsyncRead, AsyncWrite};
+
+pub trait AbstractTcpStream: AsyncRead + AsyncWrite {}
+
+impl<T> AbstractTcpStream for T where T: AsyncRead + AsyncWrite {}
+
+pub trait AbstractOutbound {
+   /// TCP traffic which needs handled by outbound
+   fn handle_tcp(
+      via: Option<impl AbstractOutbound + Sized + Send>,
+   ) -> impl Future<Output = impl AbstractTcpStream> + Send;
+}

crates/wind-core/src/main.rs

@@ -7,16 +7,22 @@ description.workspace = true
 license = "MIT OR Apache-2.0"
 
 [features]
-default = ["server", "client"]
+default = ["server", "client", "aws-lc-rs"]
 decode = []
 encode = []
 server = ["decode"]
 client = ["encode"]
+aws-lc-rs = ["rustls/aws-lc-rs"]
+ring = ["rustls/ring"]
 
 [dependencies]
+wind-core = { path = "../wind-core"}
+
+
 # Async
 tokio = { version = "*", default-features = false }
 tokio-util = { version = "*", features = ["codec"] }
+quinn = "*"
 
 tokio-stream = "*"
 futures-util = { version = "*", default-features = false, features = ["sink"] }
@@ -28,6 +34,13 @@ hex = { package = "const-hex", version = "1" }
 # Patterns
 num_enum = "0.7"
 snafu = "0.8"
+enum_dispatch = "*"
+secrecy = "0.10"
+
+# TLS
+tokio-rustls = { version = "*", default-features = false, features = ["logging"] }
+rustls = { version  = "*", default-features = false }
+rustls-platform-verifier = "*"
 
 [dev-dependencies]
 tokio = { version = "*", default-features = false, features = ["macros", "rt"] }

crates/wind-core/src/outbound.rs

@@ -0,0 +1,36 @@
+use tokio::io::{AsyncRead, AsyncWrite};
+
+use crate::outbound::TuicTcpStream;
+
+impl AsyncRead for TuicTcpStream {
+   fn poll_read(
+      self: std::pin::Pin<&mut Self>,
+      cx: &mut std::task::Context<'_>,
+      buf: &mut tokio::io::ReadBuf<'_>,
+   ) -> std::task::Poll<std::io::Result<()>> {
+      todo!()
+   }
+}
+impl AsyncWrite for TuicTcpStream {
+   fn poll_write(
+      self: std::pin::Pin<&mut Self>,
+      cx: &mut std::task::Context<'_>,
+      buf: &[u8],
+   ) -> std::task::Poll<Result<usize, std::io::Error>> {
+      todo!()
+   }
+
+   fn poll_flush(
+      self: std::pin::Pin<&mut Self>,
+      cx: &mut std::task::Context<'_>,
+   ) -> std::task::Poll<Result<(), std::io::Error>> {
+      todo!()
+   }
+
+   fn poll_shutdown(
+      self: std::pin::Pin<&mut Self>,
+      cx: &mut std::task::Context<'_>,
+   ) -> std::task::Poll<Result<(), std::io::Error>> {
+      todo!()
+   }
+}

crates/wind-tuic/Cargo.toml

@@ -0,0 +1 @@
+