From 03bf1c34d9c0080836ca7859cfd0ff86a02d6d2a Mon Sep 17 00:00:00 2001 From: Andrew Mirsky Date: Wed, 2 Jul 2025 12:24:41 -0400 Subject: [PATCH] provide plugin manager context so that it identifies auth and topic check plugins correctly --- tests/plugins/test_manager.py | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/tests/plugins/test_manager.py b/tests/plugins/test_manager.py index ccc70f2..b10668b 100644 --- a/tests/plugins/test_manager.py +++ b/tests/plugins/test_manager.py @@ -84,8 +84,11 @@ class TestPluginManager(unittest.TestCase): assert plugin.test_close_flag def test_plugin_auth_coro(self) -> None: + # provide context that activates auth plugins + context = BaseContext() + context.config = {'auth':{}} - manager = PluginManager("amqtt.test.plugins", context=None) + manager = PluginManager("amqtt.test.plugins", context=context) self.loop.run_until_complete(manager.map_plugin_auth(session=Session())) self.loop.run_until_complete(asyncio.sleep(0.5)) plugin = manager.get_plugin("EventTestPlugin") @@ -93,8 +96,11 @@ class TestPluginManager(unittest.TestCase): assert plugin.test_auth_flag def test_plugin_topic_coro(self) -> None: + # provide context that activates topic check plugins + context = BaseContext() + context.config = {'topic-check':{}} - manager = PluginManager("amqtt.test.plugins", context=None) + manager = PluginManager("amqtt.test.plugins", context=context) self.loop.run_until_complete(manager.map_plugin_topic(session=Session(), topic="test", action=Action.PUBLISH)) self.loop.run_until_complete(asyncio.sleep(0.5)) plugin = manager.get_plugin("EventTestPlugin")