From 5b0c6a52022e67a2d9cee251b3d08b9cb2b5f6cb Mon Sep 17 00:00:00 2001 From: HampusM Date: Sun, 9 Oct 2022 12:05:24 +0200 Subject: refactor!: reorganize DI containers BREAKING CHANGE: DIContainer, AsyncDIContainer & the binding structs have been relocated --- src/di_container.rs | 1267 --------------------------------------------------- 1 file changed, 1267 deletions(-) delete mode 100644 src/di_container.rs (limited to 'src/di_container.rs') diff --git a/src/di_container.rs b/src/di_container.rs deleted file mode 100644 index 2ed1e25..0000000 --- a/src/di_container.rs +++ /dev/null @@ -1,1267 +0,0 @@ -//! Dependency injection container. -//! -//! # Examples -//! ``` -//! use std::collections::HashMap; -//! use std::error::Error; -//! -//! use syrette::{injectable, DIContainer}; -//! -//! trait IDatabaseService -//! { -//! fn get_all_records(&self, table_name: String) -> HashMap; -//! } -//! -//! struct DatabaseService {} -//! -//! #[injectable(IDatabaseService)] -//! impl DatabaseService -//! { -//! fn new() -> Self -//! { -//! Self {} -//! } -//! } -//! -//! impl IDatabaseService for DatabaseService -//! { -//! fn get_all_records(&self, table_name: String) -> HashMap -//! { -//! // Do stuff here -//! HashMap::::new() -//! } -//! } -//! -//! fn main() -> Result<(), Box> -//! { -//! let mut di_container = DIContainer::new(); -//! -//! di_container -//! .bind::() -//! .to::() -//! .map_err(|err| err.to_string())?; -//! -//! let database_service = di_container -//! .get::() -//! .map_err(|err| err.to_string())? -//! .transient()?; -//! -//! Ok(()) -//! } -//! ``` -use std::any::type_name; -use std::cell::RefCell; -use std::marker::PhantomData; -use std::rc::Rc; - -#[cfg(feature = "factory")] -use crate::castable_factory::blocking::CastableFactory; -use crate::di_container_binding_map::DIContainerBindingMap; -use crate::errors::di_container::{ - BindingBuilderError, - BindingScopeConfiguratorError, - BindingWhenConfiguratorError, - DIContainerError, -}; -use crate::interfaces::injectable::Injectable; -use crate::libs::intertrait::cast::{CastBox, CastRc}; -use crate::provider::blocking::{ - IProvider, - Providable, - SingletonProvider, - TransientTypeProvider, -}; -use crate::ptr::{SingletonPtr, SomePtr}; - -/// When configurator for a binding for type 'Interface' inside a [`DIContainer`]. -pub struct BindingWhenConfigurator -where - Interface: 'static + ?Sized, -{ - di_container: Rc, - interface_phantom: PhantomData, -} - -impl BindingWhenConfigurator -where - Interface: 'static + ?Sized, -{ - fn new(di_container: Rc) -> Self - { - Self { - di_container, - interface_phantom: PhantomData, - } - } - - /// Configures the binding to have a name. - /// - /// # Errors - /// Will return Err if no binding for the interface already exists. - pub fn when_named( - &self, - name: &'static str, - ) -> Result<(), BindingWhenConfiguratorError> - { - let mut bindings_mut = self.di_container.bindings.borrow_mut(); - - let binding = bindings_mut.remove::(None).map_or_else( - || { - Err(BindingWhenConfiguratorError::BindingNotFound(type_name::< - Interface, - >( - ))) - }, - Ok, - )?; - - bindings_mut.set::(Some(name), binding); - - Ok(()) - } -} - -/// Scope configurator for a binding for type 'Interface' inside a [`DIContainer`]. -pub struct BindingScopeConfigurator -where - Interface: 'static + ?Sized, - Implementation: Injectable, -{ - di_container: Rc, - interface_phantom: PhantomData, - implementation_phantom: PhantomData, -} - -impl BindingScopeConfigurator -where - Interface: 'static + ?Sized, - Implementation: Injectable, -{ - fn new(di_container: Rc) -> Self - { - Self { - di_container, - interface_phantom: PhantomData, - implementation_phantom: PhantomData, - } - } - - /// Configures the binding to be in a transient scope. - /// - /// This is the default. - #[allow(clippy::must_use_candidate)] - pub fn in_transient_scope(&self) -> BindingWhenConfigurator - { - let mut bindings_mut = self.di_container.bindings.borrow_mut(); - - bindings_mut.set::( - None, - Box::new(TransientTypeProvider::::new()), - ); - - BindingWhenConfigurator::new(self.di_container.clone()) - } - - /// Configures the binding to be in a singleton scope. - /// - /// # Errors - /// Will return Err if resolving the implementation fails. - pub fn in_singleton_scope( - &self, - ) -> Result, BindingScopeConfiguratorError> - { - let singleton: SingletonPtr = SingletonPtr::from( - Implementation::resolve(&self.di_container, Vec::new()) - .map_err(BindingScopeConfiguratorError::SingletonResolveFailed)?, - ); - - let mut bindings_mut = self.di_container.bindings.borrow_mut(); - - bindings_mut.set::(None, Box::new(SingletonProvider::new(singleton))); - - Ok(BindingWhenConfigurator::new(self.di_container.clone())) - } -} - -/// Binding builder for type `Interface` inside a [`DIContainer`]. -pub struct BindingBuilder -where - Interface: 'static + ?Sized, -{ - di_container: Rc, - interface_phantom: PhantomData, -} - -impl BindingBuilder -where - Interface: 'static + ?Sized, -{ - fn new(di_container: Rc) -> Self - { - Self { - di_container, - interface_phantom: PhantomData, - } - } - - /// Creates a binding of type `Interface` to type `Implementation` inside of the - /// associated [`DIContainer`]. - /// - /// The scope of the binding is transient. But that can be changed by using the - /// returned [`BindingScopeConfigurator`] - /// - /// # Errors - /// Will return Err if the associated [`DIContainer`] already have a binding for - /// the interface. - /// - /// # Examples - /// ``` - /// # use std::error::Error; - /// # - /// # use syrette::{DIContainer, injectable}; - /// # - /// # trait Foo {} - /// # - /// # struct Bar {} - /// # - /// # #[injectable(Foo)] - /// # impl Bar { - /// # fn new() -> Self - /// # { - /// # Self {} - /// # } - /// # } - /// # - /// # impl Foo for Bar {} - /// # - /// # fn main() -> Result<(), Box> - /// # { - /// # let mut di_container = DIContainer::new(); - /// # - /// di_container.bind::().to::(); - /// # - /// # Ok(()) - /// # } - /// ``` - pub fn to( - &self, - ) -> Result, BindingBuilderError> - where - Implementation: Injectable, - { - { - let bindings = self.di_container.bindings.borrow(); - - if bindings.has::(None) { - return Err(BindingBuilderError::BindingAlreadyExists(type_name::< - Interface, - >( - ))); - } - } - - let binding_scope_configurator = - BindingScopeConfigurator::new(self.di_container.clone()); - - binding_scope_configurator.in_transient_scope(); - - Ok(binding_scope_configurator) - } - - /// Creates a binding of factory type `Interface` to a factory inside of the - /// associated [`DIContainer`]. - /// - /// # Errors - /// Will return Err if the associated [`DIContainer`] already have a binding for - /// the interface. - /// - /// # Examples - /// ``` - /// # use std::error::Error; - /// # - /// # use syrette::{DIContainer, factory}; - /// # use syrette::ptr::TransientPtr; - /// # - /// # trait ICustomerID {} - /// # trait ICustomer {} - /// # - /// # struct Customer - /// # { - /// # name: String, - /// # id: TransientPtr - /// # } - /// # - /// # impl Customer { - /// # fn new(name: String, id: TransientPtr) -> Self - /// # { - /// # Self { name, id } - /// # } - /// # } - /// # - /// # impl ICustomer for Customer {} - /// # - /// # #[factory] - /// # type ICustomerFactory = dyn Fn(String, u32) -> dyn ICustomer; - /// # - /// # #[factory] - /// # type ICustomerIDFactory = dyn Fn(u32) -> dyn ICustomerID; - /// # - /// # fn main() -> Result<(), Box> - /// # { - /// # let mut di_container = DIContainer::new(); - /// # - /// di_container - /// .bind::() - /// .to_factory(&|context| { - /// Box::new(move |name, id| { - /// let customer_id_factory = context - /// .get::() - /// .unwrap() - /// .factory() - /// .unwrap(); - /// - /// let customer_id = customer_id_factory(id); - /// - /// let customer = TransientPtr::new(Customer::new(name, customer_id)); - /// - /// customer as TransientPtr - /// }) - /// }); - /// # - /// # Ok(()) - /// # } - /// ``` - #[cfg(feature = "factory")] - #[cfg_attr(doc_cfg, doc(cfg(feature = "factory")))] - pub fn to_factory( - &self, - factory_func: &'static Func, - ) -> Result, BindingBuilderError> - where - Args: 'static, - Return: 'static + ?Sized, - Interface: Fn>, - Func: Fn<(std::rc::Rc,), Output = Box>, - { - { - let bindings = self.di_container.bindings.borrow(); - - if bindings.has::(None) { - return Err(BindingBuilderError::BindingAlreadyExists(type_name::< - Interface, - >( - ))); - } - } - - let mut bindings_mut = self.di_container.bindings.borrow_mut(); - - let factory_impl = CastableFactory::new(factory_func); - - bindings_mut.set::( - None, - Box::new(crate::provider::blocking::FactoryProvider::new( - crate::ptr::FactoryPtr::new(factory_impl), - false, - )), - ); - - Ok(BindingWhenConfigurator::new(self.di_container.clone())) - } - - /// Creates a binding of type `Interface` to a factory that takes no arguments - /// inside of the associated [`DIContainer`]. - /// - /// # Errors - /// Will return Err if the associated [`DIContainer`] already have a binding for - /// the interface. - /// - /// # Examples - /// ``` - /// # use std::error::Error; - /// # - /// # use syrette::{DIContainer, factory}; - /// # use syrette::ptr::TransientPtr; - /// # - /// # trait IBuffer {} - /// # - /// # struct Buffer - /// # { - /// # buf: [u8; SIZE] - /// # } - /// # - /// # impl Buffer - /// # { - /// # fn new() -> Self - /// # { - /// # Self { - /// # buf: [0; SIZE] - /// # } - /// # } - /// # } - /// # - /// # impl IBuffer for Buffer {} - /// # - /// # const BUFFER_SIZE: usize = 12; - /// # - /// # fn main() -> Result<(), Box> - /// # { - /// # let mut di_container = DIContainer::new(); - /// # - /// di_container.bind::().to_default_factory(&|_| { - /// Box::new(|| { - /// let buffer = TransientPtr::new(Buffer::::new()); - /// - /// buffer as TransientPtr - /// }) - /// }); - /// # - /// # Ok(()) - /// # } - /// ``` - #[cfg(feature = "factory")] - #[cfg_attr(doc_cfg, doc(cfg(feature = "factory")))] - pub fn to_default_factory( - &self, - factory_func: &'static FactoryFunc, - ) -> Result, BindingBuilderError> - where - Return: 'static + ?Sized, - FactoryFunc: Fn< - (Rc,), - Output = crate::ptr::TransientPtr< - dyn Fn<(), Output = crate::ptr::TransientPtr>, - >, - >, - { - { - let bindings = self.di_container.bindings.borrow(); - - if bindings.has::(None) { - return Err(BindingBuilderError::BindingAlreadyExists(type_name::< - Interface, - >( - ))); - } - } - - let mut bindings_mut = self.di_container.bindings.borrow_mut(); - - let factory_impl = CastableFactory::new(factory_func); - - bindings_mut.set::( - None, - Box::new(crate::provider::blocking::FactoryProvider::new( - crate::ptr::FactoryPtr::new(factory_impl), - true, - )), - ); - - Ok(BindingWhenConfigurator::new(self.di_container.clone())) - } -} - -/// Dependency injection container. -pub struct DIContainer -{ - bindings: RefCell>, -} - -impl DIContainer -{ - /// Returns a new `DIContainer`. - #[must_use] - pub fn new() -> Rc - { - Rc::new(Self { - bindings: RefCell::new(DIContainerBindingMap::new()), - }) - } - - /// Returns a new [`BindingBuilder`] for the given interface. - #[must_use] - pub fn bind(self: &mut Rc) -> BindingBuilder - where - Interface: 'static + ?Sized, - { - BindingBuilder::::new(self.clone()) - } - - /// Returns the type bound with `Interface`. - /// - /// # Errors - /// Will return `Err` if: - /// - No binding for `Interface` exists - /// - Resolving the binding for `Interface` fails - /// - Casting the binding for `Interface` fails - pub fn get(self: &Rc) -> Result, DIContainerError> - where - Interface: 'static + ?Sized, - { - self.get_bound::(Vec::new(), None) - } - - /// Returns the type bound with `Interface` and the specified name. - /// - /// # Errors - /// Will return `Err` if: - /// - No binding for `Interface` with name `name` exists - /// - Resolving the binding for `Interface` fails - /// - Casting the binding for `Interface` fails - pub fn get_named( - self: &Rc, - name: &'static str, - ) -> Result, DIContainerError> - where - Interface: 'static + ?Sized, - { - self.get_bound::(Vec::new(), Some(name)) - } - - #[doc(hidden)] - pub fn get_bound( - self: &Rc, - dependency_history: Vec<&'static str>, - name: Option<&'static str>, - ) -> Result, DIContainerError> - where - Interface: 'static + ?Sized, - { - let binding_providable = - self.get_binding_providable::(name, dependency_history)?; - - self.handle_binding_providable(binding_providable) - } - - fn handle_binding_providable( - self: &Rc, - binding_providable: Providable, - ) -> Result, DIContainerError> - where - Interface: 'static + ?Sized, - { - match binding_providable { - Providable::Transient(transient_binding) => Ok(SomePtr::Transient( - transient_binding.cast::().map_err(|_| { - DIContainerError::CastFailed { - interface: type_name::(), - binding_kind: "transient", - } - })?, - )), - Providable::Singleton(singleton_binding) => Ok(SomePtr::Singleton( - singleton_binding.cast::().map_err(|_| { - DIContainerError::CastFailed { - interface: type_name::(), - binding_kind: "singleton", - } - })?, - )), - #[cfg(feature = "factory")] - Providable::Factory(factory_binding) => { - use crate::interfaces::factory::IFactory; - - let factory = factory_binding - .cast::,), Interface>>() - .map_err(|_| DIContainerError::CastFailed { - interface: type_name::(), - binding_kind: "factory", - })?; - - Ok(SomePtr::Factory(factory(self.clone()).into())) - } - #[cfg(feature = "factory")] - Providable::DefaultFactory(factory_binding) => { - use crate::interfaces::factory::IFactory; - use crate::ptr::TransientPtr; - - let default_factory = factory_binding - .cast::,), - dyn Fn<(), Output = TransientPtr>, - >>() - .map_err(|_| DIContainerError::CastFailed { - interface: type_name::(), - binding_kind: "default factory", - })?; - - Ok(SomePtr::Transient(default_factory(self.clone())())) - } - } - } - - fn get_binding_providable( - self: &Rc, - name: Option<&'static str>, - dependency_history: Vec<&'static str>, - ) -> Result - where - Interface: 'static + ?Sized, - { - self.bindings - .borrow() - .get::(name) - .map_or_else( - || { - Err(DIContainerError::BindingNotFound { - interface: type_name::(), - name, - }) - }, - Ok, - )? - .provide(self, dependency_history) - .map_err(|err| DIContainerError::BindingResolveFailed { - reason: err, - interface: type_name::(), - }) - } -} - -#[cfg(test)] -mod tests -{ - use std::error::Error; - - use mockall::mock; - - use super::*; - use crate::errors::injectable::InjectableError; - use crate::provider::blocking::IProvider; - use crate::ptr::TransientPtr; - - mod subjects - { - //! Test subjects. - - use std::fmt::Debug; - use std::rc::Rc; - - use syrette_macros::declare_interface; - - use super::DIContainer; - use crate::interfaces::injectable::Injectable; - use crate::ptr::TransientPtr; - - pub trait IUserManager - { - fn add_user(&self, user_id: i128); - - fn remove_user(&self, user_id: i128); - } - - pub struct UserManager {} - - impl UserManager - { - pub fn new() -> Self - { - Self {} - } - } - - impl IUserManager for UserManager - { - fn add_user(&self, _user_id: i128) - { - // ... - } - - fn remove_user(&self, _user_id: i128) - { - // ... - } - } - - use crate as syrette; - - declare_interface!(UserManager -> IUserManager); - - impl Injectable for UserManager - { - fn resolve( - _di_container: &Rc, - _dependency_history: Vec<&'static str>, - ) -> Result, crate::errors::injectable::InjectableError> - where - Self: Sized, - { - Ok(TransientPtr::new(Self::new())) - } - } - - pub trait INumber - { - fn get(&self) -> i32; - - fn set(&mut self, number: i32); - } - - impl PartialEq for dyn INumber - { - fn eq(&self, other: &Self) -> bool - { - self.get() == other.get() - } - } - - impl Debug for dyn INumber - { - fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result - { - f.write_str(format!("{}", self.get()).as_str()) - } - } - - pub struct Number - { - pub num: i32, - } - - impl Number - { - pub fn new() -> Self - { - Self { num: 0 } - } - } - - impl INumber for Number - { - fn get(&self) -> i32 - { - self.num - } - - fn set(&mut self, number: i32) - { - self.num = number; - } - } - - declare_interface!(Number -> INumber); - - impl Injectable for Number - { - fn resolve( - _di_container: &Rc, - _dependency_history: Vec<&'static str>, - ) -> Result, crate::errors::injectable::InjectableError> - where - Self: Sized, - { - Ok(TransientPtr::new(Self::new())) - } - } - } - - #[test] - fn can_bind_to() -> Result<(), Box> - { - let mut di_container = DIContainer::new(); - - assert_eq!(di_container.bindings.borrow().count(), 0); - - di_container - .bind::() - .to::()?; - - assert_eq!(di_container.bindings.borrow().count(), 1); - - Ok(()) - } - - #[test] - fn can_bind_to_transient() -> Result<(), Box> - { - let mut di_container = DIContainer::new(); - - assert_eq!(di_container.bindings.borrow().count(), 0); - - di_container - .bind::() - .to::()? - .in_transient_scope(); - - assert_eq!(di_container.bindings.borrow().count(), 1); - - Ok(()) - } - - #[test] - fn can_bind_to_transient_when_named() -> Result<(), Box> - { - let mut di_container = DIContainer::new(); - - assert_eq!(di_container.bindings.borrow().count(), 0); - - di_container - .bind::() - .to::()? - .in_transient_scope() - .when_named("regular")?; - - assert_eq!(di_container.bindings.borrow().count(), 1); - - Ok(()) - } - - #[test] - fn can_bind_to_singleton() -> Result<(), Box> - { - let mut di_container = DIContainer::new(); - - assert_eq!(di_container.bindings.borrow().count(), 0); - - di_container - .bind::() - .to::()? - .in_singleton_scope()?; - - assert_eq!(di_container.bindings.borrow().count(), 1); - - Ok(()) - } - - #[test] - fn can_bind_to_singleton_when_named() -> Result<(), Box> - { - let mut di_container = DIContainer::new(); - - assert_eq!(di_container.bindings.borrow().count(), 0); - - di_container - .bind::() - .to::()? - .in_singleton_scope()? - .when_named("cool")?; - - assert_eq!(di_container.bindings.borrow().count(), 1); - - Ok(()) - } - - #[test] - #[cfg(feature = "factory")] - fn can_bind_to_factory() -> Result<(), Box> - { - use crate as syrette; - use crate::factory; - - #[factory] - type IUserManagerFactory = dyn Fn() -> dyn subjects::IUserManager; - - let mut di_container = DIContainer::new(); - - assert_eq!(di_container.bindings.borrow().count(), 0); - - di_container - .bind::() - .to_factory(&|_| { - Box::new(move || { - let user_manager: TransientPtr = - TransientPtr::new(subjects::UserManager::new()); - - user_manager - }) - })?; - - assert_eq!(di_container.bindings.borrow().count(), 1); - - Ok(()) - } - - #[test] - #[cfg(feature = "factory")] - fn can_bind_to_factory_when_named() -> Result<(), Box> - { - use crate as syrette; - use crate::factory; - - #[factory] - type IUserManagerFactory = dyn Fn() -> dyn subjects::IUserManager; - - let mut di_container = DIContainer::new(); - - assert_eq!(di_container.bindings.borrow().count(), 0); - - di_container - .bind::() - .to_factory(&|_| { - Box::new(move || { - let user_manager: TransientPtr = - TransientPtr::new(subjects::UserManager::new()); - - user_manager - }) - })? - .when_named("awesome")?; - - assert_eq!(di_container.bindings.borrow().count(), 1); - - Ok(()) - } - - #[test] - fn can_get() -> Result<(), Box> - { - mock! { - Provider {} - - impl IProvider for Provider - { - fn provide( - &self, - di_container: &Rc, - dependency_history: Vec<&'static str>, - ) -> Result; - } - } - - let di_container = DIContainer::new(); - - let mut mock_provider = MockProvider::new(); - - mock_provider.expect_provide().returning(|_, _| { - Ok(Providable::Transient(TransientPtr::new( - subjects::UserManager::new(), - ))) - }); - - di_container - .bindings - .borrow_mut() - .set::(None, Box::new(mock_provider)); - - di_container - .get::()? - .transient()?; - - Ok(()) - } - - #[test] - fn can_get_named() -> Result<(), Box> - { - mock! { - Provider {} - - impl IProvider for Provider - { - fn provide( - &self, - di_container: &Rc, - dependency_history: Vec<&'static str>, - ) -> Result; - } - } - - let di_container = DIContainer::new(); - - let mut mock_provider = MockProvider::new(); - - mock_provider.expect_provide().returning(|_, _| { - Ok(Providable::Transient(TransientPtr::new( - subjects::UserManager::new(), - ))) - }); - - di_container - .bindings - .borrow_mut() - .set::(Some("special"), Box::new(mock_provider)); - - di_container - .get_named::("special")? - .transient()?; - - Ok(()) - } - - #[test] - fn can_get_singleton() -> Result<(), Box> - { - mock! { - Provider {} - - impl IProvider for Provider - { - fn provide( - &self, - di_container: &Rc, - dependency_history: Vec<&'static str>, - ) -> Result; - } - } - - let di_container = DIContainer::new(); - - let mut mock_provider = MockProvider::new(); - - let mut singleton = SingletonPtr::new(subjects::Number::new()); - - SingletonPtr::get_mut(&mut singleton).unwrap().num = 2820; - - mock_provider - .expect_provide() - .returning_st(move |_, _| Ok(Providable::Singleton(singleton.clone()))); - - di_container - .bindings - .borrow_mut() - .set::(None, Box::new(mock_provider)); - - let first_number_rc = di_container.get::()?.singleton()?; - - assert_eq!(first_number_rc.get(), 2820); - - let second_number_rc = - di_container.get::()?.singleton()?; - - assert_eq!(first_number_rc.as_ref(), second_number_rc.as_ref()); - - Ok(()) - } - - #[test] - fn can_get_singleton_named() -> Result<(), Box> - { - mock! { - Provider {} - - impl IProvider for Provider - { - fn provide( - &self, - di_container: &Rc, - dependency_history: Vec<&'static str>, - ) -> Result; - } - } - - let di_container = DIContainer::new(); - - let mut mock_provider = MockProvider::new(); - - let mut singleton = SingletonPtr::new(subjects::Number::new()); - - SingletonPtr::get_mut(&mut singleton).unwrap().num = 2820; - - mock_provider - .expect_provide() - .returning_st(move |_, _| Ok(Providable::Singleton(singleton.clone()))); - - di_container - .bindings - .borrow_mut() - .set::(Some("cool"), Box::new(mock_provider)); - - let first_number_rc = di_container - .get_named::("cool")? - .singleton()?; - - assert_eq!(first_number_rc.get(), 2820); - - let second_number_rc = di_container - .get_named::("cool")? - .singleton()?; - - assert_eq!(first_number_rc.as_ref(), second_number_rc.as_ref()); - - Ok(()) - } - - #[test] - #[cfg(feature = "factory")] - fn can_get_factory() -> Result<(), Box> - { - use crate::ptr::FactoryPtr; - - trait IUserManager - { - fn add_user(&mut self, user_id: i128); - - fn remove_user(&mut self, user_id: i128); - } - - struct UserManager - { - users: Vec, - } - - impl UserManager - { - fn new(users: Vec) -> Self - { - Self { users } - } - } - - impl IUserManager for UserManager - { - fn add_user(&mut self, user_id: i128) - { - self.users.push(user_id); - } - - fn remove_user(&mut self, user_id: i128) - { - let user_index = - self.users.iter().position(|user| *user == user_id).unwrap(); - - self.users.remove(user_index); - } - } - - type FactoryFunc = dyn Fn< - (std::rc::Rc,), - Output = Box< - dyn Fn<(Vec,), Output = crate::ptr::TransientPtr>, - >, - >; - - use crate as syrette; - - #[crate::factory] - type IUserManagerFactory = dyn Fn(Vec) -> dyn IUserManager; - - mock! { - Provider {} - - impl IProvider for Provider - { - fn provide( - &self, - di_container: &Rc, - dependency_history: Vec<&'static str>, - ) -> Result; - } - } - - let di_container = DIContainer::new(); - - let factory_func: &'static FactoryFunc = &|_: Rc| { - Box::new(move |users| { - let user_manager: TransientPtr = - TransientPtr::new(UserManager::new(users)); - - user_manager - }) - }; - - let mut mock_provider = MockProvider::new(); - - mock_provider.expect_provide().returning_st(|_, _| { - Ok(Providable::Factory(FactoryPtr::new(CastableFactory::new( - factory_func, - )))) - }); - - di_container - .bindings - .borrow_mut() - .set::(None, Box::new(mock_provider)); - - di_container.get::()?.factory()?; - - Ok(()) - } - - #[test] - #[cfg(feature = "factory")] - fn can_get_factory_named() -> Result<(), Box> - { - use crate::ptr::FactoryPtr; - - trait IUserManager - { - fn add_user(&mut self, user_id: i128); - - fn remove_user(&mut self, user_id: i128); - } - - struct UserManager - { - users: Vec, - } - - impl UserManager - { - fn new(users: Vec) -> Self - { - Self { users } - } - } - - impl IUserManager for UserManager - { - fn add_user(&mut self, user_id: i128) - { - self.users.push(user_id); - } - - fn remove_user(&mut self, user_id: i128) - { - let user_index = - self.users.iter().position(|user| *user == user_id).unwrap(); - - self.users.remove(user_index); - } - } - - type FactoryFunc = dyn Fn< - (std::rc::Rc,), - Output = Box< - dyn Fn<(Vec,), Output = crate::ptr::TransientPtr>, - >, - >; - - use crate as syrette; - - #[crate::factory] - type IUserManagerFactory = dyn Fn(Vec) -> dyn IUserManager; - - mock! { - Provider {} - - impl IProvider for Provider - { - fn provide( - &self, - di_container: &Rc, - dependency_history: Vec<&'static str>, - ) -> Result; - } - } - - let di_container = DIContainer::new(); - - let factory_func: &'static FactoryFunc = &|_: Rc| { - Box::new(move |users| { - let user_manager: TransientPtr = - TransientPtr::new(UserManager::new(users)); - - user_manager - }) - }; - - let mut mock_provider = MockProvider::new(); - - mock_provider.expect_provide().returning_st(|_, _| { - Ok(Providable::Factory(FactoryPtr::new(CastableFactory::new( - factory_func, - )))) - }); - - di_container - .bindings - .borrow_mut() - .set::(Some("special"), Box::new(mock_provider)); - - di_container - .get_named::("special")? - .factory()?; - - Ok(()) - } -} -- cgit v1.2.3-18-g5258