tokio UDP port open in hptp-recv

Cargo.lock

@@ -96,6 +96,7 @@ dependencies = [
 name = "hptp-recv"
 version = "0.1.0"
 dependencies = [
+ "failure",
  "hptp",
  "tokio",
 ]
@@ -104,9 +105,7 @@ dependencies = [
 name = "hptp-send"
 version = "0.1.0"
 dependencies = [
- "failure",
  "hptp",
- "tokio",
 ]
 
 [[package]]

hptp-recv/Cargo.toml

@@ -9,3 +9,5 @@ edition = "2018"
 
 [dependencies]
 hptp = { path = "../hptp" }
+tokio = {version = "0.2.*", features = ["rt-core", "io-std", "io-util", "udp"]}
+failure = "0.1.7"

hptp-recv/src/main.rs

@@ -1,5 +1,33 @@
+extern crate failure;
 extern crate hptp;
+extern crate tokio;
 
-fn main() {
-    println!("{}", hptp::RECV_GREETING);
+use failure::Error;
+use hptp::log::Logger;
+use std::net::Ipv4Addr;
+use tokio::net::UdpSocket;
+
+fn main() -> Result<(), Box<dyn std::error::Error>> {
+    let mut rt = tokio::runtime::Runtime::new()?;
+    let mut log = Logger::new();
+    let fut = start(&mut log);
+    Ok(rt.block_on(fut)?)
+}
+
+async fn start(log: &mut Logger) -> Result<(), Error> {
+    let host = (Ipv4Addr::LOCALHOST, 3700);
+    let sock = UdpSocket::bind(host).await?;
+
+    log.bound(sock.local_addr()?.port()).await?;
+
+    let (mut rx, _tx) = sock.split();
+    let mut buf = [0u8; 2000];
+    loop {
+        let (n, _who) = rx.recv_from(&mut buf).await?;
+        log.debug_msg(match String::from_utf8(buf[..n].into()) {
+            Ok(s) => format!("got: {:?}", s),
+            Err(e) => format!("got: {:?} (invalid utf8)", e.as_bytes()),
+        })
+        .await?;
+    }
 }