mirror
/
amqtt
kopia lustrzana https://github.com/Yakifo/amqtt
1
0
Forkuj 0
Kod Zgłoszenia Packages Projekty Wydania Wiki Aktywność

remove hbmqtt plugin namespace compatibility

pull/80/head
Florian Ludwig 2021-07-31 19:45:02 +02:00
rodzic b958b6b29c
commit 86cec6d2a5
2 zmienionych plików z 0 dodań i 10 usunięć
Pokaż statystyki Ściągnij plik aktualizacji Ściągnij plik porównania Expand all files Collapse all files

3
amqtt/plugins/manager.py
Wyświetl plik

@ -64,9 +64,6 @@ class PluginManager:
self._plugins.append(plugin) self._plugins.append(plugin)
self.logger.debug(" Plugin %s ready" % ep.name) self.logger.debug(" Plugin %s ready" % ep.name)
if namespace.startswith("hbmqtt."):
self._load_plugins("amqtt" + namespace[6:])
def _load_plugin(self, ep: pkg_resources.EntryPoint): def _load_plugin(self, ep: pkg_resources.EntryPoint):
try: try:
self.logger.debug(" Loading plugin %s" % ep) self.logger.debug(" Loading plugin %s" % ep)

7
tests/plugins/test_manager.py
Wyświetl plik

@ -43,13 +43,6 @@ class TestPluginManager(unittest.TestCase):
manager = PluginManager("amqtt.test.plugins", context=None) manager = PluginManager("amqtt.test.plugins", context=None)
assert len(manager._plugins) > 0 assert len(manager._plugins) > 0
def test_load_plugin_transition(self):
# entry points have been renamed from hbmqtt. to amqtt.
# For now the plugin manager automatically rewrites
# hbmqtt.test.plugins -> amqtt.test.plugins
manager = PluginManager("hbmqtt.test.plugins", context=None)
assert len(manager._plugins) > 0
def test_fire_event(self): def test_fire_event(self):
async def fire_event(): async def fire_event():
await manager.fire_event("test") await manager.fire_event("test")