refactor(multiverse): Add a common method to execute commands on rooms

Author: poljar

labs/multiverse/src/widgets/room_view/mod.rs

@@ -10,7 +10,7 @@ use matrix_sdk::{
         api::client::receipt::create_receipt::v3::ReceiptType,
         events::room::message::RoomMessageEventContent, OwnedRoomId, UserId,
     },
-    RoomState,
+    Room, RoomState,
 };
 use ratatui::{prelude::*, widgets::*};
 use tokio::{spawn, task::JoinHandle};
@@ -264,56 +264,59 @@ impl RoomView {
         };
     }
 
-    async fn invite_member(&mut self, user_id: &str) {
+    /// Attempt to find the currently selected room and pass it to the async
+    /// callback.
+    async fn call_with_room(&self, function: impl AsyncFnOnce(Room, &StatusHandle)) {
         let Some(room) = self
             .selected_room
             .as_deref()
             .and_then(|room_id| self.ui_rooms.lock().get(room_id).cloned())
         else {
             self.status_handle
-                .set_message(format!("Coulnd't find the room object to invite {user_id}"));
+                .set_message("Couldn't find a room selected room to perform an action".to_owned());
             return;
         };
 
-        let user_id = match UserId::parse_with_server_name(
-            user_id,
-            room.client().user_id().unwrap().server_name(),
-        ) {
-            Ok(user_id) => user_id,
-            Err(e) => {
-                self.status_handle
-                    .set_message(format!("Failed to parse {user_id} as a user ID: {e:?}"));
-                return;
-            }
-        };
+        function(room, &self.status_handle).await
+    }
 
-        match room.invite_user_by_id(&user_id).await {
-            Ok(_) => {
-                self.status_handle
-                    .set_message(format!("Successfully invited {user_id} to the room"));
-                self.input.clear();
-            }
-            Err(e) => {
-                self.status_handle
-                    .set_message(format!("Failed to invite {user_id} to the room: {e:?}"));
+    async fn invite_member(&mut self, user_id: &str) {
+        self.call_with_room(async move |room, status_handle| {
+            let user_id = match UserId::parse_with_server_name(
+                user_id,
+                room.client().user_id().unwrap().server_name(),
+            ) {
+                Ok(user_id) => user_id,
+                Err(e) => {
+                    status_handle
+                        .set_message(format!("Failed to parse {user_id} as a user ID: {e:?}"));
+                    return;
+                }
+            };
+
+            match room.invite_user_by_id(&user_id).await {
+                Ok(_) => {
+                    status_handle
+                        .set_message(format!("Successfully invited {user_id} to the room"));
+                }
+                Err(e) => {
+                    status_handle
+                        .set_message(format!("Failed to invite {user_id} to the room: {e:?}"));
+                }
             }
-        }
+        })
+        .await;
+
+        self.input.clear();
     }
 
     async fn leave_room(&mut self) {
-        let Some(room) = self
-            .selected_room
-            .as_deref()
-            .and_then(|room_id| self.ui_rooms.lock().get(room_id).cloned())
-        else {
-            self.status_handle
-                .set_message(format!("Coulnd't find the room object to leave the room"));
-            return;
-        };
-
-        let _ = room.leave().await.inspect_err(|e| {
-            self.status_handle.set_message(format!("Couldn't leave the room {e:?}"))
-        });
+        self.call_with_room(async |room, status_handle| {
+            let _ = room.leave().await.inspect_err(|e| {
+                status_handle.set_message(format!("Couldn't leave the room {e:?}"))
+            });
+        })
+        .await;
 
         self.input.clear();
     }