1
  2
  3
  4
  5
  6
  7
  8
  9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 21
 22
 23
 24
 25
 26
 27
 28
 29
 30
 31
 32
 33
 34
 35
 36
 37
 38
 39
 40
 41
 42
 43
 44
 45
 46
 47
 48
 49
 50
 51
 52
 53
 54
 55
 56
 57
 58
 59
 60
 61
 62
 63
 64
 65
 66
 67
 68
 69
 70
 71
 72
 73
 74
 75
 76
 77
 78
 79
 80
 81
 82
 83
 84
 85
 86
 87
 88
 89
 90
 91
 92
 93
 94
 95
 96
 97
 98
 99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
//! Implementation of a `Container` based on a `HashMap`
//!
//! Author: [Boris](mailto:boris@humanenginuity.com)
//! Version: 1.2
//!
//! ## Release notes
//! - v1.2 : remove multi-thread support (imposed an unnecessary Sync+Send marker on parameters)
//! - v1.1 : replace static function by methods & added a constructor `get_scope()`
//! - v1.0 : creation

// =======================================================================
// LIBRARY IMPORTS
// =======================================================================
use std::any::{Any, TypeId};
use std::boxed::Box;
use std::collections::HashMap;

use he_di_internals::error::Error as DIError;
use anymap::AnyMap;

use result::Result as DIResult;
use component::ComponentIndex;
use container::RegisteredType;

// =======================================================================
// STRUCT DEFINITION
// =======================================================================
// <clic to unfold doc>
/// Struct containing all the components registered during the build phase, used to `resolve` Components.
///
/// A Container can't be used as a builder/factory of components from the same type,
/// [resolve()](struct.Container.html#method.resolve) will consume registration data.
/// Use [resolve_ref()](struct.Container.html#method.resolve_ref) or
/// [resolve_mut()](struct.Container.html#method.resolve_mut)
/// if you just want to borrow a (mutable) reference of a Component.
///
/// # Examples
///
/// ```rust
/// extern crate he_di;
/// #[macro_use] extern crate he_di_derive;
///
/// trait FooValue {
///     fn get_value(&self) -> usize;
///     fn set_value(&mut self, _: usize);
/// }
///
/// #[derive(Component)]
/// #[interface(FooValue)]
/// struct FooImpl {
///     value: usize,
/// }
///
/// impl FooValue for FooImpl {
///     fn get_value(&self) -> usize {
///         self.value
///     }
///
///     fn set_value(&mut self, val: usize) {
///         self.value = val;
///     }
/// }
///
/// fn main() {
///     let mut builder = he_di::ContainerBuilder::new();
///     builder
///         .register::<FooImpl>()
///         .as_type::<FooValue>()
///         .with_named_parameter("value", 17 as usize);
///
///     let mut container = builder.build().unwrap();
///
///     {
///         let foo : &FooValue = container.resolve_ref::<FooValue>().unwrap();
///         assert_eq!(foo.get_value(), 17);
///     }
///
///     {
///         let foo : &mut FooValue = container.resolve_mut::<FooValue>().unwrap();
///         assert_eq!(foo.get_value(), 17);
///         foo.set_value(99);
///     }
///
///     {
///         let foo : Box<FooValue> = container.resolve::<FooValue>().unwrap(); // consume registration data, `FooValue` won't be able to be resolved from this container any longer
///         assert_eq!(foo.get_value(), 99);
///     }
///
///     {
///         let foo = container.resolve_ref::<FooValue>();
///         assert!(foo.is_err());
///     }
///
///     {
///         let foo = container.resolve_mut::<FooValue>();
///         assert!(foo.is_err());
///     }
/// }
/// ```
/// See also [module documentation](index.html) for more details.
#[derive(Debug)]
pub struct Container {
    component_map: HashMap<ComponentIndex, RegisteredType>,
    resolved_component_map: AnyMap,
}

// =======================================================================
// STRUCT IMPLEMENTATION
// =======================================================================
impl Container {
    /// Create a new Container from a ContainerBuilder's init_map
    pub(crate) fn new(init_map: HashMap<ComponentIndex, RegisteredType>) -> Self {
        // Invert the key/values of the map since we will lookup (resolve) the services using the type and not the component
        let reversed_map: HashMap<ComponentIndex, RegisteredType> = init_map
            .into_iter()
            .filter_map(|(_, registered_type)| if registered_type.as_trait.is_some()
                {
                    Some((
                        ComponentIndex::Id(
                            registered_type.as_trait.clone().unwrap().0,
                        ),
                        registered_type,
                    ))
                } else {
                    None
                }
            ).collect();

        Container {
            component_map: reversed_map,
            resolved_component_map: AnyMap::new(),
        }
    }

    /// Create a new Component registered with the trait `T` and transfer the ownership
    /// of the Component to the callee.
    /// Further resolve calls on the same container for the same trait `T` will fail.
    ///
    /// # Errors
    /// Returns a [Error::ResolveError](enum.Error.html) if we can't resolve your Component 
    /// from the Container (most likely your Component wasn't properly registered)
    ///
    /// # Examples
    ///
    /// ```rust,ignore
    /// let foo = some_container.resolve::<Foo>();
    /// ```
    pub fn resolve<T: ?Sized + 'static>(&mut self) -> DIResult<Box<T>> {
        if self.resolved_component_map.contains::<Box<T>>() {
            self.resolved_component_map.remove::<Box<T>>().ok_or_else(
                || {
                    panic!(
                        "invalid state: unable to remove existing component {}",
                        unsafe { ::std::intrinsics::type_name::<T>() }
                    )
                },
            ) // ok to panic, this would be a bug
        } else {
            // Note: for now we have no other way than to remove the RegisterType from the map
            // meaning that we would be able to get only 1 instance of each type registered
            // until we find a way to Clone parameters
            // TODO work around this
            let mut registered_type = self.component_map
                .remove(&ComponentIndex::Id(TypeId::of::<T>()))
                .ok_or_else(|| {
                    DIError::ResolveError(format!(
                        "no component {} registered in this container",
                        unsafe { ::std::intrinsics::type_name::<T>() }
                    ))
                })?;
            let mut result_map = registered_type.builder.build(
                self,
                &mut registered_type.parameters,
            )?; // AnyMap

            #[allow(or_fun_call)]
            result_map.remove::<Box<T>>().ok_or(DIError::ResolveError(
                format!("Unable to create a new instance of {}", unsafe {
                    ::std::intrinsics::type_name::<T>()
                }),
            ))
        }
    }

    /// Get a reference of a Component registered with the trait `T`.
    /// This component can later be resolved with any other resolve method.
    ///
    /// # Errors
    /// Returns a [Error::ResolveError](enum.Error.html) if we can't resolve your Component 
    /// from the Container (most likely your Component wasn't properly registered)
    ///
    /// # Examples
    ///
    /// ```rust,ignore
    /// let foo = some_container.resolve_ref::<Foo>();
    /// ```
    pub fn resolve_ref<T: ?Sized + 'static>(&mut self) -> DIResult<&T> {
        if !self.resolved_component_map.contains::<Box<T>>() {
            let component = self.resolve::<T>()?;
            self.resolved_component_map.insert(component); // insert a Box<T>
        }

        // Note: the following works because Box<T> coerces into &T
        #[allow(or_fun_call)]
        let coerced_result: &T = self.resolved_component_map.get::<Box<T>>()
            .ok_or(
                DIError::ResolveError(format!(
                    "Unable to create a reference of component {}",
                    unsafe { ::std::intrinsics::type_name::<T>() }
                )),
            )?;
        Ok(coerced_result)
    }

    /// Get a mutable reference of a Component registered with the trait `T`.
    /// This component can later be resolved with any other resolve method.
    ///
    /// # Errors
    /// Returns a [Error::ResolveError](enum.Error.html) if we can't resolve your Component 
    /// from the Container (most likely your Component wasn't properly registered)
    ///
    /// # Examples
    ///
    /// ```rust,ignore
    /// let foo = some_container.resolve_mut::<Foo>();
    /// ```
    pub fn resolve_mut<T: ?Sized + 'static>(&mut self) -> DIResult<&mut T> {
        if !self.resolved_component_map.contains::<Box<T>>() {
            let component = self.resolve::<T>()?;
            self.resolved_component_map.insert(component);
        }

        #[allow(or_fun_call)]
        let coerced_result: &mut T = self.resolved_component_map.get_mut::<Box<T>>().ok_or(
            DIError::ResolveError(format!(
                "Unable to get a mutable reference of component {}",
                unsafe { ::std::intrinsics::type_name::<T>() }
            )),
        )?;
        Ok(coerced_result)
    }

    /// Add a new named parameter for an already registered Component `T`.
    /// If `T` wasn't previously registered, it does nothing.
    ///
    /// # Examples
    /// Classic use is in a chained calls like that:
    ///
    /// ```rust,ignore
    /// let foo = some_container
    ///     .with_named_parameter::<Foo, String>("param_1", "value 1".to_string())
    ///     // ...
    ///     .with_named_parameter::<Foo, String>("param_N", "value N".to_string())
    ///     .resolve::<Foo>();
    /// ```
    pub fn with_named_parameter<T: ?Sized + 'static, V: Any>(
        &mut self,
        name: &str,
        value: V,
    ) -> &mut Self {
        {
            let registered_type = self.component_map.get_mut(
                &ComponentIndex::Id(TypeId::of::<T>()),
            );
            if registered_type.is_none() {
                warn!("no component {} registered in this container", unsafe {
                    ::std::intrinsics::type_name::<T>()
                });
            } else {
                let _ = registered_type.unwrap().with_named_parameter(name, value);
            }
        } // release mutable borrow
        self
    }

    /// Add a new typed parameter for an already registered Component `T`.
    /// If `T` wasn't previously registered, it does nothing.
    ///
    /// # Examples
    /// Classic use is in a chained calls like that:
    ///
    /// ```rust,ignore
    /// let foo = some_container
    ///     .with_typed_parameter::<Foo, String>("value 1".to_string())
    ///     // ...
    ///     .with_typed_parameter::<Foo, String>("value N".to_string())
    ///     .resolve::<Foo>();
    /// ```
    pub fn with_typed_parameter<T: ?Sized + 'static, V: Any>(&mut self, value: V) -> &mut Self {
        {
            let registered_type = self.component_map.get_mut(
                &ComponentIndex::Id(TypeId::of::<T>()),
            );
            if registered_type.is_none() {
                warn!("no component {} registered in this container", unsafe {
                    ::std::intrinsics::type_name::<T>()
                });
            } else {
                let _ = registered_type.unwrap().with_typed_parameter(value);
            }
        } // release mutable borrow
        self
    }
}