From 9931a932bf1c7f27765f88bdb623c8831d54ff55 Mon Sep 17 00:00:00 2001 From: Joscha Date: Mon, 14 Feb 2022 13:31:56 +0100 Subject: [PATCH] Log new messages --- cove-server/src/main.rs | 14 +++++++++++--- 1 file changed, 11 insertions(+), 3 deletions(-) diff --git a/cove-server/src/main.rs b/cove-server/src/main.rs index ad10b7b..4ff9b29 100644 --- a/cove-server/src/main.rs +++ b/cove-server/src/main.rs @@ -27,14 +27,16 @@ struct Client { #[derive(Debug)] struct Room { + name: String, clients: HashMap, last_message: MessageId, last_timestamp: u128, } impl Room { - fn new() -> Self { + fn new(name: String) -> Self { Self { + name, clients: HashMap::new(), last_message: MessageId::of(&format!("{}", rand::thread_rng().gen::())), last_timestamp: util::timestamp(), @@ -109,6 +111,12 @@ impl Room { content, }; + self.last_message = message.id(); + info!( + "&{} now at {} ({})", + self.name, self.last_message, self.last_timestamp + ); + self.notify_except( id, &Packet::ntf(SendNtf { @@ -216,8 +224,8 @@ impl Server { self.rooms .lock() .await - .entry(name) - .or_insert_with(|| Arc::new(Mutex::new(Room::new()))) + .entry(name.clone()) + .or_insert_with(|| Arc::new(Mutex::new(Room::new(name)))) .clone() }