diff --git a/src/dns.rs b/src/dns.rs index cebe1e4..430b954 100644 --- a/src/dns.rs +++ b/src/dns.rs @@ -24,7 +24,7 @@ impl DnsResolver { )) } - pub(crate) async fn resolve(&self, host: &str) -> Result, Box> { + async fn resolve(&self, host: &str) -> Result, Box> { let response = self.resolver.lookup_ip(host).await?; for ip in response.iter() { log::info!("{host}: adding ip {ip}"); @@ -32,7 +32,7 @@ impl DnsResolver { Ok(response.iter().collect()) } - pub async fn run(mut self, server: Server) { + pub(crate) async fn run(mut self, server: Server) { tokio::select! { _ = server.cancelled() => {}, _ = self.do_dns(&server) => {}, @@ -56,7 +56,7 @@ impl DnsResolver { }; /* FIXME race -> need some other event */ - server.notify_client_update(handle); + server.client_resolved(handle); log::info!("resolving ({handle}) `{hostname}` ..."); let ips = match self.resolve(&hostname).await { @@ -76,7 +76,7 @@ impl DnsResolver { s.ips = addrs; s.resolving = false; } - server.notify_client_update(handle); + server.client_resolved(handle); } } } diff --git a/src/server.rs b/src/server.rs index d4008a2..9f57ee5 100644 --- a/src/server.rs +++ b/src/server.rs @@ -287,7 +287,7 @@ impl Server { self.notify_frontend(FrontendEvent::PortChanged(port, msg)); } - pub(crate) fn notify_client_update(&self, handle: ClientHandle) { + pub(crate) fn client_resolved(&self, handle: ClientHandle) { let state = self.client_manager.borrow().get(handle).cloned(); if let Some((config, state)) = state { self.notify_frontend(FrontendEvent::State(handle, config, state)); @@ -373,7 +373,7 @@ impl Server { handle } - pub async fn deactivate_client( + async fn deactivate_client( &self, capture: &Sender, emulate: &Sender, @@ -390,7 +390,7 @@ impl Server { log::debug!("deactivating client {handle} done"); } - pub async fn activate_client( + async fn activate_client( &self, capture: &Sender, emulate: &Sender, @@ -423,7 +423,7 @@ impl Server { log::debug!("activating client {handle} done"); } - pub async fn remove_client( + async fn remove_client( &self, capture: &Sender, emulate: &Sender, diff --git a/src/server/capture_task.rs b/src/server/capture_task.rs index 7655dfb..17001ca 100644 --- a/src/server/capture_task.rs +++ b/src/server/capture_task.rs @@ -19,7 +19,7 @@ use crate::{client::ClientHandle, frontend::Status, server::State}; use super::Server; #[derive(Debug, Error)] -pub enum LanMouseCaptureError { +pub(crate) enum LanMouseCaptureError { #[error("error creating input-capture: `{0}`")] Create(#[from] CaptureCreationError), #[error("error while capturing input: `{0}`")] @@ -27,7 +27,7 @@ pub enum LanMouseCaptureError { } #[derive(Clone, Copy, Debug)] -pub enum CaptureEvent { +pub(crate) enum CaptureEvent { /// capture must release the mouse Release, /// add a capture client @@ -36,7 +36,7 @@ pub enum CaptureEvent { Destroy(CaptureHandle), } -pub fn new( +pub(crate) fn new( server: Server, capture_rx: Receiver, udp_send: Sender<(Event, SocketAddr)>, diff --git a/src/server/emulation_task.rs b/src/server/emulation_task.rs index a0212df..f788e95 100644 --- a/src/server/emulation_task.rs +++ b/src/server/emulation_task.rs @@ -21,7 +21,7 @@ use input_event::{Event, KeyboardEvent}; use super::{network_task::NetworkError, CaptureEvent, Server}; #[derive(Clone, Debug)] -pub enum EmulationEvent { +pub(crate) enum EmulationEvent { /// create a new client Create(EmulationHandle), /// destroy a client @@ -30,7 +30,7 @@ pub enum EmulationEvent { ReleaseKeys(ClientHandle), } -pub fn new( +pub(crate) fn new( server: Server, emulation_rx: Receiver, udp_rx: Receiver>, diff --git a/src/server/network_task.rs b/src/server/network_task.rs index 78d0c4b..20e2c3b 100644 --- a/src/server/network_task.rs +++ b/src/server/network_task.rs @@ -11,7 +11,7 @@ use input_event::{Event, ProtocolError}; use super::Server; -pub async fn new( +pub(crate) async fn new( server: Server, udp_recv_tx: Sender>, udp_send_rx: Receiver<(Event, SocketAddr)>, diff --git a/src/server/ping_task.rs b/src/server/ping_task.rs index 4908d65..784282c 100644 --- a/src/server/ping_task.rs +++ b/src/server/ping_task.rs @@ -10,7 +10,7 @@ use super::{capture_task::CaptureEvent, emulation_task::EmulationEvent, Server, const MAX_RESPONSE_TIME: Duration = Duration::from_millis(500); -pub fn new( +pub(crate) fn new( server: Server, sender_ch: Sender<(Event, SocketAddr)>, emulate_notify: Sender,