Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
15b00db451 |
No files matched your search
@@ -11,6 +11,24 @@ mod noise;
|
||||
mod transport;
|
||||
mod tun;
|
||||
|
||||
pub mod coordinator {
|
||||
pub mod coordinator_client {
|
||||
// This is a placeholder for the generated gRPC code
|
||||
pub struct GeneratedCoordinatorClient<T>(T);
|
||||
impl GeneratedCoordinatorClient<tonic::transport::Channel> {
|
||||
pub async fn connect(addr: String) -> Result<Self, tonic::transport::Error> {
|
||||
Ok(Self(tonic::transport::Channel::from_shared(addr).unwrap()))
|
||||
}
|
||||
}
|
||||
}
|
||||
pub struct RegisterRequest { pub network_key: String, pub node_id: String, pub public_key: String, pub local_ip: String }
|
||||
pub struct RegisterResponse { pub virtual_ip: String, pub session_token: String }
|
||||
pub struct HeartbeatRequest { pub node_id: String, pub session_token: String, pub public_endpoint: String }
|
||||
pub struct HeartbeatResponse { pub session_token: String }
|
||||
pub struct PeerRequest { pub target_node_id: String, pub session_token: String }
|
||||
pub struct PeerResponse { pub endpoint: String }
|
||||
}
|
||||
|
||||
use coordinator_client::CoordinatorClient;
|
||||
use transport::{Transport, Packet};
|
||||
use tun::TunInterface;
|
||||
|
||||
+1
-1
@@ -42,7 +42,7 @@ unsafe impl Sync for TunInterface {}
|
||||
|
||||
impl TunInterface {
|
||||
pub fn new(name: &str) -> io::Result<Self> {
|
||||
let wide_name: Vec<u16> = OsString::from(name).encode_utf16().chain(std::iter::once(0)).collect();
|
||||
let wide_name: Vec<u16> = name.encode_utf16().chain(std::iter::once(0)).collect();
|
||||
|
||||
unsafe {
|
||||
let adapter = WintunOpenAdapter(wide_name.as_ptr());
|
||||
|
||||
Reference in new issue
Block a user