gruberb/protohackers
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Merge branch 'main' of github.com:gruberb/protohackers-rs into main

Browse source
This commit is contained in:
Bastian Gruber 2023-04-29 12:03:51 +00:00
commit 6ef6cb5b4b
1 changed files with 16 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

27
problem_03/src/server.rs
View file

@ -57,17 +57,22 @@ async fn main() -> Result<()> {
// we won't process until we find one. // we won't process until we find one.
match framed.next().await { match framed.next().await {
Some(Ok(username)) => { Some(Ok(username)) => {
name = username.clone(); if !username.is_empty() && username.is_ascii() {
db.0.lock().unwrap().insert(username.clone(), address); name = username.clone();
let message = compose_message(username.clone(), db.clone()); db.0.lock().unwrap().insert(username.clone(), address);
info!("Adding username: {username} to db"); let message = compose_message(username.clone(), db.clone());
let _ = framed.send(message).await; info!("Adding username: {username} to db");
info!("Send message to client"); let _ = framed.send(message).await;
let b = BroadcastMessage( info!("Send message to client");
username.clone(), let b = BroadcastMessage(
format!("* {} has entered the room", username), username.clone(),
); format!("* {} has entered the room", username),
let _ = tx.send(b); );
let _ = tx.send(b);
} else {
return;
}
} }
Some(Err(e)) => { Some(Err(e)) => {
error!("Error parsing message: {e}"); error!("Error parsing message: {e}");