Compare commits
59 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 34c7927601 | |||
| ebf31756b5 | |||
| 406c1b77ed | |||
| 1be429c5cd | |||
| a093b3f56c | |||
| 1dc0c81d84 | |||
| 3e38cabf81 | |||
| 63f649af25 | |||
| b6efe1b1df | |||
| c5ee073d65 | |||
| 3bcf01dc26 | |||
| dd5904c273 | |||
| b763308aa9 | |||
| 34ba757bc6 | |||
| b5d2e1b0be | |||
| d3031952bf | |||
| 3312f2da28 | |||
| a21122671d | |||
| 9effa4be3e | |||
| 217038b863 | |||
| 8c19c4a97b | |||
| c7662a5d47 | |||
| 68d3aa3ed2 | |||
| 2ea29fe5ea | |||
| 1195d399b6 | |||
| b709e4d942 | |||
| 96bb0f0f3d | |||
| 993617976f | |||
| 828213912e | |||
| 44136c33b8 | |||
| 490423e94a | |||
| fa2c25d6c5 | |||
| 0db2e1dfca | |||
| 7200cb0bf8 | |||
| da3d09d3b1 | |||
| 00173e73ae | |||
| c849d32f73 | |||
| ffc7baa394 | |||
| ea1ba5d5ab | |||
| b01a9cca3e | |||
| 485d7a28d8 | |||
| f711cdcf06 | |||
| 2199d18c79 | |||
| d22861622b | |||
| 13858e433f | |||
| 37cad62835 | |||
| b4ad8fee0c | |||
| 4e51fd06f0 | |||
| dd780864a6 | |||
| 83db451e1b | |||
| b58be97d1f | |||
| eb03302323 | |||
| dec115c596 | |||
| 591cc49933 | |||
| 36807b7aa6 | |||
| afc38c32b3 | |||
| 798165c501 | |||
| fc247d4888 | |||
| 394f72d383 |
@@ -0,0 +1,13 @@
|
|||||||
|
dist:
|
||||||
|
python -m build
|
||||||
|
|
||||||
|
test:
|
||||||
|
twine upload --repository testpypi dist/*
|
||||||
|
|
||||||
|
publish:
|
||||||
|
twine upload --repository pypi dist/*
|
||||||
|
|
||||||
|
all:
|
||||||
|
$(dist)
|
||||||
|
$(test)
|
||||||
|
$(publish)
|
||||||
@@ -1,3 +1,30 @@
|
|||||||
# XtendR
|
# XtendR
|
||||||
|
|
||||||
A python 3 extension system to ease the use of plugins.
|
A very basic Python 3.12 plugin system based on the K.I.S.S principle.
|
||||||
|
|
||||||
|
I was in need of a new plugin system, which should meet these requirements:
|
||||||
|
:heavy_plus_sign: Simple to use
|
||||||
|
:heavy_plus_sign: Work well with Python 3.12
|
||||||
|
:heavy_plus_sign: Maintainable - Don't expect to see new releases every month. __If it ain't broken, don't fix it!!!__
|
||||||
|
|
||||||
|
I previously used yapsy, but it doesn't meet the requirements anymore.
|
||||||
|
:x: No longer simple, and simple to use (Simplicity in use has been sacrificed for more complexity. It has become bloated)
|
||||||
|
:x: Not workink with Python 3.12
|
||||||
|
:x: No longer maintained (Hasn't been maintained for a few years)
|
||||||
|
|
||||||
|
I didn't find anything that suited my needs, so I decided to make my own plugin system.
|
||||||
|
It simply contains 2 classes, one for the plugin system and one abstraction base class for the plugins themselves.
|
||||||
|
|
||||||
|
At the moment only 4 functions are available:
|
||||||
|
- Attach
|
||||||
|
- Run
|
||||||
|
- Stop
|
||||||
|
- Detach
|
||||||
|
|
||||||
|
Attach and Detach are used for registrering/unregistrering a module on the system.
|
||||||
|
The Run and Stop functions are mandatory in the plugin modules.
|
||||||
|
|
||||||
|
The system expects a folder called 'plugins', placed at the root, along side your main python file.
|
||||||
|
Each plugin should be placed in subfolders, named as the plugin, inside the 'plugins' folder.
|
||||||
|
|
||||||
|
The example.py along with the plugins/example_plugin/example_plugin.py and plugins/example_plugin/example_plugin.json shows the workings of this plugin system.
|
||||||
+13
-2
@@ -1,5 +1,9 @@
|
|||||||
|
import time
|
||||||
from xtendr.xtendrsystem import XtendRSystem
|
from xtendr.xtendrsystem import XtendRSystem
|
||||||
|
|
||||||
|
def my_callback():
|
||||||
|
print("'example_plugin is finished pre-loading")
|
||||||
|
|
||||||
if __name__ == "__main__":
|
if __name__ == "__main__":
|
||||||
"""Example usage of the PluginSystem.
|
"""Example usage of the PluginSystem.
|
||||||
|
|
||||||
@@ -15,7 +19,14 @@ if __name__ == "__main__":
|
|||||||
Detached plugin 'example_plugin'.
|
Detached plugin 'example_plugin'.
|
||||||
"""
|
"""
|
||||||
system = XtendRSystem()
|
system = XtendRSystem()
|
||||||
system.attach("example_plugin") # Assuming 'example_plugin/plugin_info.json' exists
|
system.attach("example_plugin", my_callback) # Assuming 'example_plugin/plugin_info.json' exists
|
||||||
system.run("example_plugin")
|
for i in range(3):
|
||||||
|
print(f"Main program is running iteration {i+1}...")
|
||||||
|
time.sleep(2)
|
||||||
|
system.run("example_plugin", test="Hello!")
|
||||||
|
system.stop("example_plugin")
|
||||||
|
system.run("example_plugin", 25)
|
||||||
|
system.stop("example_plugin")
|
||||||
|
system.run("example_plugin", "Hello!", 25)
|
||||||
system.stop("example_plugin")
|
system.stop("example_plugin")
|
||||||
system.detach("example_plugin")
|
system.detach("example_plugin")
|
||||||
@@ -1,3 +1,5 @@
|
|||||||
|
import threading
|
||||||
|
import time
|
||||||
from xtendr.xtendrbase import XtendRBase
|
from xtendr.xtendrbase import XtendRBase
|
||||||
|
|
||||||
class ExamplePlugin(XtendRBase):
|
class ExamplePlugin(XtendRBase):
|
||||||
@@ -5,13 +7,33 @@ class ExamplePlugin(XtendRBase):
|
|||||||
|
|
||||||
Example:
|
Example:
|
||||||
>>> plugin = ExamplePlugin()
|
>>> plugin = ExamplePlugin()
|
||||||
>>> plugin.run()
|
>>> plugin.run("Hello!", 25)
|
||||||
|
Passed arguments 2:
|
||||||
|
Argument 0: Hello!
|
||||||
|
Argument 1: 25
|
||||||
ExamplePlugin is running!
|
ExamplePlugin is running!
|
||||||
>>> plugin.stop()
|
>>> plugin.stop()
|
||||||
ExamplePlugin has stopped!
|
ExamplePlugin has stopped!
|
||||||
"""
|
"""
|
||||||
def run(self):
|
def run(self, *args, **kwargs):
|
||||||
|
arglen = len(args)
|
||||||
|
keylen = len(kwargs)
|
||||||
|
if arglen > 0:
|
||||||
|
print(f"Passed arguments {arglen}:")
|
||||||
|
for idx, a in enumerate(args):
|
||||||
|
print(f"Argument {idx}: {a}")
|
||||||
|
if keylen > 0:
|
||||||
|
print(f"Keyword arguments passed {keylen}")
|
||||||
|
if not "test" in kwargs:
|
||||||
|
raise ValueError("Didn't get expected 'test' keyword!")
|
||||||
|
for kw in kwargs:
|
||||||
|
print(f"Argument {kw}: {kwargs[kw]}")
|
||||||
|
|
||||||
print("ExamplePlugin is running!")
|
print("ExamplePlugin is running!")
|
||||||
|
|
||||||
def stop(self):
|
def stop(self):
|
||||||
print("ExamplePlugin has stopped!")
|
print("ExamplePlugin has stopped!")
|
||||||
|
|
||||||
|
def pre_load(self, callback):
|
||||||
|
time.sleep(5) # Indicate long running pre-load.
|
||||||
|
callback()
|
||||||
|
|||||||
@@ -3,17 +3,17 @@ if __name__ == "__main__":
|
|||||||
|
|
||||||
setup(
|
setup(
|
||||||
name="XtendR",
|
name="XtendR",
|
||||||
version="0.0.3",
|
version="0.3.2",
|
||||||
packages=find_packages(),
|
packages=find_packages(),
|
||||||
install_requires=[],
|
install_requires=[],
|
||||||
author="Jan Lerking",
|
author="Jan Lerking",
|
||||||
author_email="",
|
author_email="",
|
||||||
description="A modular plugin system for Python.",
|
description="A modular plugin system for Python.",
|
||||||
url="",
|
url="https://www.gitea.com/Lerking/XtendR",
|
||||||
classifiers=[
|
classifiers=[
|
||||||
"Programming Language :: Python :: 3.12",
|
"Programming Language :: Python :: 3.11",
|
||||||
"License :: OSI Approved :: MIT License",
|
"License :: OSI Approved :: MIT License",
|
||||||
"Operating System :: OS Independent",
|
"Operating System :: OS Independent",
|
||||||
],
|
],
|
||||||
python_requires='>=3.12',
|
python_requires='>=3.11',
|
||||||
)
|
)
|
||||||
@@ -1,7 +1,3 @@
|
|||||||
import importlib
|
|
||||||
import sys
|
|
||||||
import os
|
|
||||||
import json
|
|
||||||
from abc import ABC, abstractmethod
|
from abc import ABC, abstractmethod
|
||||||
|
|
||||||
class XtendRBase(ABC):
|
class XtendRBase(ABC):
|
||||||
@@ -21,9 +17,14 @@ class XtendRBase(ABC):
|
|||||||
Stopping TestPlugin
|
Stopping TestPlugin
|
||||||
"""
|
"""
|
||||||
@abstractmethod
|
@abstractmethod
|
||||||
def run(self):
|
def run(self, *args, **kwargs):
|
||||||
pass
|
pass
|
||||||
|
|
||||||
@abstractmethod
|
@abstractmethod
|
||||||
def stop(self):
|
def stop(self):
|
||||||
pass
|
pass
|
||||||
|
|
||||||
|
@abstractmethod
|
||||||
|
def pre_load(self, *args):
|
||||||
|
pass
|
||||||
|
|
||||||
+18
-6
@@ -2,15 +2,19 @@ import importlib
|
|||||||
import sys
|
import sys
|
||||||
import os
|
import os
|
||||||
import json
|
import json
|
||||||
from abc import ABC, abstractmethod
|
import threading
|
||||||
from xtendr.xtendrbase import XtendRBase
|
from xtendr.xtendrbase import XtendRBase
|
||||||
|
|
||||||
|
__version__ = "0.3.2"
|
||||||
|
|
||||||
class XtendRSystem:
|
class XtendRSystem:
|
||||||
"""Plugin system to manage plugins.
|
"""Plugin system to manage plugins.
|
||||||
|
|
||||||
Example:
|
Example:
|
||||||
>>> system = XtendRSystem()
|
>>> system = XtendRSystem()
|
||||||
>>> system.attach("example_plugin") # Assuming 'example_plugin/plugin_info.json' exists
|
>>> system.version()
|
||||||
|
XtendR v0.1.3
|
||||||
|
>>> system.attach("example_plugin") # Assuming 'example_plugin/example_plugin.json' exists
|
||||||
>>> system.run("example_plugin")
|
>>> system.run("example_plugin")
|
||||||
ExamplePlugin is running!
|
ExamplePlugin is running!
|
||||||
>>> system.stop("example_plugin")
|
>>> system.stop("example_plugin")
|
||||||
@@ -18,16 +22,20 @@ class XtendRSystem:
|
|||||||
>>> system.detach("example_plugin")
|
>>> system.detach("example_plugin")
|
||||||
Detached plugin 'example_plugin'.
|
Detached plugin 'example_plugin'.
|
||||||
"""
|
"""
|
||||||
def __init__(self):
|
def __init__(self, pluginpath = "plugins"):
|
||||||
|
self.pluginspath = pluginpath
|
||||||
self.plugins = {}
|
self.plugins = {}
|
||||||
|
|
||||||
def attach(self, name: str) -> None:
|
def version(self) -> str:
|
||||||
|
return "XtendR v" + __version__
|
||||||
|
|
||||||
|
def attach(self, name: str, callback) -> None:
|
||||||
"""Dynamically load a plugin from its folder."""
|
"""Dynamically load a plugin from its folder."""
|
||||||
if name in self.plugins:
|
if name in self.plugins:
|
||||||
print(f"Plugin '{name}' is already attached.")
|
print(f"Plugin '{name}' is already attached.")
|
||||||
return
|
return
|
||||||
|
|
||||||
plugin_path = os.path.join(os.getcwd(), "plugins", name)
|
plugin_path = os.path.join(os.getcwd(), self.pluginspath, name)
|
||||||
info_path = os.path.join(plugin_path, name + ".json")
|
info_path = os.path.join(plugin_path, name + ".json")
|
||||||
print(plugin_path + "\n" + info_path)
|
print(plugin_path + "\n" + info_path)
|
||||||
|
|
||||||
@@ -56,9 +64,13 @@ class XtendRSystem:
|
|||||||
self.plugins[name] = {
|
self.plugins[name] = {
|
||||||
'instance': instance,
|
'instance': instance,
|
||||||
'running': False,
|
'running': False,
|
||||||
'info': plugin_info
|
'info': plugin_info,
|
||||||
|
'autorun': False
|
||||||
}
|
}
|
||||||
print(f"Attached plugin '{name}'.")
|
print(f"Attached plugin '{name}'.")
|
||||||
|
print(f"Running pre-load on '{name}'.")
|
||||||
|
thread = threading.Thread(target=self.plugins[name]['instance'].pre_load, args=(callback,))
|
||||||
|
thread.start()
|
||||||
except (ModuleNotFoundError, json.JSONDecodeError, AttributeError) as e:
|
except (ModuleNotFoundError, json.JSONDecodeError, AttributeError) as e:
|
||||||
print(f"Failed to attach plugin '{name}': {e}")
|
print(f"Failed to attach plugin '{name}': {e}")
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user