add: group channels, group channel members list, group channel renaming

crates/core/src/database/channels.rs

@@ -34,6 +34,25 @@ impl DataManager {
 
     auto_method!(get_channel_by_id(usize as i64)@get_channel_from_row -> "SELECT * FROM channels WHERE id = $1" --name="channel" --returns=Channel --cache-key-tmpl="atto.channel:{}");
 
+    /// Get all member profiles from a channel members list.
+    pub async fn fill_members(
+        &self,
+        members: &Vec<usize>,
+        ignore_users: Vec<usize>,
+    ) -> Result<Vec<User>> {
+        let mut out = Vec::new();
+
+        for member in members {
+            if ignore_users.contains(&member) {
+                continue;
+            }
+
+            out.push(self.get_user_by_id(member.to_owned()).await?);
+        }
+
+        Ok(out)
+    }
+
     /// Get all channels by community.
     ///
     /// # Arguments
@@ -214,6 +233,55 @@ impl DataManager {
         Ok(())
     }
 
+    pub async fn add_channel_member(&self, id: usize, user: User, member: String) -> Result<()> {
+        let mut y = self.get_channel_by_id(id).await?;
+
+        if user.id != y.owner && member != user.username {
+            if !user.permissions.check(FinePermission::MANAGE_CHANNELS) {
+                return Err(Error::NotAllowed);
+            } else {
+                self.create_audit_log_entry(AuditLogEntry::new(
+                    user.id,
+                    format!("invoked `add_channel_member` with x value `{member}`"),
+                ))
+                .await?
+            }
+        }
+
+        // check permissions
+        let member = self.get_user_by_username(&member).await?;
+
+        if self
+            .get_userblock_by_initiator_receiver(member.id, user.id)
+            .await
+            .is_ok()
+        {
+            return Err(Error::NotAllowed);
+        }
+
+        // ...
+        y.members.push(member.id);
+
+        let conn = match self.connect().await {
+            Ok(c) => c,
+            Err(e) => return Err(Error::DatabaseConnection(e.to_string())),
+        };
+
+        let res = execute!(
+            &conn,
+            "UPDATE channels SET members = $1 WHERE id = $2",
+            params![&serde_json::to_string(&y.members).unwrap(), &(id as i64)]
+        );
+
+        if let Err(e) = res {
+            return Err(Error::DatabaseError(e.to_string()));
+        }
+
+        self.2.remove(format!("atto.channel:{}", id)).await;
+
+        Ok(())
+    }
+
     pub async fn remove_channel_member(&self, id: usize, user: User, member: usize) -> Result<()> {
         let mut y = self.get_channel_by_id(id).await?;
 
@@ -230,7 +298,10 @@ impl DataManager {
         }
 
         y.members
-            .remove(y.members.iter().position(|x| *x == member).unwrap());
+            .remove(match y.members.iter().position(|x| *x == member) {
+                Some(i) => i,
+                None => return Err(Error::GeneralNotFound("member".to_string())),
+            });
 
         let conn = match self.connect().await {
             Ok(c) => c,

crates/core/src/model/channels.rs

@@ -4,7 +4,7 @@ use tetratto_shared::{snow::Snowflake, unix_epoch_timestamp};
 use super::communities_permissions::CommunityPermission;
 
 /// A channel is a more "chat-like" feed in communities.
-#[derive(Serialize, Deserialize)]
+#[derive(Clone, Serialize, Deserialize)]
 pub struct Channel {
     pub id: usize,
     pub community: usize,