From 4bca196df31e18893af37ae975d452776b75cb8e Mon Sep 17 00:00:00 2001
From: oxalica <oxalicc@pm.me>
Date: Sat, 21 Sep 2024 15:20:14 -0400
Subject: [PATCH] fix(event): consistently use i64 for uid

---
 blahd/src/event.rs | 7 +++----
 blahd/src/lib.rs   | 3 +--
 2 files changed, 4 insertions(+), 6 deletions(-)

diff --git a/blahd/src/event.rs b/blahd/src/event.rs
index f178db8..0e99253 100644
--- a/blahd/src/event.rs
+++ b/blahd/src/event.rs
@@ -63,7 +63,7 @@ fn de_duration_sec<'de, D: de::Deserializer<'de>>(de: D) -> Result<Duration, D::
 
 #[derive(Debug, Default)]
 pub struct State {
-    pub user_listeners: Mutex<HashMap<u64, UserEventSender>>,
+    pub user_listeners: Mutex<HashMap<i64, UserEventSender>>,
 }
 
 #[derive(Debug)]
@@ -103,7 +103,7 @@ type UserEventSender = broadcast::Sender<Arc<SignedChatMsg>>;
 struct UserEventReceiver {
     rx: BroadcastStream<Arc<SignedChatMsg>>,
     st: Arc<AppState>,
-    uid: u64,
+    uid: i64,
 }
 
 impl Drop for UserEventReceiver {
@@ -147,8 +147,7 @@ pub async fn handle_ws(st: Arc<AppState>, ws: &mut WebSocket) -> Result<Infallib
             .db
             .with_read(|txn| txn.get_user(&auth.signee.user))
             .map_err(|err| anyhow!("{}", err.message))?;
-        // FIXME: Consistency of id's sign.
-        uid as u64
+        uid
     };
 
     tracing::debug!(%uid, "user connected");
diff --git a/blahd/src/lib.rs b/blahd/src/lib.rs
index 6b675f2..9c926ca 100644
--- a/blahd/src/lib.rs
+++ b/blahd/src/lib.rs
@@ -583,8 +583,7 @@ async fn room_msg_post(
     let listeners = st.event.user_listeners.lock();
     let mut cnt = 0usize;
     for uid in members {
-        // FIXME: u64 vs i64.
-        if let Some(tx) = listeners.get(&(uid as u64)) {
+        if let Some(tx) = listeners.get(&uid) {
             if tx.send(chat.clone()).is_ok() {
                 cnt += 1;
             }