Add emoji reaction support: React with ✏️ (pencil2) to trigger DraftResponseAgent

Author: Song Meo

src/bro/connector/slack.py

@@ -135,6 +135,47 @@ def _process_message(self, client: BaseSocketModeClient, req: SocketModeRequest)
                         )
                     )
                     return None
+
+                case ("events_api", "reaction_added"):
+                    response = SocketModeResponse(envelope_id=req.envelope_id)
+                    client.send_socket_mode_response(response)
+                    _logger.info(f"Received reaction_added event: {event}")
+
+                    # Check if it's the draft emoji (pencil2 ✏️)
+                    reaction = event.get("reaction")
+                    if reaction == "pencil2":
+                        # Get the message that was reacted to
+                        message_ts = event.get("item", {}).get("ts")
+                        channel_id = event.get("item", {}).get("channel")
+
+                        if message_ts and channel_id:
+                            try:
+                                # Fetch the original message
+                                result = self._web_client.conversations_history(
+                                    channel=channel_id, latest=message_ts, inclusive=True, limit=1
+                                )
+
+                                if result["messages"]:
+                                    message_text = result["messages"][0].get("text", "")
+                                    _logger.info(f"Pencil reaction on message: {message_text[:100]}")
+
+                                    # Create a synthetic message to trigger draft response
+                                    user_info = self._web_client.users_info(user=user_id)["user"]
+                                    user_name = user_info["name"]
+
+                                    self._unread_msgs.append(
+                                        ReceivedMessage(
+                                            via=Channel(name=channel_id),
+                                            user=User(name=user_name),
+                                            text=f"[DRAFT_RESPONSE_REQUEST]\n{message_text}",
+                                            attachments=[],
+                                            thread_ts=message_ts,  # Reply in the same thread
+                                        )
+                                    )
+                            except Exception as e:
+                                _logger.error(f"Failed to handle reaction: {e}")
+                    return None
+
             return None
 
     def list_channels(self) -> list[Channel]:

src/bro/conversation.py

@@ -562,6 +562,45 @@ def spin(self) -> bool:
                     self._current_thread_ts = msg_thread_ts
 
                 try:
+                    # Check if this is a draft response request triggered by emoji reaction
+                    if msg.text.startswith("[DRAFT_RESPONSE_REQUEST]"):
+                        _logger.info("Draft response request detected from emoji reaction")
+                        # Extract the inquiry context from the message
+                        inquiry_text = msg.text.replace("[DRAFT_RESPONSE_REQUEST]\n", "").strip()
+
+                        # Trigger DraftResponseAgent directly
+                        if hasattr(self._reasoner, "_draft_response_agent") and self._reasoner._draft_response_agent:
+                            try:
+                                _logger.info(f"Running DraftResponseAgent for emoji reaction")
+                                draft_result = self._reasoner._draft_response_agent.run(inquiry_text)
+
+                                # Post draft as response in the thread
+                                response_data = textwrap.dedent(
+                                    f"""\
+                                via: {msg.via.name!r}
+                                user: "Bro"
+                                attachments: []
+                                ---
+                                {draft_result}
+                                """
+                                )
+                                self._context += [
+                                    {
+                                        "role": "user",
+                                        "content": [
+                                            {"type": "input_text", "text": response_data},
+                                        ],
+                                    },
+                                ]
+                                conversation_response = self._request_inference(self._context)
+                                output = conversation_response["output"]
+                                if output:
+                                    self._process_response_output(output)
+                            except Exception as e:
+                                _logger.error(f"DraftResponseAgent failed: {e}")
+                        # Skip normal processing for this message
+                        continue
+
                     input_data = textwrap.dedent(
                         f"""\
                     via: {msg.via.name!r}