From 080cc42bb1da09059dbc35049a7ded0649961e0c Mon Sep 17 00:00:00 2001
From: HampusM <hampus@hampusmat.com>
Date: Mon, 29 Aug 2022 20:52:56 +0200
Subject: feat: implement async functionality

---
 src/provider/blocking.rs | 122 +++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 122 insertions(+)
 create mode 100644 src/provider/blocking.rs

(limited to 'src/provider/blocking.rs')

diff --git a/src/provider/blocking.rs b/src/provider/blocking.rs
new file mode 100644
index 0000000..13674b9
--- /dev/null
+++ b/src/provider/blocking.rs
@@ -0,0 +1,122 @@
+#![allow(clippy::module_name_repetitions)]
+use std::marker::PhantomData;
+
+use crate::errors::injectable::InjectableError;
+use crate::interfaces::injectable::Injectable;
+use crate::ptr::{SingletonPtr, TransientPtr};
+use crate::DIContainer;
+
+#[derive(strum_macros::Display, Debug)]
+pub enum Providable
+{
+    Transient(TransientPtr<dyn Injectable>),
+    Singleton(SingletonPtr<dyn Injectable>),
+    #[cfg(feature = "factory")]
+    Factory(crate::ptr::FactoryPtr<dyn crate::interfaces::any_factory::AnyFactory>),
+}
+
+pub trait IProvider
+{
+    fn provide(
+        &self,
+        di_container: &DIContainer,
+        dependency_history: Vec<&'static str>,
+    ) -> Result<Providable, InjectableError>;
+}
+
+pub struct TransientTypeProvider<InjectableType>
+where
+    InjectableType: Injectable,
+{
+    injectable_phantom: PhantomData<InjectableType>,
+}
+
+impl<InjectableType> TransientTypeProvider<InjectableType>
+where
+    InjectableType: Injectable,
+{
+    pub fn new() -> Self
+    {
+        Self {
+            injectable_phantom: PhantomData,
+        }
+    }
+}
+
+impl<InjectableType> IProvider for TransientTypeProvider<InjectableType>
+where
+    InjectableType: Injectable,
+{
+    fn provide(
+        &self,
+        di_container: &DIContainer,
+        dependency_history: Vec<&'static str>,
+    ) -> Result<Providable, InjectableError>
+    {
+        Ok(Providable::Transient(InjectableType::resolve(
+            di_container,
+            dependency_history,
+        )?))
+    }
+}
+
+pub struct SingletonProvider<InjectableType>
+where
+    InjectableType: Injectable,
+{
+    singleton: SingletonPtr<InjectableType>,
+}
+
+impl<InjectableType> SingletonProvider<InjectableType>
+where
+    InjectableType: Injectable,
+{
+    pub fn new(singleton: SingletonPtr<InjectableType>) -> Self
+    {
+        Self { singleton }
+    }
+}
+
+impl<InjectableType> IProvider for SingletonProvider<InjectableType>
+where
+    InjectableType: Injectable,
+{
+    fn provide(
+        &self,
+        _di_container: &DIContainer,
+        _dependency_history: Vec<&'static str>,
+    ) -> Result<Providable, InjectableError>
+    {
+        Ok(Providable::Singleton(self.singleton.clone()))
+    }
+}
+
+#[cfg(feature = "factory")]
+pub struct FactoryProvider
+{
+    factory: crate::ptr::FactoryPtr<dyn crate::interfaces::any_factory::AnyFactory>,
+}
+
+#[cfg(feature = "factory")]
+impl FactoryProvider
+{
+    pub fn new(
+        factory: crate::ptr::FactoryPtr<dyn crate::interfaces::any_factory::AnyFactory>,
+    ) -> Self
+    {
+        Self { factory }
+    }
+}
+
+#[cfg(feature = "factory")]
+impl IProvider for FactoryProvider
+{
+    fn provide(
+        &self,
+        _di_container: &DIContainer,
+        _dependency_history: Vec<&'static str>,
+    ) -> Result<Providable, InjectableError>
+    {
+        Ok(Providable::Factory(self.factory.clone()))
+    }
+}
-- 
cgit v1.2.3-18-g5258