Initial commit

Author: mavrix93

.gitignore

@@ -0,0 +1,54 @@
+# Byte-compiled / optimized / DLL files
+__pycache__/
+*.py[cod]
+*$py.class
+
+# C extensions
+*.so
+
+# Distribution / packaging
+.Python
+build/
+develop-eggs/
+dist/
+downloads/
+eggs/
+.eggs/
+lib/
+lib64/
+parts/
+sdist/
+var/
+wheels/
+share/python-wheels/
+*.egg-info/
+.installed.cfg
+*.egg
+MANIFEST
+
+# PyInstaller
+#  Usually these files are written by a python script from a template
+#  before PyInstaller builds the exe, so as to inject date/other infos into it.
+*.manifest
+*.spec
+
+# Sphinx documentation
+docs/_build/
+
+# PyBuilder
+.pybuilder/
+target/
+
+
+# Environments
+.env
+.venv
+env/
+venv/
+ENV/
+
+
+# mypy
+.mypy_cache/
+.dmypy.json
+dmypy.json

.idea/.gitignore

@@ -0,0 +1,22 @@
+from typing import Optional, Type, Generic, TypeVar, NamedTuple, Any
+
+ComponentConfigT = TypeVar("ComponentConfigT", bound=Optional[tuple])
+ComponentT = TypeVar("ComponentT", bound="Component")
+ComponentsT = TypeVar("ComponentsT", bound=Optional[tuple])
+ComponentOrProtocolT = TypeVar("ComponentOrProtocolT", "Component", Any)
+
+
+class ComponentConfig(NamedTuple):
+    pass
+
+
+class Component(Generic[ComponentConfigT, ComponentsT]):
+    def __init__(self, components: ComponentsT = None, config: ComponentConfigT = None):
+        self.config = config
+        self.components: ComponentsT = components or tuple()
+
+    def __getitem__(self, item: Type[ComponentOrProtocolT]) -> ComponentOrProtocolT:
+        for component in self.components:
+            if isinstance(component, item):
+                return component
+        raise KeyError

.idea/componenter.iml

@@ -0,0 +1,66 @@
+from dev.version1 import Component, ComponentsContainer, ComponentsContainerType
+
+
+class Executor(Component[ComponentsContainerType]):
+    def run(self):
+        pass
+
+
+class MethodExecutor(Executor[ComponentsContainerType]):
+    def __init__(self, parent):
+        super().__init__(parent=parent)
+
+    def run(self, *args, **kwargs):
+        # TODO..
+        return self.parent[ExecutionMethod]
+
+
+class ValidationExecutor(Executor):
+    def run(self, *args, **kwargs):
+        if not self.parent[Validator].validate(*args, **kwargs):
+            raise ValueError("Failed to validate")
+
+
+class Validator(Component):
+    def __init__(self, parent):
+        super().__init__(parent=parent)
+        self.validate_method = self.parent.validate_method
+
+    def validate(self, *args, **kwargs) -> bool:
+        return self.validate_method(*args, **kwargs)
+
+
+###
+
+
+class ExecutionMethod(Component[ComponentsContainerType]):
+    @staticmethod
+    def run_method(x: int, y: int) -> int:
+        pass
+
+
+class SumMethod(ExecutionMethod[ComponentsContainerType]):
+    @staticmethod
+    def run_method(x: int, y: int) -> int:
+        return x + y
+
+
+class Action(ComponentsContainer, components=[MethodExecutor, SumMethod]):
+    action_meta = None
+
+
+class Condition(ComponentsContainer, components=[ValidationExecutor, Validator]):
+    @staticmethod
+    def validate_method(x: int):
+        return x > 0
+
+
+##
+
+if __name__ == "__main__":
+    action = Action()
+    ll = MethodExecutor(action).parent
+    print(action[MethodExecutor].run(10, 13))
+
+    condition = Condition()
+    print(condition[ValidationExecutor].run(-1))

.idea/inspectionProfiles/Project_Default.xml

@@ -0,0 +1,40 @@
+from typing import Any
+
+from componenter.component import Component, ComponentConfigT, ComponentsT
+from dev.examples.actions.configs import (
+    RunnerComponents,
+    RunnerConfig,
+    MethodExecutorConfig,
+    MethodValidationExecutorConfig,
+    ExecutionChainComponents,
+)
+from dev.examples.actions.types import IRunner, IExecutor, DataContainer, IExecutionChain
+
+
+class Executor(Component[ComponentConfigT, ComponentsT], IExecutor):
+    def execute(self, **kwargs) -> Any:
+        pass
+
+
+class MethodExecutor(Executor[MethodExecutorConfig, None], IExecutor):
+    def execute(self, **kwargs) -> Any:
+        return self.config.method(**kwargs)
+
+
+class ValidationExecutor(Executor[MethodValidationExecutorConfig, None], IExecutor):
+    def execute(self, **kwargs):
+        if not self.config.method(**kwargs):
+            raise ValueError("Validation failed for {} with {}".format(self.__class__, kwargs))
+
+
+class NoChangeRunner(Component[RunnerConfig, RunnerComponents], IRunner):
+    def run(self, data: DataContainer) -> DataContainer:
+        self.components.executor.execute(**data.dict())
+        return data
+
+
+class ExecutionChain(Component[None, ExecutionChainComponents], IExecutionChain):
+    def run_chain(self, data: DataContainer) -> DataContainer:
+        for runner in self.components.runners:
+            data = runner.run(data)
+        return data

.idea/inspectionProfiles/profiles_settings.xml

@@ -0,0 +1,23 @@
+from typing import NamedTuple, Callable, Any, List
+
+from dev.examples.actions.types import IExecutor, IRunner
+
+
+class MethodExecutorConfig(NamedTuple):
+    method: Callable[..., Any]
+
+
+class MethodValidationExecutorConfig(NamedTuple):
+    method: Callable[..., bool]
+
+
+class RunnerComponents(NamedTuple):
+    executor: IExecutor
+
+
+class RunnerConfig(NamedTuple):
+    name: str
+
+
+class ExecutionChainComponents(NamedTuple):
+    runners: List[IRunner]

.idea/misc.xml

@@ -0,0 +1,37 @@
+from dev.examples.actions.components import NoChangeRunner, MethodExecutor, ValidationExecutor, ExecutionChain
+from dev.examples.actions.configs import (
+    RunnerComponents,
+    MethodExecutorConfig,
+    MethodValidationExecutorConfig,
+    ExecutionChainComponents,
+)
+from dev.examples.actions.types import DataContainer, IExecutor
+
+if __name__ == "__main__":
+    runner = NoChangeRunner(
+        components=RunnerComponents(
+            executor=MethodExecutor(
+                config=MethodExecutorConfig(method=lambda name, age: print("Name", name, "age", age))
+            )
+        )
+    )
+
+    validator = NoChangeRunner(
+        components=RunnerComponents(
+            executor=ValidationExecutor(config=MethodValidationExecutorConfig(method=lambda name, age: age > 18))
+        )
+    )
+
+    class Person(DataContainer):
+        name: str
+        age: int
+
+    runner.run(Person(name="johan", age=39))
+
+    validator.run(Person(name="johan", age=19))
+
+    runner[IExecutor].execute(name="GG", age=1)
+
+    ExecutionChain(components=ExecutionChainComponents(runners=[runner, validator])).run_chain(
+        Person(name="johan", age=39)
+    )

.idea/modules.xml

@@ -0,0 +1,26 @@
+import abc
+from typing import Any
+
+from pydantic import BaseModel
+
+
+class DataContainer(BaseModel):
+    pass
+
+
+class IRunner(abc.ABC):
+    @abc.abstractmethod
+    def run(self, data: DataContainer) -> DataContainer:
+        ...
+
+
+class IExecutor(abc.ABC):
+    @abc.abstractmethod
+    def execute(self, **kwargs) -> Any:
+        ...
+
+
+class IExecutionChain(abc.ABC):
+    @abc.abstractmethod
+    def run_chain(self, data: DataContainer) -> DataContainer:
+        ...