chat-action-bar: Update stack page when needed

E.g. when a channel is muted/unmuted in a different device.

Author: melix99

src/session/content/chat_action_bar.rs

@@ -12,7 +12,9 @@ use tdlib::{functions, types};
 
 use crate::components::MessageEntry;
 use crate::session::content::SendPhotoDialog;
-use crate::tdlib::{BoxedDraftMessage, BoxedFormattedText, Chat, ChatType, SecretChatState};
+use crate::tdlib::{
+    BasicGroup, BoxedDraftMessage, BoxedFormattedText, Chat, ChatType, SecretChatState, Supergroup,
+};
 use crate::utils::{block_on, spawn, temp_dir};
 use crate::{expressions, strings};
 
@@ -29,6 +31,7 @@ enum ChatActionBarState {
 mod imp {
     use super::*;
     use once_cell::sync::Lazy;
+    use once_cell::unsync::OnceCell;
     use std::cell::{Cell, RefCell};
 
     #[derive(Debug, Default, CompositeTemplate)]
@@ -38,6 +41,9 @@ mod imp {
         pub(super) chat_action_in_cooldown: Cell<bool>,
         pub(super) state: Cell<ChatActionBarState>,
         pub(super) emoji_chooser: RefCell<Option<gtk::EmojiChooser>>,
+        pub(super) chat_signal_group: OnceCell<glib::SignalGroup>,
+        pub(super) basic_group_signal_group: OnceCell<glib::SignalGroup>,
+        pub(super) supergroup_signal_group: OnceCell<glib::SignalGroup>,
         pub(super) bindings: RefCell<Vec<gtk::ExpressionWatch>>,
         #[template_child]
         pub(super) top_bar_revealer: TemplateChild<gtk::Revealer>,
@@ -117,12 +123,6 @@ mod imp {
                 None,
                 |widget, _, _| async move {
                     widget.toggle_mute().await;
-                    let btn = &widget.imp().mute_button;
-                    if widget.is_chat_muted() {
-                        btn.set_label(&gettext("Unmute"));
-                    } else {
-                        btn.set_label(&gettext("Mute"));
-                    }
                 },
             );
             klass.install_action_async(
@@ -221,6 +221,8 @@ mod imp {
                 .connect_activate(clone!(@weak obj => move |_| {
                     obj.activate_action("chat-action-bar.send-message", None).unwrap()
                 }));
+
+            obj.create_signal_groups();
         }
 
         fn dispose(&self) {
@@ -251,6 +253,55 @@ impl ChatActionBar {
         glib::Object::new()
     }
 
+    fn create_signal_groups(&self) {
+        let imp = self.imp();
+
+        let chat_signal_group = glib::SignalGroup::new(Chat::static_type());
+        chat_signal_group.connect_local(
+            "notify::notification-settings",
+            false,
+            clone!(@weak self as obj => @default-return None, move |_| {
+                obj.update_stack_page();
+                None
+            }),
+        );
+        chat_signal_group.connect_local(
+            "notify::is-blocked",
+            false,
+            clone!(@weak self as obj => @default-return None, move |_| {
+                obj.update_stack_page();
+                None
+            }),
+        );
+        imp.chat_signal_group.set(chat_signal_group).unwrap();
+
+        let basic_group_signal_group = glib::SignalGroup::new(BasicGroup::static_type());
+        basic_group_signal_group.connect_local(
+            "notify::status",
+            false,
+            clone!(@weak self as obj => @default-return None, move |_| {
+                obj.update_stack_page();
+                None
+            }),
+        );
+        imp.basic_group_signal_group
+            .set(basic_group_signal_group)
+            .unwrap();
+
+        let supergroup_signal_group = glib::SignalGroup::new(Supergroup::static_type());
+        supergroup_signal_group.connect_local(
+            "notify::status",
+            false,
+            clone!(@weak self as obj => @default-return None, move |_| {
+                obj.update_stack_page();
+                None
+            }),
+        );
+        imp.supergroup_signal_group
+            .set(supergroup_signal_group)
+            .unwrap();
+    }
+
     fn cancel_action(&self) {
         use ChatActionBarState::*;
 
@@ -694,10 +745,11 @@ impl ChatActionBar {
         }
 
         imp.chat.replace(chat);
-        self.notify("chat");
 
-        // FIXME: Update entry_stack everytime ChatMemberStatus or ChatPermissions has changed
         self.update_stack_page();
+        self.update_signal_groups();
+
+        self.notify("chat");
     }
 
     pub(crate) fn reply_to_message_id(&self, message_id: i64) {
@@ -708,7 +760,7 @@ impl ChatActionBar {
         self.set_state(ChatActionBarState::Editing(message_id));
     }
 
-    pub(crate) fn update_stack_page(&self) {
+    fn update_stack_page(&self) {
         let imp = self.imp();
         if let Some(chat) = self.chat() {
             match chat.type_() {
@@ -778,6 +830,28 @@ impl ChatActionBar {
             }
         }
     }
+
+    fn update_signal_groups(&self) {
+        let imp = self.imp();
+
+        let chat = self.chat();
+        imp.chat_signal_group
+            .get()
+            .unwrap()
+            .set_target(chat.as_ref());
+
+        let basic_group = chat.as_ref().and_then(|c| c.type_().basic_group());
+        imp.basic_group_signal_group
+            .get()
+            .unwrap()
+            .set_target(basic_group);
+
+        let supergroup = chat.as_ref().and_then(|c| c.type_().supergroup());
+        imp.supergroup_signal_group
+            .get()
+            .unwrap()
+            .set_target(supergroup);
+    }
 }
 
 async fn save_stream_to_file(

src/tdlib/chat.rs

@@ -49,6 +49,20 @@ impl ChatType {
             _ => return None,
         })
     }
+
+    pub(crate) fn basic_group(&self) -> Option<&BasicGroup> {
+        Some(match self {
+            ChatType::BasicGroup(basic_group) => basic_group,
+            _ => return None,
+        })
+    }
+
+    pub(crate) fn supergroup(&self) -> Option<&Supergroup> {
+        Some(match self {
+            ChatType::Supergroup(supergroup) => supergroup,
+            _ => return None,
+        })
+    }
 }
 
 mod imp {