Add Tier 2 tools: SFTP, proxy, JWT, quiesce, health indicators (v1.9.0)

New tools (30):
- SFTP client (9): server list/create/get/delete, user list/create/get/delete, test connection
- HTTP proxy (6): list, create, get, delete, enable, disable
- JWT management (6): issuer list/add/get/delete, settings get/update
- Quiesce mode (3): status, enable (graceful drain), disable (return to active)
- Health indicators (3): list, get, change (for K8s health checks)

Plus SFTP user aliases for key-based and password authentication.

253 tools + 9 prompts + 5 resources. 160/160 E2E tests passing.

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.8.0"
+version = "1.9.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,34 @@
+use serde_json::{Value, json};
+
+impl super::ISClient {
+    pub async fn health_indicators_list(&self) -> Result<Value, String> {
+        self.invoke_get("wm.server.healthindicators:getAllHealthIndicators")
+            .await
+    }
+
+    pub async fn health_indicator_get(&self, name: &str) -> Result<Value, String> {
+        self.invoke_post(
+            "wm.server.healthindicators:getHealthIndicator",
+            &json!({"name": name}),
+        )
+        .await
+    }
+
+    pub async fn health_indicator_change(
+        &self,
+        name: &str,
+        settings: &Value,
+    ) -> Result<Value, String> {
+        let mut payload = json!({"name": name});
+        if let Some(obj) = settings.as_object() {
+            for (k, v) in obj {
+                payload
+                    .as_object_mut()
+                    .unwrap()
+                    .insert(k.clone(), v.clone());
+            }
+        }
+        self.invoke_post("wm.server.healthindicators:changeHealthIndicator", &payload)
+            .await
+    }
+}

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

@@ -0,0 +1,30 @@
+use serde_json::{Value, json};
+
+impl super::ISClient {
+    pub async fn jwt_issuer_list(&self) -> Result<Value, String> {
+        self.invoke_get("wm.server.jwt:listIssuers").await
+    }
+
+    pub async fn jwt_issuer_add(&self, settings: &Value) -> Result<Value, String> {
+        self.invoke_post("wm.server.jwt:addIssuer", settings).await
+    }
+
+    pub async fn jwt_issuer_get(&self, name: &str) -> Result<Value, String> {
+        self.invoke_post("wm.server.jwt:getIssuer", &json!({"issuerName": name}))
+            .await
+    }
+
+    pub async fn jwt_issuer_delete(&self, name: &str) -> Result<Value, String> {
+        self.invoke_post("wm.server.jwt:removeIssuer", &json!({"issuerName": name}))
+            .await
+    }
+
+    pub async fn jwt_settings_get(&self) -> Result<Value, String> {
+        self.invoke_get("wm.server.jwt:getGlobalSettings").await
+    }
+
+    pub async fn jwt_settings_update(&self, settings: &Value) -> Result<Value, String> {
+        self.invoke_post("wm.server.jwt:updateGlobalSettings", settings)
+            .await
+    }
+}

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

@@ -7,10 +7,12 @@ mod adapters;
 mod auditing;
 mod flow_debug;
 mod global_vars;
+mod health;
 mod jar_installer;
 mod jdbc_pools;
 mod jms;
 mod jndi;
+mod jwt;
 mod marketplace;
 mod monitoring;
 mod mqtt;
@@ -19,10 +21,13 @@ mod oauth;
 mod packages;
 mod packages_ext;
 mod ports;
+mod proxy;
+mod quiesce;
 mod remote_servers;
 mod scheduler;
 mod security;
 mod services;
+mod sftp;
 mod streaming;
 mod testing;
 mod triggers;

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

@@ -0,0 +1,45 @@
+use serde_json::{Value, json};
+
+impl super::ISClient {
+    pub async fn proxy_list(&self) -> Result<Value, String> {
+        self.invoke_get("wm.server.proxy:getProxyServerAliases")
+            .await
+    }
+
+    pub async fn proxy_create(&self, settings: &Value) -> Result<Value, String> {
+        self.invoke_post("wm.server.proxy:createProxyServerAlias", settings)
+            .await
+    }
+
+    pub async fn proxy_get(&self, alias: &str) -> Result<Value, String> {
+        self.invoke_post(
+            "wm.server.proxy:getProxyServerDetails",
+            &json!({"alias": alias}),
+        )
+        .await
+    }
+
+    pub async fn proxy_delete(&self, alias: &str) -> Result<Value, String> {
+        self.invoke_post(
+            "wm.server.proxy:deleteProxyServerAlias",
+            &json!({"alias": alias}),
+        )
+        .await
+    }
+
+    pub async fn proxy_enable(&self, alias: &str) -> Result<Value, String> {
+        self.invoke_post(
+            "wm.server.proxy:enableProxyServerAlias",
+            &json!({"alias": alias}),
+        )
+        .await
+    }
+
+    pub async fn proxy_disable(&self, alias: &str) -> Result<Value, String> {
+        self.invoke_post(
+            "wm.server.proxy:disableProxyServerAlias",
+            &json!({"alias": alias}),
+        )
+        .await
+    }
+}

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

@@ -0,0 +1,17 @@
+use serde_json::{Value, json};
+
+impl super::ISClient {
+    pub async fn quiesce_status(&self) -> Result<Value, String> {
+        self.invoke_get("wm.server.quiesce:getCurrentMode").await
+    }
+
+    pub async fn quiesce_enable(&self, settings: &Value) -> Result<Value, String> {
+        self.invoke_post("wm.server.quiesce:setQuiesceMode", settings)
+            .await
+    }
+
+    pub async fn quiesce_disable(&self) -> Result<Value, String> {
+        self.invoke_post("wm.server.quiesce:setActiveMode", &json!({}))
+            .await
+    }
+}

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

@@ -0,0 +1,63 @@
+use serde_json::{Value, json};
+
+impl super::ISClient {
+    pub async fn sftp_server_list(&self) -> Result<Value, String> {
+        self.invoke_get("wm.server.sftpclient:listServerAliases")
+            .await
+    }
+
+    pub async fn sftp_server_create(&self, settings: &Value) -> Result<Value, String> {
+        self.invoke_post("wm.server.sftpclient:createServerAlias", settings)
+            .await
+    }
+
+    pub async fn sftp_server_get(&self, alias: &str) -> Result<Value, String> {
+        self.invoke_post(
+            "wm.server.sftpclient:getServerAliasInfo",
+            &json!({"alias": alias}),
+        )
+        .await
+    }
+
+    pub async fn sftp_server_delete(&self, alias: &str) -> Result<Value, String> {
+        self.invoke_post(
+            "wm.server.sftpclient:deleteServerAlias",
+            &json!({"alias": alias}),
+        )
+        .await
+    }
+
+    pub async fn sftp_user_list(&self) -> Result<Value, String> {
+        self.invoke_get("wm.server.sftpclient:listUserAliases")
+            .await
+    }
+
+    pub async fn sftp_user_create(&self, settings: &Value) -> Result<Value, String> {
+        self.invoke_post("wm.server.sftpclient:createUserAlias", settings)
+            .await
+    }
+
+    pub async fn sftp_user_get(&self, alias: &str) -> Result<Value, String> {
+        self.invoke_post(
+            "wm.server.sftpclient:getUserAlias",
+            &json!({"alias": alias}),
+        )
+        .await
+    }
+
+    pub async fn sftp_user_delete(&self, alias: &str) -> Result<Value, String> {
+        self.invoke_post(
+            "wm.server.sftpclient:removeUserAlias",
+            &json!({"alias": alias}),
+        )
+        .await
+    }
+
+    pub async fn sftp_test_connection(&self, alias: &str) -> Result<Value, String> {
+        self.invoke_post(
+            "wm.server.sftpclient:testConnection",
+            &json!({"alias": alias}),
+        )
+        .await
+    }
+}

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

@@ -0,0 +1,22 @@
+use rmcp::schemars;
+use serde::Deserialize;
+
+#[derive(Debug, Deserialize, schemars::JsonSchema)]
+pub struct HealthIndicatorNameParam {
+    #[schemars(description = "Health indicator name")]
+    pub name: String,
+    #[schemars(description = "Target IS instance name (omit for default)")]
+    pub instance: Option<String>,
+}
+
+#[derive(Debug, Deserialize, schemars::JsonSchema)]
+pub struct HealthIndicatorUpdateParam {
+    #[schemars(description = "Health indicator name")]
+    pub name: String,
+    #[schemars(
+        description = "JSON string with health indicator settings to update: enabled, threshold, etc."
+    )]
+    pub settings: String,
+    #[schemars(description = "Target IS instance name (omit for default)")]
+    pub instance: Option<String>,
+}

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

@@ -0,0 +1,30 @@
+use rmcp::schemars;
+use serde::Deserialize;
+
+#[derive(Debug, Deserialize, schemars::JsonSchema)]
+pub struct JwtIssuerCreateParam {
+    #[schemars(
+        description = "JSON string with JWT issuer settings: issuerName, jwksUri, audience, claims, etc."
+    )]
+    pub settings: String,
+    #[schemars(description = "Target IS instance name (omit for default)")]
+    pub instance: Option<String>,
+}
+
+#[derive(Debug, Deserialize, schemars::JsonSchema)]
+pub struct JwtIssuerNameParam {
+    #[schemars(description = "JWT issuer name")]
+    pub issuer_name: String,
+    #[schemars(description = "Target IS instance name (omit for default)")]
+    pub instance: Option<String>,
+}
+
+#[derive(Debug, Deserialize, schemars::JsonSchema)]
+pub struct JwtSettingsUpdateParam {
+    #[schemars(
+        description = "JSON string with JWT global settings: enableJwtAuth, tokenLifetime, etc."
+    )]
+    pub settings: String,
+    #[schemars(description = "Target IS instance name (omit for default)")]
+    pub instance: Option<String>,
+}