use crate::revision::filter_rev::GridFilterRevision; use crate::revision::grid_group::GridGroupRevision; use crate::revision::{FieldRevision, FieldTypeRevision}; use indexmap::IndexMap; use nanoid::nanoid; use serde::{Deserialize, Serialize}; use serde_repr::*; use std::collections::HashMap; use std::fmt::Debug; use std::sync::Arc; pub fn gen_grid_filter_id() -> String { nanoid!(6) } pub fn gen_grid_group_id() -> String { nanoid!(6) } pub fn gen_grid_sort_id() -> String { nanoid!(6) } pub type GridFilters = SettingContainer; pub type GridFilterRevisionMap = GridObjectRevisionMap; pub type FiltersByFieldId = HashMap>>; // pub type GridGroups = SettingContainer; pub type GridGroupRevisionMap = GridObjectRevisionMap; pub type GroupsByFieldId = HashMap>>; // pub type GridSorts = SettingContainer; pub type GridSortRevisionMap = GridObjectRevisionMap; pub type SortsByFieldId = HashMap>>; #[derive(Debug, Clone, Serialize, Deserialize, Default, Eq, PartialEq)] pub struct GridSettingRevision { pub layout: GridLayoutRevision, pub filters: GridFilters, pub groups: GridGroups, #[serde(skip)] pub sorts: GridSorts, } #[derive(Debug, PartialEq, Eq, Hash, Clone, Serialize_repr, Deserialize_repr)] #[repr(u8)] pub enum GridLayoutRevision { Table = 0, Board = 1, } impl ToString for GridLayoutRevision { fn to_string(&self) -> String { let layout_rev = self.clone() as u8; layout_rev.to_string() } } impl std::default::Default for GridLayoutRevision { fn default() -> Self { GridLayoutRevision::Table } } impl GridSettingRevision { pub fn get_all_groups(&self, field_revs: &[Arc]) -> Option { self.groups.get_all_objects(&self.layout, field_revs) } pub fn get_groups( &self, layout: &GridLayoutRevision, field_id: &str, field_type_rev: &FieldTypeRevision, ) -> Option>> { self.groups.get_objects(layout, field_id, field_type_rev) } pub fn get_mut_groups( &mut self, layout: &GridLayoutRevision, field_id: &str, field_type: &FieldTypeRevision, ) -> Option<&mut Vec>> { self.groups.get_mut_objects(layout, field_id, field_type) } pub fn insert_group( &mut self, layout: &GridLayoutRevision, field_id: &str, field_type: &FieldTypeRevision, group_rev: GridGroupRevision, ) { self.groups.insert_object(layout, field_id, field_type, group_rev); } pub fn get_all_filters(&self, field_revs: &[Arc]) -> Option { self.filters.get_all_objects(&self.layout, field_revs) } pub fn get_filters( &self, layout: &GridLayoutRevision, field_id: &str, field_type_rev: &FieldTypeRevision, ) -> Option>> { self.filters.get_objects(layout, field_id, field_type_rev) } pub fn get_mut_filters( &mut self, layout: &GridLayoutRevision, field_id: &str, field_type: &FieldTypeRevision, ) -> Option<&mut Vec>> { self.filters.get_mut_objects(layout, field_id, field_type) } pub fn insert_filter( &mut self, layout: &GridLayoutRevision, field_id: &str, field_type: &FieldTypeRevision, filter_rev: GridFilterRevision, ) { self.filters.insert_object(layout, field_id, field_type, filter_rev); } pub fn get_all_sort(&self) -> Option { None } } #[derive(Debug, Clone, Serialize, Deserialize, Default, PartialEq, Eq)] pub struct GridSortRevision { pub id: String, pub field_id: Option, } #[derive(Debug, Clone, Serialize, Deserialize, Default, Eq, PartialEq)] #[serde(transparent)] pub struct SettingContainer where T: Debug + Clone + Default + Eq + PartialEq + serde::Serialize + serde::de::DeserializeOwned + 'static, { /// Each layout contains multiple key/value. /// Key: field_id /// Value: this value contains key/value. /// Key: FieldType, /// Value: the corresponding objects. #[serde(with = "indexmap::serde_seq")] inner: IndexMap>>, } impl SettingContainer where T: Debug + Clone + Default + Eq + PartialEq + serde::Serialize + serde::de::DeserializeOwned + 'static, { pub fn get_mut_objects( &mut self, layout: &GridLayoutRevision, field_id: &str, field_type: &FieldTypeRevision, ) -> Option<&mut Vec>> { let value = self .inner .get_mut(layout) .and_then(|object_rev_map_by_field_id| object_rev_map_by_field_id.get_mut(field_id)) .and_then(|object_rev_map| object_rev_map.get_mut(field_type)); if value.is_none() { tracing::warn!("Can't find the {:?} with", std::any::type_name::()); } value } pub fn get_objects( &self, layout: &GridLayoutRevision, field_id: &str, field_type_rev: &FieldTypeRevision, ) -> Option>> { self.inner .get(layout) .and_then(|object_rev_map_by_field_id| object_rev_map_by_field_id.get(field_id)) .and_then(|object_rev_map| object_rev_map.get(field_type_rev)) .cloned() } pub fn get_all_objects( &self, layout: &GridLayoutRevision, field_revs: &[Arc], ) -> Option>>> { // Acquire the read lock. let object_rev_map_by_field_id = self.inner.get(layout)?; // Get the objects according to the FieldType, so we need iterate the field_revs. let objects_by_field_id = field_revs .iter() .flat_map(|field_rev| { let field_type = &field_rev.field_type_rev; let field_id = &field_rev.id; let object_rev_map = object_rev_map_by_field_id.get(field_id)?; let objects: Vec> = object_rev_map.get(field_type)?.clone(); Some((field_rev.id.clone(), objects)) }) .collect::>>>(); Some(objects_by_field_id) } pub fn insert_object( &mut self, layout: &GridLayoutRevision, field_id: &str, field_type: &FieldTypeRevision, object: T, ) { let object_rev_map_by_field_id = self.inner.entry(layout.clone()).or_insert_with(IndexMap::new); let object_rev_map = object_rev_map_by_field_id .entry(field_id.to_string()) .or_insert_with(GridObjectRevisionMap::::new); object_rev_map .entry(field_type.to_owned()) .or_insert_with(Vec::new) .push(Arc::new(object)) } } #[derive(Debug, Clone, Serialize, Deserialize, Default, Eq, PartialEq)] #[serde(transparent)] pub struct GridObjectRevisionMap where T: Debug + Clone + Default + Eq + PartialEq + serde::Serialize + serde::de::DeserializeOwned + 'static, { #[serde(with = "indexmap::serde_seq")] pub object_by_field_type: IndexMap>>, } impl GridObjectRevisionMap where T: Debug + Clone + Default + Eq + PartialEq + serde::Serialize + serde::de::DeserializeOwned + 'static, { pub fn new() -> Self { GridObjectRevisionMap::default() } } impl std::ops::Deref for GridObjectRevisionMap where T: Debug + Clone + Default + Eq + PartialEq + serde::Serialize + serde::de::DeserializeOwned + 'static, { type Target = IndexMap>>; fn deref(&self) -> &Self::Target { &self.object_by_field_type } } impl std::ops::DerefMut for GridObjectRevisionMap where T: Debug + Clone + Default + Eq + PartialEq + serde::Serialize + serde::de::DeserializeOwned + 'static, { fn deref_mut(&mut self) -> &mut Self::Target { &mut self.object_by_field_type } }