1 files changed, 72 insertions, 0 deletions
diff --git a/src/open_chats.rs b/src/open_chats.rs
new file mode 100644
index 0000000..bf2eb73
--- /dev/null
+++ b/src/open_chats.rs
@@ -0,0 +1,72 @@
+// SPDX-FileCopyrightText: 2025 cel <cel@bunny.garden>
+//
+// SPDX-License-Identifier: AGPL-3.0-or-later
+
+use filamento::chat::ChatStoreFields;
+use indexmap::IndexMap;
+use jid::BareJID;
+use leptos::prelude::*;
+use reactive_stores::{ArcStore, Store};
+use tracing::debug;
+
+use crate::chat::{ArcMacawChat, MacawChat};
+
+#[derive(Store, Default)]
+pub struct OpenChatsPanel {
+    // jid must be a chat in the chats map
+    chat_view: Option<BareJID>,
+    #[store(key: BareJID = |(jid, _)| jid.clone())]
+    chats: IndexMap<BareJID, ArcMacawChat>,
+}
+
+pub fn open_chat(open_chats: Store<OpenChatsPanel>, chat: ArcMacawChat) {
+    if let Some(jid) = &*open_chats.chat_view().read() {
+        if let Some((index, _jid, entry)) = open_chats.chats().write().shift_remove_full(jid) {
+            let new_jid = chat.get().correspondent().read().clone();
+            open_chats
+                .chats()
+                .write()
+                .insert_before(index, new_jid.clone(), chat);
+            *open_chats.chat_view().write() = Some(new_jid);
+        } else {
+            let new_jid = chat.get().correspondent().read().clone();
+            open_chats.chats().write().insert(new_jid.clone(), chat);
+            *open_chats.chat_view().write() = Some(new_jid);
+        }
+    } else {
+        let new_jid = chat.get().correspondent().read().clone();
+        open_chats.chats().write().insert(new_jid.clone(), chat);
+        *open_chats.chat_view().write() = Some(new_jid);
+    }
+}
+
+impl OpenChatsPanel {
+    pub fn open(&mut self, chat: ArcMacawChat) {
+        if let Some(jid) = &mut self.chat_view {
+            debug!("a chat was already open");
+            if let Some((index, _jid, entry)) = self.chats.shift_remove_full(jid) {
+                let new_jid = chat.get().correspondent().read().clone();
+                self.chats.insert_before(index, new_jid.clone(), chat);
+                *&mut self.chat_view = Some(new_jid);
+            } else {
+                let new_jid = chat.get().correspondent().read().clone();
+                self.chats.insert(new_jid.clone(), chat);
+                *&mut self.chat_view = Some(new_jid);
+            }
+        } else {
+            let new_jid = chat.get().correspondent().read().clone();
+            self.chats.insert(new_jid.clone(), chat);
+            *&mut self.chat_view = Some(new_jid);
+        }
+        debug!("opened chat");
+    }
+
+    // TODO:
+    // pub fn open_in_new_tab_unfocused(&mut self) {
+
+    // }
+
+    // pub fn open_in_new_tab_focus(&mut self) {
+
+    // }
+}