aboutsummaryrefslogtreecommitdiffstats
path: root/src/cmd/server.rs
diff options
context:
space:
mode:
authorJesse Luehrs <doy@tozt.net>2019-09-01 22:15:28 -0400
committerJesse Luehrs <doy@tozt.net>2019-09-01 22:16:02 -0400
commit9479692af28d82e496dde9609f3bd308a8b9a7ff (patch)
tree3dda010a942e135ee80dca1960977cde553da1c0 /src/cmd/server.rs
parent82f3a81589da723497d5aa1ffa7f8b26acf3520c (diff)
downloadteleterm-9479692af28d82e496dde9609f3bd308a8b9a7ff.tar.gz
teleterm-9479692af28d82e496dde9609f3bd308a8b9a7ff.zip
actually, remove protobufs too
Diffstat (limited to 'src/cmd/server.rs')
-rw-r--r--src/cmd/server.rs15
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(())