feat: implement OpenClaw parity — polls, stickers, emojis, voice messages, reactionMode, ackReaction

New commands (agent → bot):
- CreatePollCommand: native Discord polls with answers, duration, multiselect
- CreateStickerCommand: create guild stickers from local file
- FetchEmojisCommand: request-reply fetch of all guild custom emojis
- SendMessageCommand.as_voice: send OGG/Opus files as Discord voice messages (IS_VOICE_MESSAGE flag)

New bot behavior:
- ReactionMode (off/own/all): configurable via DISCORD_REACTION_MODE env; filters which reaction events are forwarded to NATS
- ack_reaction: optional emoji (DISCORD_ACK_REACTION env) to react to incoming messages before publishing to NATS

New NATS subjects: agent.poll.create, agent.sticker.create, agent.fetch.emojis

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

Author: jramirezhdez02

rsworkspace/crates/discord-agent/src/processor.rs

@@ -292,6 +292,7 @@ impl MessageProcessor {
                 reply_to_message_id: Some(message_id),
                 files: vec![],
                 components: vec![],
+                as_voice: false,
             };
             let subject = subjects::agent::message_send(publisher.prefix());
             publisher.publish(&subject, &cmd).await?;
@@ -866,6 +867,7 @@ impl MessageProcessor {
             reply_to_message_id: None,
             files: vec![],
             components: vec![],
+            as_voice: false,
         };
         let subject = subjects::agent::message_send(publisher.prefix());
         publisher.publish(&subject, &cmd).await?;
@@ -902,6 +904,7 @@ impl MessageProcessor {
             reply_to_message_id: None,
             files: vec![],
             components: vec![],
+            as_voice: false,
         };
         let subject = subjects::agent::message_send(publisher.prefix());
         publisher.publish(&subject, &cmd).await?;
@@ -1255,6 +1258,7 @@ impl MessageProcessor {
             reply_to_message_id: None,
             files: vec![],
             components: vec![],
+            as_voice: false,
         };
         let subject = subjects::agent::message_send(publisher.prefix());
         publisher.publish(&subject, &cmd).await?;

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

@@ -179,6 +179,10 @@ pub struct DiscordBridge {
     pub guild_commands_guild_id: Option<u64>,
     /// Runtime state for the DM pairing flow (shared with OutboundProcessor).
     pub pairing_state: Arc<PairingState>,
+    /// Controls which reaction events are forwarded to NATS.
+    pub reaction_mode: crate::config::ReactionMode,
+    /// Optional emoji to react with when a message is received and will be processed.
+    pub ack_reaction: Option<String>,
 }
 
 impl TypeMapKey for DiscordBridge {
@@ -193,6 +197,8 @@ impl DiscordBridge {
         access_config: AccessConfig,
         presence_enabled: bool,
         guild_commands_guild_id: Option<u64>,
+        reaction_mode: crate::config::ReactionMode,
+        ack_reaction: Option<String>,
     ) -> Self {
         Self {
             publisher: MessagePublisher::new(client, prefix),
@@ -202,6 +208,24 @@ impl DiscordBridge {
             presence_enabled,
             guild_commands_guild_id,
             pairing_state: Arc::new(PairingState::new()),
+            reaction_mode,
+            ack_reaction,
+        }
+    }
+
+    /// Returns the bot's own user ID (0 if not yet set).
+    pub fn bot_user_id(&self) -> u64 {
+        self.bot_user_id.load(Ordering::Relaxed)
+    }
+
+    /// 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 {
+        match self.reaction_mode {
+            crate::config::ReactionMode::Off => false,
+            crate::config::ReactionMode::Own => is_bot_message,
+            crate::config::ReactionMode::All => true,
         }
     }
 

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

@@ -36,6 +36,24 @@ pub struct Config {
     pub nats: NatsConfig,
 }
 
+/// Controls which reaction events are forwarded to NATS.
+#[derive(Debug, Clone, Serialize, Deserialize, PartialEq)]
+#[serde(rename_all = "snake_case")]
+pub enum ReactionMode {
+    /// Publish no reaction events
+    Off,
+    /// Only publish reactions to messages sent by the bot itself
+    Own,
+    /// Publish all reaction events (default)
+    All,
+}
+
+impl Default for ReactionMode {
+    fn default() -> Self {
+        ReactionMode::All
+    }
+}
+
 /// Discord bot specific configuration
 #[derive(Debug, Clone, Serialize, Deserialize)]
 pub struct DiscordBotConfig {
@@ -52,6 +70,13 @@ pub struct DiscordBotConfig {
     /// Access control configuration
     #[serde(default)]
     pub access: AccessConfig,
+    /// Controls which reaction events are forwarded to NATS
+    #[serde(default)]
+    pub reaction_mode: ReactionMode,
+    /// 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>,
 }
 
 impl Config {
@@ -123,11 +148,25 @@ impl Config {
             .var("DISCORD_GUILD_COMMANDS_GUILD_ID")
             .and_then(|s| s.parse::<u64>().ok());
 
+        let reaction_mode = match env
+            .var_or("DISCORD_REACTION_MODE", "all")
+            .to_lowercase()
+            .as_str()
+        {
+            "off" => ReactionMode::Off,
+            "own" => ReactionMode::Own,
+            _ => ReactionMode::All,
+        };
+
+        let ack_reaction = env.var("DISCORD_ACK_REACTION").filter(|s| !s.is_empty());
+
         Ok(Config {
             discord: DiscordBotConfig {
                 bot_token,
                 presence_enabled,
                 guild_commands_guild_id,
+                reaction_mode,
+                ack_reaction,
                 access: AccessConfig {
                     dm_policy,
                     guild_policy,

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

@@ -185,6 +185,14 @@ impl EventHandler for Handler {
             }
         }
 
+        // Send ack reaction if configured
+        if let Some(ref emoji) = bridge.ack_reaction {
+            let reaction = serenity::model::channel::ReactionType::Unicode(emoji.clone());
+            if let Err(e) = msg.react(&ctx.http, reaction).await {
+                debug!("Failed to send ack reaction: {}", e);
+            }
+        }
+
         if let Err(e) = bridge.publish_message_created(&msg).await {
             error!("Failed to publish message_created: {}", e);
         }
@@ -326,6 +334,14 @@ impl EventHandler for Handler {
             }
         }
 
+        // Reaction mode filtering
+        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) {
+            return;
+        }
+
         if let Err(e) = bridge.publish_reaction_add(&add_reaction).await {
             error!("Failed to publish reaction_add: {}", e);
         }
@@ -358,6 +374,14 @@ impl EventHandler for Handler {
             }
         }
 
+        // Reaction mode filtering
+        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) {
+            return;
+        }
+
         if let Err(e) = bridge.publish_reaction_remove(&removed_reaction).await {
             error!("Failed to publish reaction_remove: {}", e);
         }

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

@@ -119,6 +119,8 @@ async fn main() -> Result<()> {
         config.discord.access.clone(),
         config.discord.presence_enabled,
         config.discord.guild_commands_guild_id,
+        config.discord.reaction_mode.clone(),
+        config.discord.ack_reaction.clone(),
     ));
 
     // Extract pairing_state before bridge is moved into TypeMap so it can be