diff --git a/src/main.rs b/src/bin/relay.rs similarity index 83% rename from src/main.rs rename to src/bin/relay.rs index c72d830..77f7390 100644 --- a/src/main.rs +++ b/src/bin/relay.rs @@ -21,9 +21,7 @@ use tokio::{ time::delay_for, }; -mod watcher; - -use watcher::Watchers; +use ptth::watcher::Watchers; #[derive (Clone)] enum Message { @@ -60,6 +58,17 @@ async fn handle_wake (state: Arc ) status_reply (StatusCode::OK, "ok\n") } +async fn handle_udp_send () -> Response +{ + use tokio::net::UdpSocket; + + let mut sock = UdpSocket::bind (SocketAddr::from (([0,0,0,0], 0))).await.unwrap (); + + sock.send_to (b"handle_udp_send\n", SocketAddr::from (([127,0,0,1], 9000u16))).await.unwrap (); + + status_reply (StatusCode::OK, "ok\n") +} + async fn handle_all (req: Request , state: Arc ) -> Result , Infallible> { @@ -72,6 +81,9 @@ async fn handle_all (req: Request , state: Arc ) else if uri == "/wake" { Ok (handle_wake (state).await) } + else if uri == "/udp_send" { + Ok (handle_udp_send ().await) + } else { Ok (status_reply (StatusCode::OK, "Hi\n")) } diff --git a/src/lib.rs b/src/lib.rs new file mode 100644 index 0000000..887d28c --- /dev/null +++ b/src/lib.rs @@ -0,0 +1 @@ +pub mod watcher;