use std::any::{Any, TypeId}; use std::{fmt, mem}; use fxhash::FxHashMap; /// A type map of request extensions. #[derive(Default)] pub struct Extensions { /// Use FxHasher with a std HashMap with for faster /// lookups on the small `TypeId` (u64 equivalent) keys. map: FxHashMap>, } impl Extensions { /// Create an empty `Extensions`. #[inline] pub fn new() -> Extensions { Extensions { map: FxHashMap::default(), } } /// Insert a type into this `Extensions`. /// /// If a extension of this type already existed, it will /// be returned. pub fn insert(&mut self, val: T) { self.map.insert(TypeId::of::(), Box::new(val)); } /// Check if container contains entry pub fn contains(&self) -> bool { self.map.contains_key(&TypeId::of::()) } /// Get a reference to a type previously inserted on this `Extensions`. pub fn get(&self) -> Option<&T> { self.map .get(&TypeId::of::()) .and_then(|boxed| boxed.downcast_ref()) } /// Get a mutable reference to a type previously inserted on this `Extensions`. pub fn get_mut(&mut self) -> Option<&mut T> { self.map .get_mut(&TypeId::of::()) .and_then(|boxed| boxed.downcast_mut()) } /// Remove a type from this `Extensions`. /// /// If a extension of this type existed, it will be returned. pub fn remove(&mut self) -> Option { self.map .remove(&TypeId::of::()) .and_then(|boxed| boxed.downcast().ok().map(|boxed| *boxed)) } /// Clear the `Extensions` of all inserted extensions. #[inline] pub fn clear(&mut self) { self.map.clear(); } /// Extends self with the items from another `Extensions`. pub fn extend(&mut self, other: Extensions) { self.map.extend(other.map); } /// Sets (or overrides) items from `other` into this map. pub(crate) fn drain_from(&mut self, other: &mut Self) { self.map.extend(mem::take(&mut other.map)); } } impl fmt::Debug for Extensions { fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { f.debug_struct("Extensions").finish() } } #[cfg(test)] mod tests { use super::*; #[test] fn test_remove() { let mut map = Extensions::new(); map.insert::(123); assert!(map.get::().is_some()); map.remove::(); assert!(map.get::().is_none()); } #[test] fn test_clear() { let mut map = Extensions::new(); map.insert::(8); map.insert::(16); map.insert::(32); assert!(map.contains::()); assert!(map.contains::()); assert!(map.contains::()); map.clear(); assert!(!map.contains::()); assert!(!map.contains::()); assert!(!map.contains::()); map.insert::(10); assert_eq!(*map.get::().unwrap(), 10); } #[test] fn test_integers() { let mut map = Extensions::new(); map.insert::(8); map.insert::(16); map.insert::(32); map.insert::(64); map.insert::(128); map.insert::(8); map.insert::(16); map.insert::(32); map.insert::(64); map.insert::(128); assert!(map.get::().is_some()); assert!(map.get::().is_some()); assert!(map.get::().is_some()); assert!(map.get::().is_some()); assert!(map.get::().is_some()); assert!(map.get::().is_some()); assert!(map.get::().is_some()); assert!(map.get::().is_some()); assert!(map.get::().is_some()); assert!(map.get::().is_some()); } #[test] fn test_composition() { struct Magi(pub T); struct Madoka { pub god: bool, } struct Homura { pub attempts: usize, } struct Mami { pub guns: usize, } let mut map = Extensions::new(); map.insert(Magi(Madoka { god: false })); map.insert(Magi(Homura { attempts: 0 })); map.insert(Magi(Mami { guns: 999 })); assert!(!map.get::>().unwrap().0.god); assert_eq!(0, map.get::>().unwrap().0.attempts); assert_eq!(999, map.get::>().unwrap().0.guns); } #[test] fn test_extensions() { #[derive(Debug, PartialEq)] struct MyType(i32); let mut extensions = Extensions::new(); extensions.insert(5i32); extensions.insert(MyType(10)); assert_eq!(extensions.get(), Some(&5i32)); assert_eq!(extensions.get_mut(), Some(&mut 5i32)); assert_eq!(extensions.remove::(), Some(5i32)); assert!(extensions.get::().is_none()); assert_eq!(extensions.get::(), None); assert_eq!(extensions.get(), Some(&MyType(10))); } #[test] fn test_extend() { #[derive(Debug, PartialEq)] struct MyType(i32); let mut extensions = Extensions::new(); extensions.insert(5i32); extensions.insert(MyType(10)); let mut other = Extensions::new(); other.insert(15i32); other.insert(20u8); extensions.extend(other); assert_eq!(extensions.get(), Some(&15i32)); assert_eq!(extensions.get_mut(), Some(&mut 15i32)); assert_eq!(extensions.remove::(), Some(15i32)); assert!(extensions.get::().is_none()); assert_eq!(extensions.get::(), None); assert_eq!(extensions.get(), Some(&MyType(10))); assert_eq!(extensions.get(), Some(&20u8)); assert_eq!(extensions.get_mut(), Some(&mut 20u8)); } #[test] fn test_drain_from() { let mut ext = Extensions::new(); ext.insert(2isize); let mut more_ext = Extensions::new(); more_ext.insert(5isize); more_ext.insert(5usize); assert_eq!(ext.get::(), Some(&2isize)); assert_eq!(ext.get::(), None); assert_eq!(more_ext.get::(), Some(&5isize)); assert_eq!(more_ext.get::(), Some(&5usize)); ext.drain_from(&mut more_ext); assert_eq!(ext.get::(), Some(&5isize)); assert_eq!(ext.get::(), Some(&5usize)); assert_eq!(more_ext.get::(), None); assert_eq!(more_ext.get::(), None); } }