feat: WeCom Stream Mode (WebSocket long-connection)

Author: felix307253927

crates/openfang-api/src/channel_bridge.rs

@@ -18,6 +18,7 @@ use openfang_channels::teams::TeamsAdapter;
 use openfang_channels::telegram::TelegramAdapter;
 use openfang_channels::twitch::TwitchAdapter;
 use openfang_channels::types::ChannelAdapter;
+use openfang_channels::wecom_stream::WeComStreamAdapter;
 use openfang_channels::whatsapp::WhatsAppAdapter;
 use openfang_channels::xmpp::XmppAdapter;
 use openfang_channels::zulip::ZulipAdapter;
@@ -812,6 +813,7 @@ impl ChannelBridgeHandle for KernelBridgeAdapter {
             "linkedin" => channels.linkedin.as_ref().map(|c| c.overrides.clone()),
             "wecom" => channels.wecom.as_ref().map(|c| c.overrides.clone()),
             "mqtt" => channels.mqtt.as_ref().map(|c| c.overrides.clone()),
+            "wecom_stream" => channels.wecom_stream.as_ref().map(|c| c.overrides.clone()),
             _ => None,
         }
     }
@@ -1116,6 +1118,7 @@ pub async fn start_channel_bridge_with_config(
         || config.ntfy.is_some()
         || config.gotify.is_some()
         || config.webhook.is_some()
+        || config.wecom_stream.is_some()
         || config.linkedin.is_some();
 
     if !has_any {
@@ -1477,6 +1480,14 @@ pub async fn start_channel_bridge_with_config(
         }
     }
 
+    // WeCom Stream
+    if let Some(ref ws_config) = config.wecom_stream {
+        if let Some(secret) = read_token(&ws_config.secret_env, "WECOM_WS_SECRET") {
+            let adapter = Arc::new(WeComStreamAdapter::new(ws_config.bot_id.clone(), secret));
+            adapters.push((adapter, ws_config.default_agent.clone()));
+        }
+    }
+
     // ── Wave 4 ──────────────────────────────────────────────────
 
     // Nextcloud Talk

crates/openfang-api/src/routes.rs

@@ -2208,6 +2208,20 @@ const CHANNEL_REGISTRY: &[ChannelMeta] = &[
         setup_steps: &["Create a WeCom application at work.weixin.qq.com", "Get Corp ID, Agent ID, and Secret", "Configure callback URL to your webhook endpoint"],
         config_template: "[channels.wecom]\ncorp_id = \"\"\nagent_id = \"\"\nsecret_env = \"WECOM_SECRET\"",
     },
+    ChannelMeta {
+        name: "wecom_stream", display_name: "WeCom Stream", icon: "WC",
+        description: "WeCom Stream Mode (WebSocket long-connection)",
+        category: "enterprise", difficulty: "Easy", setup_time: "~5 min",
+        quick_setup: "Create an Enterprise Internal App with Stream Mode enabled",
+        setup_type: "form",
+        fields: &[
+            ChannelField { key: "bot_id", label: "Bot ID (Corp ID)", field_type: FieldType::Text, env_var: None, required: true, placeholder: "ww...", advanced: false },
+            ChannelField { key: "secret_env", label: "Secret", field_type: FieldType::Secret, env_var: Some("WECOM_WS_SECRET"), required: true, placeholder: "secret...", advanced: false },
+            ChannelField { key: "default_agent", label: "Default Agent", field_type: FieldType::Text, env_var: None, required: false, placeholder: "assistant", advanced: true },
+        ],
+        setup_steps: &["Create an Enterprise Internal App in WeCom Open Platform", "Enable Stream Mode in the app settings", "Copy Bot ID (Corp ID) and Secret below"],
+        config_template: "[channels.wecom_stream]\nbot_id = \"\"\nsecret_env = \"WECOM_WS_SECRET\"",
+    },
 ];
 
 /// Check if a channel is configured (has a `[channels.xxx]` section in config).
@@ -2255,6 +2269,7 @@ fn is_channel_configured(config: &openfang_types::config::ChannelsConfig, name:
         "webhook" => config.webhook.is_some(),
         "mumble" => config.mumble.is_some(),
         "wecom" => config.wecom.is_some(),
+        "wecom_stream" => config.wecom_stream.is_some(),
         _ => false,
     }
 }

crates/openfang-channels/src/lib.rs

@@ -53,3 +53,4 @@ pub mod mumble;
 pub mod ntfy;
 pub mod webhook;
 pub mod wecom;
+pub mod wecom_stream;