remove dependency on external broker

samples/client_subscribe.py

@@ -13,8 +13,8 @@ logger = logging.getLogger(__name__)
 
 
 async def uptime_coro() -> None:
-    client = MQTTClient()
-    await client.connect("mqtt://test.mosquitto.org/")
+    client = MQTTClient(config={'auto_reconnect': False})
+    await client.connect("mqtt://localhost:1883")
 
     await client.subscribe(
         [

tests/test_samples.py

@@ -200,10 +200,46 @@ async def test_client_publish_ws():
     await broker.shutdown()
 
 
-def test_client_subscribe():
-    client_subscribe_main()
+broker_std_config = {
+    "listeners": {
+        "default": {
+            "type": "tcp",
+            "bind": "0.0.0.0:1883",        }
+    },
+    'sys_interval':2,
+    "auth": {
+        "allow-anonymous": True,
+        "plugins": ["auth_anonymous"]
+            }
+}
 
 
+@pytest.mark.asyncio
+async def test_client_subscribe():
+
+    # start a standard broker
+    broker = Broker(config=broker_std_config)
+    await broker.start()
+    await asyncio.sleep(1)
+
+    # run the sample
+    client_subscribe_script = Path(__file__).parent.parent / "samples/client_subscribe.py"
+
+    process = await asyncio.create_subprocess_shell(
+        " ".join(["python", str(client_subscribe_script)]),
+        stdout=asyncio.subprocess.PIPE,
+        stderr=asyncio.subprocess.PIPE
+    )
+
+    stdout, stderr = await process.communicate()
+
+    assert "ERROR" not in stdout.decode("utf-8")
+    assert "Exception" not in stdout.decode("utf-8")
+    assert "ERROR" not in stderr.decode("utf-8")
+    assert "Exception" not in stderr.decode("utf-8")
+
+    await broker.shutdown()
+
 @pytest.mark.asyncio
 async def test_client_subscribe_plugin_acl():
     broker = Broker(config=broker_acl_config)