Slack Button Fix and Threaded Messaging

changelog/6020.feature.rst

@@ -0,0 +1,11 @@
+You can now enable threaded message responses from Rasa through the Slack connector. 
+This option is enabled using an optional configuration in the credentials.yml file
+
+.. code-block:: none
+
+    slack:
+      slack_token:
+      slack_channel:
+      use_threads: True
+
+Button support has also been added in the Slack connector. 

docs/core/domains.rst

@@ -217,7 +217,28 @@ output payloads that will only work in certain channels.
     - text: "Which game would you like to play?"
       channel: "slack"
       custom:
-        - # payload for Slack dropdown menu to choose a game
+        blocks:
+        - type: actions
+          elements:
+          - type: button
+            text:
+              type: plain_text
+              emoji: true
+              text: "Chess :crown:"
+            value: '/inform{"game": "chess"}'
+          - type: button
+            text:
+              type: plain_text
+              emoji: true
+              text: "Checkers :checkered_flag:"
+            value: '/inform{"game": "checkers"}'
+          - type: button
+            text:
+              type: plain_text
+              emoji: true
+              text: "Fortnite :european_castle:"
+            value: '/inform{"game": "fortnite"}'
+            style: danger
     - text: "Which game would you like to play?"
       buttons:
       - title: "Chess"

docs/user-guide/connectors/slack.rst

@@ -74,7 +74,7 @@ You need to supply a ``credentials.yml`` with the following content:
      slack_retry_reason_header: "x-slack-retry-reason"  # Slack HTTP header name indicating reason that slack send retry request. This configuration is optional.
      slack_retry_number_header: "x-slack-retry-num"  # Slack HTTP header name indicating the attempt number. This configuration is optional.
      errors_ignore_retry: None  # Any error codes given by Slack included in this list will be ignored. Error codes are listed `here <https://api.slack.com/events-api#errors>`_.
-
+     use_threads: False  # If set to True, bot responses will appear as a threaded message in Slack. This configuration is optional and set to False by default.  
 
 The endpoint for receiving slack messages is
 ``http://localhost:5005/webhooks/slack/webhook``, replacing

rasa/core/channels/slack.py

@@ -20,9 +20,15 @@ class SlackBot(OutputChannel):
     def name(cls) -> Text:
         return "slack"
 
-    def __init__(self, token: Text, slack_channel: Optional[Text] = None) -> None:
+    def __init__(
+        self,
+        token: Text,
+        slack_channel: Optional[Text] = None,
+        ts: Optional[Text] = None,
+    ) -> None:
 
         self.slack_channel = slack_channel
+        self.ts = ts
         self.client = WebClient(token, run_async=True)
         super().__init__()
 
@@ -35,26 +41,53 @@ async def send_text_message(
     ) -> None:
         recipient = self.slack_channel or recipient_id
         for message_part in text.strip().split("\n\n"):
-            await self.client.chat_postMessage(
-                channel=recipient, as_user=True, text=message_part, type="mrkdwn",
-            )
+            if self.ts:
+                await self.client.chat_postMessage(
+                    channel=recipient,
+                    as_user=True,
+                    text=message_part,
+                    type="mrkdwn",
+                    thread_ts=self.ts,
+                )
+            else:
+                await self.client.chat_postMessage(
+                    channel=recipient, as_user=True, text=message_part, type="mrkdwn"
+                )
 
     async def send_image_url(
         self, recipient_id: Text, image: Text, **kwargs: Any
     ) -> None:
         recipient = self.slack_channel or recipient_id
         image_block = {"type": "image", "image_url": image, "alt_text": image}
-        await self.client.chat_postMessage(
-            channel=recipient, as_user=True, text=image, blocks=[image_block],
-        )
+        if self.ts:
+            await self.client.chat_postMessage(
+                channel=recipient,
+                as_user=True,
+                text=image,
+                blocks=[image_block],
+                thread_ts=self.ts,
+            )
+        else:
+            await self.client.chat_postMessage(
+                channel=recipient, as_user=True, text=image, blocks=[image_block],
+            )
 
     async def send_attachment(
         self, recipient_id: Text, attachment: Dict[Text, Any], **kwargs: Any
     ) -> None:
         recipient = self.slack_channel or recipient_id
-        await self.client.chat_postMessage(
-            channel=recipient, as_user=True, attachments=[attachment], **kwargs,
-        )
+        if self.ts:
+            await self.client.chat_postMessage(
+                channel=recipient,
+                as_user=True,
+                attachments=[attachment],
+                thread_ts=self.ts,
+                **kwargs,
+            )
+        else:
+            await self.client.chat_postMessage(
+                channel=recipient, as_user=True, attachments=[attachment], **kwargs,
+            )
 
     async def send_text_with_buttons(
         self,
@@ -83,18 +116,30 @@ async def send_text_with_buttons(
                     "value": button["payload"],
                 }
             )
-        await self.client.chat_postMessage(
-            channel=recipient,
-            as_user=True,
-            text=text,
-            blocks=[text_block, button_block],
-        )
+        if self.ts:
+            await self.client.chat_postMessage(
+                channel=recipient,
+                as_user=True,
+                text=text,
+                blocks=[text_block, button_block],
+                thread_ts=self.ts,
+            )
+        else:
+            await self.client.chat_postMessage(
+                channel=recipient,
+                as_user=True,
+                text=text,
+                blocks=[text_block, button_block],
+            )
 
     async def send_custom_json(
         self, recipient_id: Text, json_message: Dict[Text, Any], **kwargs: Any
     ) -> None:
         json_message.setdefault("channel", self.slack_channel or recipient_id)
         json_message.setdefault("as_user", True)
+        if self.ts:
+            json_message.setdefault("thread_ts", self.ts)
+
         await self.client.chat_postMessage(**json_message)
 
 
@@ -117,6 +162,7 @@ def from_credentials(cls, credentials: Optional[Dict[Text, Any]]) -> InputChanne
             credentials.get("slack_retry_reason_header", "x-slack-retry-reason"),
             credentials.get("slack_retry_number_header", "x-slack-retry-num"),
             credentials.get("errors_ignore_retry", None),
+            credentials.get("use_threads", False),
         )
         # pytype: enable=attribute-error
 
@@ -127,6 +173,7 @@ def __init__(
         slack_retry_reason_header: Optional[Text] = None,
         slack_retry_number_header: Optional[Text] = None,
         errors_ignore_retry: Optional[List[Text]] = None,
+        use_threads: Optional[Text] = None,
     ) -> None:
         """Create a Slack input channel.
 
@@ -156,6 +203,7 @@ def __init__(
         self.errors_ignore_retry = errors_ignore_retry or ("http_timeout",)
         self.retry_reason_header = slack_retry_reason_header
         self.retry_num_header = slack_retry_number_header
+        self.use_threads = use_threads
 
     @staticmethod
     def _is_app_mention(slack_event: Dict) -> bool:
@@ -297,13 +345,17 @@ async def process_message(
 
         if metadata is not None:
             output_channel = metadata.get("out_channel")
+            if self.use_threads:
+                ts = metadata.get("ts")
+            else:
+                ts = None
         else:
             output_channel = None
 
         try:
             user_msg = UserMessage(
                 text,
-                self.get_output_channel(output_channel),
+                self.get_output_channel(output_channel, ts),
                 sender_id,
                 input_channel=self.name(),
                 metadata=metadata,
@@ -326,13 +378,30 @@ def get_metadata(self, request: Request) -> Dict[Text, Any]:
             Metadata extracted from the sent event payload. This includes the output channel for the response,
             and users that have installed the bot.
         """
-        slack_event = request.json
-        event = slack_event.get("event", {})
-
-        return {
-            "out_channel": event.get("channel"),
-            "users": slack_event.get("authed_users"),
-        }
+        content_type = request.headers.get("content-type")
+        if content_type == "application/json":
+            slack_event = request.json
+            event = slack_event.get("event", {})
+            ts = event.get("thread_ts", event.get("ts"))
+
+            return {
+                "out_channel": event.get("channel"),
+                "ts": ts,
+                "users": slack_event.get("authed_users"),
+            }
+
+        if content_type == "application/x-www-form-urlencoded":
+            output = request.form
+            payload = json.loads(output["payload"][0])
+            message = payload.get("message", {})
+            ts = message.get("thread_ts", message.get("ts"))
+            return {
+                "out_channel": payload.get("channel", {}).get("id"),
+                "ts": ts,
+                "users": payload.get("user", {}).get("id"),
+            }
+
+        return {}
 
     def blueprint(
         self, on_new_message: Callable[[UserMessage], Awaitable[Any]]
@@ -345,26 +414,8 @@ async def health(_: Request) -> HTTPResponse:
 
         @slack_webhook.route("/webhook", methods=["GET", "POST"])
         async def webhook(request: Request) -> HTTPResponse:
-            if request.form:
-                output = request.form
-                payload = json.loads(output["payload"][0])
-
-                if self._is_interactive_message(payload):
-                    sender_id = payload["user"]["id"]
-                    text = self._get_interactive_response(payload["actions"][0])
-                    if text is not None:
-                        metadata = self.get_metadata(request)
-                        return await self.process_message(
-                            request, on_new_message, text, sender_id, metadata
-                        )
-                    elif payload["actions"][0]["type"] == "button":
-                        # link buttons don't have "value", don't send their clicks to bot
-                        return response.text("User clicked link button")
-                return response.text(
-                    "The input message could not be processed.", status=500
-                )
-
-            elif request.json:
+            content_type = request.headers.get("content-type")
+            if content_type == "application/json":
                 output = request.json
                 event = output.get("event", {})
                 user_message = event.get("text", "")
@@ -391,6 +442,25 @@ async def webhook(request: Request) -> HTTPResponse:
                         f"Received message on unsupported channel: {metadata['out_channel']}"
                     )
 
+            elif content_type == "application/x-www-form-urlencoded":
+                output = request.form
+                payload = json.loads(output["payload"][0])
+
+                if self._is_interactive_message(payload):
+                    sender_id = payload["user"]["id"]
+                    text = self._get_interactive_response(payload["actions"][0])
+                    if text is not None:
+                        metadata = self.get_metadata(request)
+                        return await self.process_message(
+                            request, on_new_message, text, sender_id, metadata
+                        )
+                    if payload["actions"][0]["type"] == "button":
+                        # link buttons don't have "value", don't send their clicks to bot
+                        return response.text("User clicked link button")
+                return response.text(
+                    "The input message could not be processed.", status=500
+                )
+
             return response.text("Bot message delivered.")
 
         return slack_webhook
@@ -402,9 +472,11 @@ def _is_supported_channel(self, slack_event: Dict, metadata: Dict) -> bool:
             or metadata["out_channel"] == self.slack_channel
         )
 
-    def get_output_channel(self, channel: Optional[Text] = None) -> OutputChannel:
+    def get_output_channel(
+        self, channel: Optional[Text] = None, ts: Optional[Text] = None
+    ) -> OutputChannel:
         channel = channel or self.slack_channel
-        return SlackBot(self.slack_token, channel)
+        return SlackBot(self.slack_token, channel, ts)
 
     def set_output_channel(self, channel: Text) -> None:
         self.slack_channel = channel