feat: implement remaining OpenClaw parity — FetchBans, message chunking, allowBots, reactionAllowlist, responsPrefix

- Add ReactionMode::Allowlist variant and reaction_allowlist config (DISCORD_REACTION_ALLOWLIST)
- Add allow_bots config field (DISCORD_ALLOW_BOTS) to process bot messages
- Add response_prefix config (DISCORD_RESPONSE_PREFIX) prepended to outbound messages
- FetchedBan type + FetchBansCommand + fetch_bans NATS subject + handle_fetch_bans handler
- Message chunking in handle_send_messages: splits content >2000 chars at newlines/spaces,
  applies response_prefix to first chunk, sends embeds/components/files on last chunk
- Fix outbound_tests.rs to pass pairing_state and response_prefix to OutboundProcessor::new
- Fix SendMessageCommand test literals to include as_voice field

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: jramirezhdez02

rsworkspace/crates/discord-bot/src/bridge.rs

@@ -181,8 +181,12 @@ pub struct DiscordBridge {
     pub pairing_state: Arc<PairingState>,
     /// Controls which reaction events are forwarded to NATS.
     pub reaction_mode: crate::config::ReactionMode,
+    /// User IDs allowed to trigger reaction events when reaction_mode = allowlist.
+    pub reaction_allowlist: Vec<u64>,
     /// Optional emoji to react with when a message is received and will be processed.
     pub ack_reaction: Option<String>,
+    /// Whether to process messages sent by other bots.
+    pub allow_bots: bool,
 }
 
 impl TypeMapKey for DiscordBridge {
@@ -198,7 +202,9 @@ impl DiscordBridge {
         presence_enabled: bool,
         guild_commands_guild_id: Option<u64>,
         reaction_mode: crate::config::ReactionMode,
+        reaction_allowlist: Vec<u64>,
         ack_reaction: Option<String>,
+        allow_bots: bool,
     ) -> Self {
         Self {
             publisher: MessagePublisher::new(client, prefix),
@@ -209,7 +215,9 @@ impl DiscordBridge {
             guild_commands_guild_id,
             pairing_state: Arc::new(PairingState::new()),
             reaction_mode,
+            reaction_allowlist,
             ack_reaction,
+            allow_bots,
         }
     }
 
@@ -220,12 +228,16 @@ impl DiscordBridge {
 
     /// Returns true if reaction events should be forwarded based on the configured mode.
     ///
-    /// `is_bot_message` — whether the message the reaction was added to was sent by this bot.
-    pub fn should_publish_reaction(&self, is_bot_message: bool) -> bool {
+    /// `is_bot_message` — whether the message was sent by this bot.
+    /// `reactor_user_id` — the user who added/removed the reaction.
+    pub fn should_publish_reaction(&self, is_bot_message: bool, reactor_user_id: Option<u64>) -> bool {
         match self.reaction_mode {
             crate::config::ReactionMode::Off => false,
             crate::config::ReactionMode::Own => is_bot_message,
             crate::config::ReactionMode::All => true,
+            crate::config::ReactionMode::Allowlist => reactor_user_id
+                .map(|id| self.reaction_allowlist.contains(&id))
+                .unwrap_or(false),
         }
     }
 

rsworkspace/crates/discord-bot/src/config.rs

@@ -46,6 +46,8 @@ pub enum ReactionMode {
     Own,
     /// Publish all reaction events (default)
     All,
+    /// Only publish reactions from users in `reaction_allowlist`
+    Allowlist,
 }
 
 impl Default for ReactionMode {
@@ -73,10 +75,19 @@ pub struct DiscordBotConfig {
     /// Controls which reaction events are forwarded to NATS
     #[serde(default)]
     pub reaction_mode: ReactionMode,
+    /// User IDs allowed to trigger reaction events when `reaction_mode = allowlist`
+    #[serde(default)]
+    pub reaction_allowlist: Vec<u64>,
     /// Optional emoji to react with when a message is received and will be processed.
     /// Use a unicode emoji (e.g. "👀") or omit to disable.
     #[serde(default)]
     pub ack_reaction: Option<String>,
+    /// Whether to process messages sent by other bots (default: false)
+    #[serde(default)]
+    pub allow_bots: bool,
+    /// Optional string prepended to every outbound message sent by the bot
+    #[serde(default)]
+    pub response_prefix: Option<String>,
 }
 
 impl Config {
@@ -155,18 +166,32 @@ impl Config {
         {
             "off" => ReactionMode::Off,
             "own" => ReactionMode::Own,
+            "allowlist" => ReactionMode::Allowlist,
             _ => ReactionMode::All,
         };
 
+        let reaction_allowlist =
+            parse_id_list(&env.var("DISCORD_REACTION_ALLOWLIST").unwrap_or_default());
+
         let ack_reaction = env.var("DISCORD_ACK_REACTION").filter(|s| !s.is_empty());
 
+        let allow_bots = env
+            .var_or("DISCORD_ALLOW_BOTS", "false")
+            .to_lowercase()
+            == "true";
+
+        let response_prefix = env.var("DISCORD_RESPONSE_PREFIX").filter(|s| !s.is_empty());
+
         Ok(Config {
             discord: DiscordBotConfig {
                 bot_token,
                 presence_enabled,
                 guild_commands_guild_id,
                 reaction_mode,
+                reaction_allowlist,
                 ack_reaction,
+                allow_bots,
+                response_prefix,
                 access: AccessConfig {
                     dm_policy,
                     guild_policy,

rsworkspace/crates/discord-bot/src/handlers/mod.rs

@@ -100,9 +100,13 @@ impl EventHandler for Handler {
     }
 
     async fn message(&self, ctx: Context, msg: Message) {
-        // Skip bot messages
+        // Skip bot messages unless allow_bots is enabled
         if msg.author.bot {
-            return;
+            let data = ctx.data.read().await;
+            let allow = data.get::<DiscordBridge>().map(|b| b.allow_bots).unwrap_or(false);
+            if !allow {
+                return;
+            }
         }
 
         let bridge = {
@@ -338,7 +342,8 @@ impl EventHandler for Handler {
         let is_bot_msg = add_reaction.message_author_id
             .map(|author| author.get() == bridge.bot_user_id())
             .unwrap_or(false);
-        if !bridge.should_publish_reaction(is_bot_msg) {
+        let reactor_id = add_reaction.user_id.map(|u| u.get());
+        if !bridge.should_publish_reaction(is_bot_msg, reactor_id) {
             return;
         }
 
@@ -378,7 +383,8 @@ impl EventHandler for Handler {
         let is_bot_msg = removed_reaction.message_author_id
             .map(|author| author.get() == bridge.bot_user_id())
             .unwrap_or(false);
-        if !bridge.should_publish_reaction(is_bot_msg) {
+        let reactor_id = removed_reaction.user_id.map(|u| u.get());
+        if !bridge.should_publish_reaction(is_bot_msg, reactor_id) {
             return;
         }
 

rsworkspace/crates/discord-bot/src/main.rs

@@ -120,7 +120,9 @@ async fn main() -> Result<()> {
         config.discord.presence_enabled,
         config.discord.guild_commands_guild_id,
         config.discord.reaction_mode.clone(),
+        config.discord.reaction_allowlist.clone(),
         config.discord.ack_reaction.clone(),
+        config.discord.allow_bots,
     ));
 
     // Extract pairing_state before bridge is moved into TypeMap so it can be
@@ -183,6 +185,7 @@ async fn main() -> Result<()> {
             prefix_for_outbound,
             Some(shard_manager_for_outbound),
             pairing_state,
+            config.discord.response_prefix.clone(),
         );
         if let Err(e) = processor.run().await {
             error!("Outbound processor error: {}", e);