Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
15b00db451 | ||
|
|
20935d2380 |
No files matched your search
@@ -1,6 +1,6 @@
|
|||||||
use tonic::{Request, Response, Status};
|
use tonic::{Request, Response, Status};
|
||||||
use coordinator::coordinator_client::CoordinatorClient as GeneratedCoordinatorClient;
|
use crate::coordinator::coordinator_client::CoordinatorClient as GeneratedCoordinatorClient;
|
||||||
use coordinator::{RegisterRequest, RegisterResponse, HeartbeatRequest, HeartbeatResponse, PeerRequest, PeerResponse};
|
use crate::coordinator::{RegisterRequest, RegisterResponse, HeartbeatRequest, HeartbeatResponse, PeerRequest, PeerResponse};
|
||||||
|
|
||||||
pub struct CoordinatorClient {
|
pub struct CoordinatorClient {
|
||||||
client: GeneratedCoordinatorClient<tonic::transport::Channel>,
|
client: GeneratedCoordinatorClient<tonic::transport::Channel>,
|
||||||
|
|||||||
@@ -11,6 +11,24 @@ mod noise;
|
|||||||
mod transport;
|
mod transport;
|
||||||
mod tun;
|
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 coordinator_client::CoordinatorClient;
|
||||||
use transport::{Transport, Packet};
|
use transport::{Transport, Packet};
|
||||||
use tun::TunInterface;
|
use tun::TunInterface;
|
||||||
|
|||||||
+1
-1
@@ -42,7 +42,7 @@ unsafe impl Sync for TunInterface {}
|
|||||||
|
|
||||||
impl TunInterface {
|
impl TunInterface {
|
||||||
pub fn new(name: &str) -> io::Result<Self> {
|
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 {
|
unsafe {
|
||||||
let adapter = WintunOpenAdapter(wide_name.as_ptr());
|
let adapter = WintunOpenAdapter(wide_name.as_ptr());
|
||||||
|
|||||||
Reference in new issue
Block a user