diff options
author | Jesse Luehrs <doy@tozt.net> | 2019-09-01 22:15:28 -0400 |
---|---|---|
committer | Jesse Luehrs <doy@tozt.net> | 2019-09-01 22:16:02 -0400 |
commit | 9479692af28d82e496dde9609f3bd308a8b9a7ff (patch) | |
tree | 3dda010a942e135ee80dca1960977cde553da1c0 /src/cmd/server.rs | |
parent | 82f3a81589da723497d5aa1ffa7f8b26acf3520c (diff) | |
download | teleterm-9479692af28d82e496dde9609f3bd308a8b9a7ff.tar.gz teleterm-9479692af28d82e496dde9609f3bd308a8b9a7ff.zip |
actually, remove protobufs too
Diffstat (limited to 'src/cmd/server.rs')
-rw-r--r-- | src/cmd/server.rs | 15 |
1 files changed, 11 insertions, 4 deletions
diff --git a/src/cmd/server.rs b/src/cmd/server.rs index 9433e83..f994ee7 100644 --- a/src/cmd/server.rs +++ b/src/cmd/server.rs @@ -25,12 +25,19 @@ fn run_impl() -> Result<()> { let listener = tokio::net::TcpListener::bind(&addr).context(Bind)?; let server = listener .incoming() - .for_each(|_sock| { - println!("got a connection"); - Ok(()) - }) .map_err(|e| { eprintln!("accept failed: {}", e); + }) + .for_each(|sock| { + crate::protocol::Message::read_async(sock) + .map(|msg| match msg { + crate::protocol::Message::StartCasting { username } => { + println!("got a connection from {}", username); + } + }) + .map_err(|e| { + eprintln!("failed to read message: {}", e); + }) }); tokio::run(server); Ok(()) |