wewo

src/communities/community.rs

@@ -1,5 +1,6 @@
 use crate::communities::interactables::category::Category;
 use crate::communities::interactables::registry;
+use crate::communities::perms::permission::Permission;
 use crate::communities::{
     community_connection::CommunityConnection, interactables::interactable::Interactable,
 };
@@ -27,8 +28,8 @@ pub struct Community {
     name: String,
     owner_id: Uuid,
     members: Vec<Uuid>,
-    permissions: HashMap<Uuid, Vec<String>>,
-    roles: HashMap<String, Vec<String>>,
+    permissions: HashMap<Uuid, Vec<Permission>>,
+    roles: HashMap<String, Vec<Permission>>,
     private_key: Secret,
     public_key: PublicKey,
     pub interactables: Arc<RwLock<Vec<Arc<Box<dyn Interactable>>>>>,
@@ -148,6 +149,13 @@ impl Community {
             .await
             .retain(|i| !Arc::ptr_eq(i, &interactable));
     }
+    pub async fn broadcast_message(&self, message: &CommunicationValue) {
+        for (_, conns) in self.connections.read().await.clone().iter() {
+            for user in conns.iter() {
+                user.send_message(message).await;
+            }
+        }
+    }
     pub async fn run_function(
         self: &mut Arc<Self>,
         user_id: Uuid,
@@ -240,7 +248,7 @@ pub async fn load(name: &String) -> Option<Arc<Community>> {
     let user_data = file_util::load_file(&format!("communities/{}/", name), "users.json");
     let user_json: JsonValue = json::parse(&user_data).unwrap();
     let mut users = Vec::new();
-    let mut permissions: HashMap<Uuid, Vec<String>> = HashMap::new();
+    let mut permissions: HashMap<Uuid, Vec<Permission>> = HashMap::new();
 
     for user in user_json.entries() {
         let (str, json): (&str, &JsonValue) = user;
@@ -258,7 +266,7 @@ pub async fn load(name: &String) -> Option<Arc<Community>> {
     }
 
     let role_data = file_util::load_file(&format!("communities/{}/", name), "roles.json");
-    let roles: HashMap<String, Vec<String>> = HashMap::new();
+    let roles: HashMap<String, Vec<Permission>> = HashMap::new();
     if let Ok(_) = json::parse(&role_data) {
         // Fill roles
     } else {

src/communities/interactables/category.rs

@@ -6,8 +6,10 @@ use async_trait::async_trait;
 use json::JsonValue;
 use std::any::Any;
 use std::sync::Arc;
+use uuid::Uuid;
 
 pub struct Category {
+    id: Uuid,
     name: String,
     path: String,
     community: Arc<Community>,
@@ -16,6 +18,7 @@ pub struct Category {
 impl Category {
     pub fn new() -> Category {
         Category {
+            id: Uuid::new_v4(),
             name: String::new(),
             path: String::new(),
             community: Arc::new(Community::new()),
@@ -50,6 +53,9 @@ impl Category {
 
 #[async_trait]
 impl Interactable for Category {
+    fn get_id(&self) -> &Uuid {
+        &self.id
+    }
     fn as_any(&self) -> &dyn Any {
         self
     }
@@ -90,7 +96,7 @@ impl Interactable for Category {
         }
         v
     }
-    async fn run_function(&self, cv: CommunicationValue) -> CommunicationValue {
+    async fn run_function(&self, _cv: CommunicationValue) -> CommunicationValue {
         CommunicationValue::new(CommunicationType::error)
     }
     fn to_json(&self) -> JsonValue {
@@ -101,8 +107,16 @@ impl Interactable for Category {
         }
         v
     }
-    fn load(&mut self, community: Arc<Community>, path: String, name: String, _json: &JsonValue) {
+    fn load(
+        &mut self,
+        community: Arc<Community>,
+        id: Uuid,
+        path: String,
+        name: String,
+        _json: &JsonValue,
+    ) {
         self.community = community;
+        self.id = id;
         self.name = name;
         self.path = path;
     }

src/communities/interactables/interactable.rs

@@ -3,6 +3,7 @@ use async_trait::async_trait;
 use json::JsonValue;
 use std::any::Any;
 use std::sync::Arc;
+use uuid::Uuid;
 
 pub type InteractableFactory = fn() -> Box<dyn Interactable>;
 
@@ -20,6 +21,14 @@ pub trait Interactable: Send + Sync + Any {
     fn set_community(&mut self, community: Arc<Community>);
     async fn run_function(&self, cv: CommunicationValue) -> CommunicationValue;
     fn get_data(&self) -> JsonValue;
+    fn get_id(&self) -> &Uuid;
     fn to_json(&self) -> JsonValue;
-    fn load(&mut self, community: Arc<Community>, path: String, name: String, json: &JsonValue);
+    fn load(
+        &mut self,
+        community: Arc<Community>,
+        id: Uuid,
+        path: String,
+        name: String,
+        json: &JsonValue,
+    );
 }

src/communities/interactables/registry.rs

@@ -9,6 +9,7 @@ use once_cell::sync::Lazy;
 use std::collections::HashMap;
 use std::sync::Arc;
 use tokio::sync::Mutex;
+use uuid::Uuid;
 
 pub static INTERACTABLE_REGISTRY: Lazy<Arc<Mutex<HashMap<String, InteractableFactory>>>> =
     Lazy::new(|| Arc::new(Mutex::new(HashMap::new())));
@@ -45,6 +46,7 @@ pub async fn get_interactable(name: &str) -> Box<dyn Interactable> {
 pub async fn save(interactable: &Arc<Box<dyn Interactable>>) {
     let mut json_object: JsonValue = interactable.to_json().clone();
     json_object["codec"] = JsonValue::String(interactable.get_codec());
+    json_object["id"] = JsonValue::String(interactable.get_id().to_string());
     file_util::save_file(
         &format!(
             "communities/{}/interactables/{}",
@@ -66,7 +68,8 @@ pub async fn load(
     );
     let json_object: JsonValue = json::parse(&s).unwrap();
     let codec: String = json_object["codec"].as_str().unwrap().to_string();
+    let id: String = json_object["id"].as_str().unwrap().to_string();
     let mut interactable = get_interactable(&codec).await;
-    interactable.load(c, path, name, &json_object);
+    interactable.load(c, Uuid::parse_str(&id).unwrap(), path, name, &json_object);
     interactable
 }

src/communities/interactables/text_chat.rs

@@ -14,6 +14,7 @@ use std::sync::Arc;
 use std::{any::Any, collections::HashMap};
 use uuid::Uuid;
 pub struct TextChat {
+    id: Uuid,
     name: String,
     path: String,
     community: Arc<Community>,
@@ -21,6 +22,7 @@ pub struct TextChat {
 impl TextChat {
     pub fn new() -> TextChat {
         TextChat {
+            id: Uuid::new_v4(),
             name: String::new(),
             path: String::new(),
             community: Arc::new(Community::new()),
@@ -152,6 +154,9 @@ impl TextChat {
 }
 #[async_trait]
 impl Interactable for TextChat {
+    fn get_id(&self) -> &Uuid {
+        &self.id
+    }
     fn as_any(&self) -> &dyn Any {
         self
     }
@@ -242,8 +247,16 @@ impl Interactable for TextChat {
     fn to_json(&self) -> JsonValue {
         JsonValue::new_object()
     }
-    fn load(&mut self, community: Arc<Community>, path: String, name: String, _: &JsonValue) {
+    fn load(
+        &mut self,
+        community: Arc<Community>,
+        id: Uuid,
+        path: String,
+        name: String,
+        _json: &JsonValue,
+    ) {
         self.community = community;
+        self.id = id;
         self.name = name;
         self.path = path;
     }

src/communities/interactables/voice_chat.rs

@@ -37,6 +37,7 @@ pub struct CallUser {
 }
 
 pub struct VoiceChat {
+    id: Uuid,
     name: String,
     path: String,
     community: Arc<Community>,
@@ -45,6 +46,7 @@ pub struct VoiceChat {
 impl VoiceChat {
     pub fn new() -> VoiceChat {
         VoiceChat {
+            id: Uuid::new_v4(),
             name: String::new(),
             path: String::new(),
             community: Arc::new(Community::new()),
@@ -71,6 +73,9 @@ impl VoiceChat {
 }
 #[async_trait]
 impl Interactable for VoiceChat {
+    fn get_id(&self) -> &Uuid {
+        &self.id
+    }
     fn as_any(&self) -> &dyn Any {
         self
     }
@@ -102,25 +107,6 @@ impl Interactable for VoiceChat {
         String::new() + &self.path + "/" + &self.name
     }
     fn get_data(&self) -> JsonValue {
-        /*
-        * "data": {
-                      "active_users": {
-                        "user_id": {
-                          "state": "<call_status>",
-                          "streaming": boolean
-                        },
-                        "user_id": {
-                          "state": "<call_status>",
-                          "streaming": boolean
-                         },
-                         "user_id": {
-                          "state": "<call_status>",
-                          "streaming": boolean
-                         }
-                      }
-                    }
-                  },
-        */
         let mut data = JsonValue::new_object();
         let mut active_users = JsonValue::new_object();
         for user in self.users.read().unwrap().iter() {
@@ -188,8 +174,16 @@ impl Interactable for VoiceChat {
         let v = JsonValue::new_object();
         v
     }
-    fn load(&mut self, community: Arc<Community>, path: String, name: String, _json: &JsonValue) {
+    fn load(
+        &mut self,
+        community: Arc<Community>,
+        id: Uuid,
+        path: String,
+        name: String,
+        _json: &JsonValue,
+    ) {
         self.community = community;
+        self.id = id;
         self.name = name;
         self.path = path;
     }

src/communities/mod.rs

@@ -8,3 +8,6 @@ pub mod interactables {
 }
 pub mod community;
 pub mod community_connection;
+pub mod perms {
+    pub mod permission;
+}

src/communities/perms/permission.rs

@@ -0,0 +1,27 @@
+use json::JsonValue;
+use uuid::Uuid;
+
+pub struct Permission {
+    pub id: Uuid,
+    pub name: String,
+}
+impl Permission {
+    pub fn new(id: Uuid, name: String) -> Self {
+        Permission { id, name }
+    }
+    pub fn to_json(&self) -> JsonValue {
+        json::object! {
+            "id" => self.id.to_string(),
+            "name" => self.name.clone()
+        }
+    }
+    pub fn from_json(json: JsonValue) -> Self {
+        Permission {
+            id: Uuid::parse_str(json["id"].as_str().unwrap()).unwrap(),
+            name: json["name"].as_str().unwrap().to_string(),
+        }
+    }
+    pub fn to_string(&self) -> String {
+        self.to_json().as_str().unwrap().to_string()
+    }
+}