From 69e296f34ea25894609227237ac913932695563b Mon Sep 17 00:00:00 2001
From: Lerking <33354709+Lerking@users.noreply.github.com>
Date: Wed, 6 Mar 2024 06:56:59 +0100
Subject: [PATCH] Add files via upload

---
 src/pyxtend/__init__.py         |  3 ++-
 src/pyxtend/pyxtend_core.py     | 31 ++++++++++++++++++++++++++++
 src/pyxtend/pyxtend_registry.py | 36 +++++++++++++++++++++++++++++++++
 3 files changed, 69 insertions(+), 1 deletion(-)

diff --git a/src/pyxtend/__init__.py b/src/pyxtend/__init__.py
index 2b71f40..954b411 100644
--- a/src/pyxtend/__init__.py
+++ b/src/pyxtend/__init__.py
@@ -1,2 +1,3 @@
 from .pyxtend_registry import PyXtendCore, IPyXtendRegistry
-from .pyxtend_core import PyXtendEngine
\ No newline at end of file
+from .pyxtend_core import PyXtendEngine
+from .pyxtend_models import Meta, Device, PluginConfig, DependencyModule, PyXtendRunTimeOption
\ No newline at end of file
diff --git a/src/pyxtend/pyxtend_core.py b/src/pyxtend/pyxtend_core.py
index e69de29..523cf24 100644
--- a/src/pyxtend/pyxtend_core.py
+++ b/src/pyxtend/pyxtend_core.py
@@ -0,0 +1,31 @@
+from logging import Logger
+
+from usecase import PluginUseCase
+from util import LogUtil
+
+
+class PyXtendEngine:
+    _logger: Logger
+
+    def __init__(self, **args) -> None:
+        self._logger = LogUtil.create(args['options']['log_level'])
+        self.use_case = PluginUseCase(args['options'])
+
+    def start(self) -> None:
+        self.__reload_plugins()
+        self.__invoke_on_plugins('Q')
+
+    def __reload_plugins(self) -> None:
+        """Reset the list of all plugins and initiate the walk over the main
+        provided plugin package to load all available plugins
+        """
+        self.use_case.discover_plugins(True)
+
+    def __invoke_on_plugins(self, command: chr):
+        """Apply all of the plugins on the argument supplied to this function
+        """
+        for module in self.use_case.modules:
+            plugin = self.use_case.register_plugin(module, self._logger)
+            delegate = self.use_case.hook_plugin(plugin)
+            device = delegate(command=command)
+            self._logger.info(f'Loaded device: {device}')
\ No newline at end of file
diff --git a/src/pyxtend/pyxtend_registry.py b/src/pyxtend/pyxtend_registry.py
index e69de29..30b6500 100644
--- a/src/pyxtend/pyxtend_registry.py
+++ b/src/pyxtend/pyxtend_registry.py
@@ -0,0 +1,36 @@
+from logging import Logger
+from typing import Optional, List
+
+from model import Meta, Device
+
+
+class IPyXtendRegistry(type):
+    plugin_registries: List[type] = list()
+
+    def __init__(cls, name, bases, attrs):
+        super().__init__(cls)
+        if name != 'PluginCore':
+            IPyXtendRegistry.plugin_registries.append(cls)
+
+
+class PyXtendCore(object, metaclass=IPyXtendRegistry):
+    """
+    Plugin core class
+    """
+
+    meta: Optional[Meta]
+
+    def __init__(self, logger: Logger) -> None:
+        """
+        Entry init block for plugins
+        :param logger: logger that plugins can make use of
+        """
+        self._logger = logger
+
+    def invoke(self, **args) -> Device:
+        """
+        Starts main plugin flow
+        :param args: possible arguments for the plugin
+        :return: a device for the plugin
+        """
+        pass
\ No newline at end of file