feat: make `MacawUser`, `MacawChat` and `MacawMessage` arena-allocated

1 files changed, 6 insertions, 6 deletions

diff --git a/src/message_subscriptions.rs b/src/message_subscriptions.rs
index 5b1d276..17d924f 100644
--- a/src/message_subscriptions.rs
+++ b/src/message_subscriptions.rs
@@ -4,11 +4,11 @@ use jid::BareJID;
 use tokio::sync::mpsc::{self, Receiver};
 use uuid::Uuid;
 
-use crate::message::MacawMessage;
+use crate::message::{ArcMacawMessage, MacawMessage};
 
 pub struct MessageSubscriptions {
-    all: HashMap<Uuid, mpsc::Sender<(BareJID, MacawMessage)>>,
-    subset: HashMap<BareJID, HashMap<Uuid, mpsc::Sender<MacawMessage>>>,
+    all: HashMap<Uuid, mpsc::Sender<(BareJID, ArcMacawMessage)>>,
+    subset: HashMap<BareJID, HashMap<Uuid, mpsc::Sender<ArcMacawMessage>>>,
 }
 
 impl MessageSubscriptions {
@@ -19,7 +19,7 @@ impl MessageSubscriptions {
         }
     }
 
-    pub async fn broadcast(&mut self, to: BareJID, message: MacawMessage) {
+    pub async fn broadcast(&mut self, to: BareJID, message: ArcMacawMessage) {
         // subscriptions to all
         let mut removals = Vec::new();
         for (id, sender) in &self.all {
@@ -54,14 +54,14 @@ impl MessageSubscriptions {
         }
     }
 
-    pub fn subscribe_all(&mut self) -> (Uuid, Receiver<(BareJID, MacawMessage)>) {
+    pub fn subscribe_all(&mut self) -> (Uuid, Receiver<(BareJID, ArcMacawMessage)>) {
         let (send, recv) = mpsc::channel(10);
         let id = Uuid::new_v4();
         self.all.insert(id, send);
         (id, recv)
     }
 
-    pub fn subscribe_chat(&mut self, chat: BareJID) -> (Uuid, Receiver<MacawMessage>) {
+    pub fn subscribe_chat(&mut self, chat: BareJID) -> (Uuid, Receiver<ArcMacawMessage>) {
         let (send, recv) = mpsc::channel(10);
         let id = Uuid::new_v4();
         if let Some(chat_subscribers) = self.subset.get_mut(&chat) {