Issue 4 merge latest upstream changes

examples/clients/mqtt-clients/client_apis_demo.py

@@ -0,0 +1,51 @@
+import logging
+
+import anyio
+
+import mcp.client.mqtt as mcp_mqtt
+from mcp.shared.mqtt import configure_logging
+
+configure_logging(level="DEBUG")
+logger = logging.getLogger(__name__)
+
+async def on_mcp_server_discovered(client, server_name):
+    logger.info(f"Discovered {server_name}, connecting ...")
+    await client.initialize_mcp_server(server_name)
+
+async def on_mcp_connect(client, server_name, connect_result):
+    capabilities = client.get_session(server_name).server_info.capabilities
+    logger.info(f"Capabilities of {server_name}: {capabilities}")
+    if capabilities.prompts:
+        prompts = await client.list_prompts(server_name)
+        logger.info(f"Prompts of {server_name}: {prompts}")
+    if capabilities.resources:
+        resources = await client.list_resources(server_name)
+        logger.info(f"Resources of {server_name}: {resources}")
+        resource_templates = await client.list_resource_templates(server_name)
+        logger.info(f"Resources templates of {server_name}: {resource_templates}")
+    if capabilities.tools:
+        toolsResult = await client.list_tools(server_name)
+        tools = toolsResult.tools
+        logger.info(f"Tools of {server_name}: {tools}")
+
+async def on_mcp_disconnect(client, server_name):
+    logger.info(f"Disconnected from {server_name}")
+
+async def main():
+    async with mcp_mqtt.MqttTransportClient(
+        "test_client",
+        auto_connect_to_mcp_server = True,
+        on_mcp_server_discovered = on_mcp_server_discovered,
+        on_mcp_connect = on_mcp_connect,
+        on_mcp_disconnect = on_mcp_disconnect,
+        mqtt_options = mcp_mqtt.MqttOptions(
+            host="broker.emqx.io",
+        )
+    ) as client:
+        client.start()
+        while True:
+            logger.info("Other works while the MQTT transport client is running in the background...")
+            await anyio.sleep(10)
+
+if __name__ == "__main__":
+    anyio.run(main)

examples/fastmcp/mqtt_simple_echo.py

@@ -0,0 +1,27 @@
+"""
+FastMCP Echo Server
+"""
+
+from mcp.server.fastmcp import FastMCP
+from mcp.shared.mqtt import MqttOptions
+
+# Create server
+mcp = FastMCP(
+    "demo_server/echo",
+    log_level="DEBUG",
+)
+
+mcp.settings.mqtt_options = MqttOptions(
+    host="broker.emqx.io",
+    verify_connack_properties=True,  # Change to False if broker is Mosquitto
+)
+
+
+@mcp.tool()
+def echo(text: str) -> str:
+    """Echo the input text"""
+    return text
+
+
+if __name__ == "__main__":
+    mcp.run(transport="mqtt")

pyproject.toml

@@ -33,6 +33,7 @@ dependencies = [
     "uvicorn>=0.31.1; sys_platform != 'emscripten'",
     "jsonschema>=4.20.0",
     "pywin32>=310; sys_platform == 'win32'",
+    "paho-mqtt>=2.1.0",
 ]
 
 [project.optional-dependencies]
@@ -59,6 +60,9 @@ dev = [
     "pytest-pretty>=1.2.0",
     "inline-snapshot>=0.23.0",
     "dirty-equals>=0.9.0",
+    "typer>=0.17.4",
+    "python-dotenv>=1.1.1",
+    "websockets>=15.0.1",
 ]
 docs = [
     "mkdocs>=1.6.1",
@@ -134,7 +138,7 @@ max-returns = 13      # Default is 6
 max-statements = 102  # Default is 50
 
 [tool.uv.workspace]
-members = ["examples/servers/*", "examples/snippets"]
+members = ["examples/servers/*", "examples/snippets", "examples/clients/mqtt-clients/smart-home"]
 
 [tool.uv.sources]
 mcp = { workspace = true }