Add remaining Tier 2 tools, reaching v2.0.0 milestone (v2.0.0)

New tools (16):
- Enterprise Gateway: rules list, DoS get/update, denied IP list (4)
- IP Access Control: list, add, delete (3)
- Password Policy: get, update (2)
- Alerts: status, enable, disable (3)
- WebSocket: sessions by port, close session (2)
- SAML module registered (ready for tools)

v2.0.0 milestone: comprehensive IS admin and development coverage.

269 tools + 9 prompts + 5 resources. 165/165 E2E tests passing.

Coverage: flow services + debugging, unit testing + mocking, adapters
(JDBC/SAP/OPC) + Designer-like browsing, Kafka streaming, JMS, MQTT,
pub/sub triggers, messaging, scheduler, users/groups/ACLs, OAuth, JWT,
JDBC pools, global variables, server monitoring, remote servers,
auditing, web services/OpenAPI, security/keystores, SFTP, HTTP proxy,
quiesce, health indicators, enterprise gateway, IP access, password
policy, alerts, WebSocket, package marketplace + install, JAR installer,
URL aliases, document type generation (JSON/XSD/XML/SAP), 5 reference
documentation resources for RAG.

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>

Author: cpoder

mcp-server-rs/Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "wm-mcp-server"
-version = "1.9.0"
+version = "2.0.0"
 edition = "2024"
 description = "MCP server for managing webMethods Integration Server via pure HTTP API"
 license = "MIT"

mcp-server-rs/Cargo.toml

@@ -0,0 +1,17 @@
+use serde_json::{Value, json};
+
+impl super::ISClient {
+    pub async fn alert_status(&self) -> Result<Value, String> {
+        self.invoke_get("wm.server.alert:alertingStatus").await
+    }
+
+    pub async fn alert_enable(&self) -> Result<Value, String> {
+        self.invoke_post("wm.server.alert:enableNotifiers", &json!({}))
+            .await
+    }
+
+    pub async fn alert_disable(&self) -> Result<Value, String> {
+        self.invoke_post("wm.server.alert:disableAllNotifiers", &json!({}))
+            .await
+    }
+}

mcp-server-rs/src/client/alerts.rs

@@ -0,0 +1,22 @@
+use serde_json::Value;
+
+impl super::ISClient {
+    pub async fn egw_rules_list(&self) -> Result<Value, String> {
+        self.invoke_get("wm.server.enterprisegateway:getRulesList")
+            .await
+    }
+
+    pub async fn egw_dos_get(&self) -> Result<Value, String> {
+        self.invoke_get("wm.server.enterprisegateway:getDOS").await
+    }
+
+    pub async fn egw_dos_update(&self, settings: &Value) -> Result<Value, String> {
+        self.invoke_post("wm.server.enterprisegateway:saveDOS", settings)
+            .await
+    }
+
+    pub async fn egw_denied_ip_list(&self) -> Result<Value, String> {
+        self.invoke_get("wm.server.enterprisegateway:getDeniedIPList")
+            .await
+    }
+}

mcp-server-rs/src/client/enterprise_gw.rs

@@ -0,0 +1,16 @@
+use serde_json::{Value, json};
+
+impl super::ISClient {
+    pub async fn ip_access_list(&self) -> Result<Value, String> {
+        self.invoke_get("wm.server.net:ipRuleList").await
+    }
+
+    pub async fn ip_access_add(&self, settings: &Value) -> Result<Value, String> {
+        self.invoke_post("wm.server.net:ipRuleAdd", settings).await
+    }
+
+    pub async fn ip_access_delete(&self, ip: &str) -> Result<Value, String> {
+        self.invoke_post("wm.server.net:ipRuleDelete", &json!({"ip": ip}))
+            .await
+    }
+}

mcp-server-rs/src/client/ip_access.rs

@@ -4,10 +4,13 @@
 //! All operations use the IS HTTP API - no disk access required.
 
 mod adapters;
+mod alerts;
 mod auditing;
+mod enterprise_gw;
 mod flow_debug;
 mod global_vars;
 mod health;
+mod ip_access;
 mod jar_installer;
 mod jdbc_pools;
 mod jms;
@@ -20,6 +23,7 @@ mod namespace;
 mod oauth;
 mod packages;
 mod packages_ext;
+mod password_policy;
 mod ports;
 mod proxy;
 mod quiesce;
@@ -33,6 +37,7 @@ mod testing;
 mod triggers;
 mod users;
 mod webservices;
+mod websocket;
 
 use reqwest::Client;
 use reqwest::header::{ACCEPT, AUTHORIZATION, HeaderMap, HeaderValue};

mcp-server-rs/src/client/mod.rs

@@ -0,0 +1,13 @@
+use serde_json::Value;
+
+impl super::ISClient {
+    pub async fn password_policy_get(&self) -> Result<Value, String> {
+        self.invoke_get("wm.server.access:getPasswordExpirySettings")
+            .await
+    }
+
+    pub async fn password_policy_update(&self, settings: &Value) -> Result<Value, String> {
+        self.invoke_post("wm.server.access:updateExpirySettings", settings)
+            .await
+    }
+}

mcp-server-rs/src/client/password_policy.rs

@@ -0,0 +1,19 @@
+use serde_json::{Value, json};
+
+impl super::ISClient {
+    pub async fn websocket_sessions_by_port(&self, port: &str) -> Result<Value, String> {
+        self.invoke_post(
+            "wm.server.net.websocket:listSessionsByPort",
+            &json!({"port": port}),
+        )
+        .await
+    }
+
+    pub async fn websocket_close_session(&self, session_id: &str) -> Result<Value, String> {
+        self.invoke_post(
+            "wm.server.net.websocket:closeSession",
+            &json!({"sessionId": session_id}),
+        )
+        .await
+    }
+}

mcp-server-rs/src/client/websocket.rs

@@ -0,0 +1 @@
+

mcp-server-rs/src/params/alerts.rs

@@ -0,0 +1,10 @@
+use rmcp::schemars;
+use serde::Deserialize;
+
+#[derive(Debug, Deserialize, schemars::JsonSchema)]
+pub struct EgwDosUpdateParam {
+    #[schemars(description = "JSON string with DoS protection settings")]
+    pub settings: String,
+    #[schemars(description = "Target IS instance name (omit for default)")]
+    pub instance: Option<String>,
+}