Merge pull request #2 from HJianBo/add-connector-tools

Add list_connectors MCP Tool

Author: HJianBo

priv/tools_definition/emqx_api_wrappers.json

@@ -19,6 +19,10 @@
             "type": "object"
         }
     },
+    "list_connectors": {
+        "description": "Get a list of all connectors configured in EMQX. Each connector has a Connector ID (as the 'id' field) in format of {type}:{name}. Each connector can be either enabled or disabled, indicated by the 'enable' field. The response also includes connector type, name, status and other configuration details.",
+        "inputSchema": {}
+    },
     "list_authenticators": {
         "description": "Get a list of authenticators configured in EMQX. Each has an Authenticator ID (as the 'id' field) in format of {mechanism}:{backend}. Each authenticator can be either enabled or disabled, indicated by the 'enable' field.",
         "inputSchema": {}

rebar.config

@@ -11,11 +11,11 @@
 
 {project_plugins, [{erlfmt, "1.6.0"}]}.
 
-{erl_opts, [warnings_as_errors, debug_info, {d, plugin_rel_vsn, "0.0.6"}]}.
+{erl_opts, [warnings_as_errors, debug_info, {d, plugin_rel_vsn, "0.0.7"}]}.
 
 %% this is the release version, different from app vsn in .app file
 {relx, [
-    {release, {emqx_mcp_tools, "0.0.6"}, [
+    {release, {emqx_mcp_tools, "0.0.7"}, [
         emqx_mcp_tools,
         emqx_plugin_helper,
         mcp_mqtt_erl

src/emqx_mcp_tools.app.src

@@ -1,6 +1,6 @@
 {application, emqx_mcp_tools, [
     {description, "An EMQX Plugin that provides some useful tools via MCP over MQTT."},
-    {vsn, "0.0.6"},
+    {vsn, "0.0.7"},
     {modules, []},
     {registered, [emqx_mcp_tools_sup]},
     {applications, [kernel, stdlib, emqtt, emqx_plugin_helper, mcp_mqtt_erl]},

src/emqx_mcp_tools_server.erl

@@ -134,6 +134,9 @@ do_call_tool(<<"emqx_connector_info">>, Args, LoopData) ->
     ConnectorId = get_required(<<"id">>, Args),
     Result = emqx_connector_api:'/connectors/:id'(get, #{bindings => #{id => ConnectorId}}),
     handle_http_api_result(Result, LoopData);
+do_call_tool(<<"list_connectors">>, _Args, LoopData) ->
+    Result = emqx_connector_api:'/connectors'(get, #{}),
+    handle_http_api_result(Result, LoopData);
 do_call_tool(<<"list_authenticators">>, _Args, LoopData) ->
     Result = emqx_authn_api:authenticators(get, #{}),
     handle_http_api_result(Result, LoopData);