diff options
| author | marios8543 <marios8543@gmail.com> | 2023-10-18 21:04:51 +0300 |
|---|---|---|
| committer | marios8543 <marios8543@gmail.com> | 2023-10-31 23:18:31 +0200 |
| commit | 7565a66d9084c71f499be3f99d3e70e3368c1f00 (patch) | |
| tree | ced5c86ad8c79d22ebab1ceedc22f38eb73debbc /backend/src/loader.py | |
| parent | e4b1efc44dc2f8dc718c809ea50680de626474c4 (diff) | |
| download | decky-loader-7565a66d9084c71f499be3f99d3e70e3368c1f00.tar.gz decky-loader-7565a66d9084c71f499be3f99d3e70e3368c1f00.zip | |
fix emit_message mechanism
Diffstat (limited to 'backend/src/loader.py')
| -rw-r--r-- | backend/src/loader.py | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/backend/src/loader.py b/backend/src/loader.py index 162cf498..7567912c 100644 --- a/backend/src/loader.py +++ b/backend/src/loader.py @@ -22,6 +22,10 @@ from .plugin.plugin import PluginWrapper Plugins = dict[str, PluginWrapper] ReloadQueue = Queue[Tuple[str, str, bool | None] | Tuple[str, str]] +#TODO: Remove placeholder method +async def log_plugin_emitted_message(message: Any): + getLogger().debug(f"EMITTED MESSAGE: " + str(message)) + class FileChangeHandler(RegexMatchingEventHandler): def __init__(self, queue: ReloadQueue, plugin_path: str) -> None: super().__init__(regexes=[r'^.*?dist\/index\.js$', r'^.*?main\.py$']) # type: ignore @@ -143,6 +147,7 @@ class Loader: if plugin.passive: self.logger.info(f"Plugin {plugin.name} is passive") self.plugins[plugin.name] = plugin.start() + self.plugins[plugin.name].set_emitted_message_callback(log_plugin_emitted_message) self.logger.info(f"Loaded {plugin.name}") if not batch: self.loop.create_task(self.dispatch_plugin(plugin.name, plugin.version)) |