653 fr slack connector post message add option to post to an existing thread

connectors/slack/element-templates/hybrid/slack-outbound-connector-hybrid.json

@@ -184,6 +184,22 @@
       "type" : "simple"
     },
     "type" : "String"
+  }, {
+    "id" : "data.thread",
+    "label" : "Thread",
+    "optional" : true,
+    "feel" : "optional",
+    "group" : "channel",
+    "binding" : {
+      "name" : "data.thread",
+      "type" : "zeebe:input"
+    },
+    "condition" : {
+      "property" : "method",
+      "equals" : "chat.postMessage",
+      "type" : "simple"
+    },
+    "type" : "String"
   }, {
     "id" : "data.newChannelName",
     "label" : "Channel name",

connectors/slack/element-templates/slack-outbound-connector.json

@@ -179,6 +179,22 @@
       "type" : "simple"
     },
     "type" : "String"
+  }, {
+    "id" : "data.thread",
+    "label" : "Thread",
+    "optional" : true,
+    "feel" : "optional",
+    "group" : "channel",
+    "binding" : {
+      "name" : "data.thread",
+      "type" : "zeebe:input"
+    },
+    "condition" : {
+      "property" : "method",
+      "equals" : "chat.postMessage",
+      "type" : "simple"
+    },
+    "type" : "String"
   }, {
     "id" : "data.newChannelName",
     "label" : "Channel name",

connectors/slack/src/main/java/io/camunda/connector/slack/outbound/model/ChatPostMessageData.java

@@ -36,6 +36,14 @@ public record ChatPostMessageData(
             binding = @PropertyBinding(name = "data.channel"))
         @NotBlank
         String channel,
+    @TemplateProperty(
+            label = "Thread",
+            id = "data.thread",
+            group = "channel",
+            optional = true,
+            feel = FeelMode.optional,
+            binding = @PropertyBinding(name = "data.thread"))
+        String thread,
     @TemplateProperty(
             label = "Message type",
             id = "data.messageType",
@@ -108,7 +116,9 @@ public SlackResponse invoke(MethodsClient methodsClient) throws SlackApiExceptio
       // Enables plain text message formatting
       requestBuilder.linkNames(true);
     }
-
+    if (StringUtils.isNotBlank(thread)) {
+      requestBuilder.threadTs(thread);
+    }
     if (blockContent != null) {
       if (!blockContent.isArray()) {
         throw new ConnectorException("Block section must be an array");

connectors/slack/src/test/java/io/camunda/connector/slack/BaseTest.java

@@ -36,6 +36,7 @@ interface ChatPostMessageData {
       String EMAIL = "john.dou@camundamail.com";
       String USERNAME = "@" + USER_REAL_NAME;
       String CHANNEL_NAME = "#john.channel";
+      String THREAD_NAME = "thread_ts";
       String CHANNEL_ID = "12345678";
       String TEXT = "_ this is secret test text _";
     }
@@ -53,6 +54,7 @@ interface ChatPostMessageData {
       String USERNAME = "USERNAME_KEY";
       String CHANNEL_NAME = "CHANNEL_NAME_KEY";
       String CHANNEL_ID = "CHANNEL_ID_KEY";
+      String THREAD_NAME = "THREAD_NAME_KEY";
       String TEXT = "TEXT_KEY";
     }
 
@@ -71,6 +73,9 @@ protected static OutboundConnectorContextBuilder getContextBuilderWithSecrets()
         .secret(
             SecretsConstant.ChatPostMessageData.CHANNEL_NAME,
             ActualValue.ChatPostMessageData.CHANNEL_NAME)
+        .secret(
+            SecretsConstant.ChatPostMessageData.THREAD_NAME,
+            ActualValue.ChatPostMessageData.THREAD_NAME)
         .secret(
             SecretsConstant.ChatPostMessageData.CHANNEL_ID,
             ActualValue.ChatPostMessageData.CHANNEL_ID)

connectors/slack/src/test/java/io/camunda/connector/slack/outbound/model/ChatPostMessageDataTest.java

@@ -58,7 +58,7 @@ class ChatPostMessageDataTest {
   void invoke_shouldThrowExceptionWhenUserWithoutEmail() throws SlackApiException, IOException {
     // Given
     ChatPostMessageData chatPostMessageData =
-        new ChatPostMessageData("test@test.com", "plainText", "Test text", EMPTY_JSON);
+        new ChatPostMessageData("test@test.com", "thread_ts", "plainText", "Test text", EMPTY_JSON);
     when(methodsClient.usersLookupByEmail(any(UsersLookupByEmailRequest.class))).thenReturn(null);
     // When and then
     Throwable thrown = catchThrowable(() -> chatPostMessageData.invoke(methodsClient));
@@ -80,7 +80,7 @@ void invoke_shouldThrowExceptionWhenUserWithoutEmail() throws SlackApiException,
   void invoke_shouldFindUserIdByEmail(String email) throws SlackApiException, IOException {
     // Given
     ChatPostMessageData chatPostMessageData =
-        new ChatPostMessageData(email, "plainText", "test", null);
+        new ChatPostMessageData(email, "thread_ts", "plainText", "test", null);
 
     when(methodsClient.usersLookupByEmail(any(UsersLookupByEmailRequest.class)))
         .thenReturn(lookupByEmailResponse);
@@ -102,7 +102,7 @@ void invoke_shouldFindUserIdByEmail(String email) throws SlackApiException, IOEx
   void invoke_WhenTextIsGiven_ShouldInvoke() throws SlackApiException, IOException {
     // Given
     ChatPostMessageData chatPostMessageData =
-        new ChatPostMessageData("test@test.com", "plainText", "test", null);
+        new ChatPostMessageData("test@test.com", "thread_ts", "plainText", "test", null);
 
     when(methodsClient.usersLookupByEmail(any(UsersLookupByEmailRequest.class)))
         .thenReturn(lookupByEmailResponse);
@@ -169,7 +169,11 @@ void invoke_WhenContentBlockIsGiven_ShouldInvoke() throws SlackApiException, IOE
 
     ChatPostMessageData chatPostMessageData =
         new ChatPostMessageData(
-            "test@test.com", "messageBlock", "test", objectMapper.readTree(blockContent));
+            "test@test.com",
+            "thread_ts",
+            "messageBlock",
+            "test",
+            objectMapper.readTree(blockContent));
 
     when(methodsClient.usersLookupByEmail(any(UsersLookupByEmailRequest.class)))
         .thenReturn(lookupByEmailResponse);
@@ -205,7 +209,7 @@ void invoke_WhenContentBlockIsNotArray_ShouldThrow() throws SlackApiException, I
 
     ChatPostMessageData chatPostMessageData =
         new ChatPostMessageData(
-            "test@test.com", "plainText", "test", objectMapper.readTree(blockContent));
+            "test@test.com", "thread_ts", "plainText", "test", objectMapper.readTree(blockContent));
 
     when(methodsClient.usersLookupByEmail(any(UsersLookupByEmailRequest.class)))
         .thenReturn(lookupByEmailResponse);

connectors/slack/src/test/resources/requests/test-cases/execute-function-with-channel-name.json

@@ -5,7 +5,8 @@
     "method": "chat.postMessage",
     "data": {
       "channel": "{{secrets.CHANNEL_NAME_KEY}}",
-      "text": "{{secrets.TEXT_KEY}}"
+      "text": "{{secrets.TEXT_KEY}}",
+      "thread" : "{{secrets.THREAD_NAME_KEY}}"
     }
   },
   {
@@ -14,7 +15,8 @@
     "method": "chat.postMessage",
     "data": {
       "channel": "{{secrets.CHANNEL_NAME_KEY}}",
-      "text": "{{secrets.TEXT_KEY}}"
+      "text": "{{secrets.TEXT_KEY}}",
+      "thread" : "{{secrets.THREAD_NAME_KEY}}"
     }
   },
   {
@@ -23,7 +25,8 @@
     "method": "chat.postMessage",
     "data": {
       "channel": "#john.channel",
-      "text": "some text"
+      "text": "some text",
+      "thread" : "normal_thread"
     }
   }
 ]

connectors/slack/src/test/resources/requests/test-cases/execute-function-with-email.json

@@ -5,7 +5,8 @@
     "method": "chat.postMessage",
     "data": {
       "channel": "{{secrets.EMAIL_KEY}}",
-      "text": "{{secrets.TEXT_KEY}}"
+      "text": "{{secrets.TEXT_KEY}}",
+      "thread" : "{{secrets.THREAD_NAME_KEY}}"
     }
   },
   {
@@ -14,7 +15,8 @@
     "method": "chat.postMessage",
     "data": {
       "channel": "{{secrets.EMAIL_KEY}}",
-      "text": "{{secrets.TEXT_KEY}}"
+      "text": "{{secrets.TEXT_KEY}}",
+      "thread" : "{{secrets.THREAD_NAME_KEY}}"
     }
   },
   {
@@ -23,7 +25,8 @@
     "method": "chat.postMessage",
     "data": {
       "channel": "john.dou@camundamail.com",
-      "text": "some text"
+      "text": "some text",
+      "thread" : "normal_thread"
     }
   }
 ]

connectors/slack/src/test/resources/requests/test-cases/execute-function-with-username.json

@@ -5,7 +5,8 @@
     "method": "chat.postMessage",
     "data": {
       "channel": "{{secrets.USERNAME_KEY}}",
-      "text": "{{secrets.TEXT_KEY}}"
+      "text": "{{secrets.TEXT_KEY}}",
+      "thread" : "{{secrets.THREAD_NAME_KEY}}"
     }
   },
   {
@@ -14,7 +15,8 @@
     "method": "chat.postMessage",
     "data": {
       "channel": "{{secrets.USERNAME_KEY}}",
-      "text": "{{secrets.TEXT_KEY}}"
+      "text": "{{secrets.TEXT_KEY}}",
+      "thread" : "{{secrets.THREAD_NAME_KEY}}"
     }
   },
   {
@@ -23,7 +25,8 @@
     "method": "chat.postMessage",
     "data": {
       "channel": "@JohnDou",
-      "text": "some text"
+      "text": "some text",
+      "thread" : "test thread"
     }
   }
 ]

connectors/slack/src/test/resources/requests/test-cases/replace-secrets.json

@@ -1,47 +1,52 @@
 [
   {
-    "description": "all secrets keys exist without braces",
-    "token": "{{secrets.TOKEN_KEY}}",
-    "method": "chat.postMessage",
-    "data": {
-      "channel": "{{secrets.EMAIL_KEY}}",
-      "text": "{{secrets.TEXT_KEY}}"
+    "description" : "all secrets keys exist without braces",
+    "token" : "{{secrets.TOKEN_KEY}}",
+    "method" : "chat.postMessage",
+    "data" : {
+      "channel" : "{{secrets.EMAIL_KEY}}",
+      "text" : "{{secrets.TEXT_KEY}}",
+      "thread" : "{{secrets.THREAD_NAME_KEY}}"
     }
   },
   {
-    "description": "all secrets keys exist with braces",
-    "token": "{{secrets.TOKEN_KEY}}",
-    "method": "chat.postMessage",
-    "data": {
-      "channel": "{{secrets.EMAIL_KEY}}",
-      "text": "{{secrets.TEXT_KEY}}"
+    "description" : "all secrets keys exist with braces",
+    "token" : "{{secrets.TOKEN_KEY}}",
+    "method" : "chat.postMessage",
+    "data" : {
+      "channel" : "{{secrets.EMAIL_KEY}}",
+      "text" : "{{secrets.TEXT_KEY}}",
+      "thread" : "{{secrets.THREAD_NAME_KEY}}"
     }
   },
   {
-    "description": "secrets in braces after text",
-    "token": "{{secrets.TOKEN_KEY}}",
-    "method": "chat.postMessage",
-    "data": {
-      "channel": "{{secrets.EMAIL_KEY}}",
-      "text": "some text {{secrets.TEXT_KEY}}"
+    "description" : "secrets in braces after text",
+    "token" : "{{secrets.TOKEN_KEY}}",
+    "method" : "chat.postMessage",
+    "data" : {
+      "channel" : "{{secrets.EMAIL_KEY}}",
+      "text" : "some text {{secrets.TEXT_KEY}}",
+      "thread" : "{{secrets.THREAD_NAME_KEY}}"
     }
   },
   {
-    "description": "secrets in braces in text",
-    "token": "{{secrets.TOKEN_KEY}}",
-    "method": "chat.postMessage",
-    "data": {
-      "channel": "{{secrets.EMAIL_KEY}}",
-      "text": "some  {{ secrets.TEXT_KEY}} text"
+    "description" : "secrets in braces in text",
+    "token" : "{{secrets.TOKEN_KEY}}",
+    "method" : "chat.postMessage",
+    "data" : {
+      "channel" : "{{secrets.EMAIL_KEY}}",
+      "text" : "some  {{ secrets.TEXT_KEY}} text",
+      "thread" : "{{secrets.THREAD_NAME_KEY}}"
     }
   },
   {
-    "description": "secrets before braces in text",
-    "token": "{{secrets.TOKEN_KEY}}",
-    "method": "chat.postMessage",
-    "data": {
-      "channel": "{{secrets.EMAIL_KEY}}",
-      "text": "{{secrets.TEXT_KEY}} some text"
+    "description" : "secrets before braces in text",
+    "token" : "{{secrets.TOKEN_KEY}}",
+    "method" : "chat.postMessage",
+    "data" : {
+      "channel" : "{{secrets.EMAIL_KEY}}",
+      "text" : "{{secrets.TEXT_KEY}} some text",
+      "thread" : "thread {{secrets.THREAD_NAME_KEY}}"
     }
   }
 ]

connectors/slack/src/test/resources/requests/test-cases/validate-fields-fail.json

@@ -4,7 +4,8 @@
     "method": "chat.postMessage",
     "data": {
       "channel": "channel",
-      "text": "_ this is secret test text _"
+      "text": "_ this is secret test text _",
+      "thread": "normal_thread"
     }
   },
   {
@@ -13,7 +14,8 @@
     "method": "chat.postMessage",
     "data": {
       "channel": "channel",
-      "text": "_ this is secret test text _"
+      "text": "_ this is secret test text _",
+      "thread": "normal_thread"
     }
   },
 
@@ -23,7 +25,8 @@
     "method": "chat.postMessage",
     "data": {
       "channel": null,
-      "text": "_ this is secret test text _"
+      "text": "_ this is secret test text _",
+      "thread": "normal_thread"
     }
   },
   {
@@ -32,7 +35,8 @@
     "method": "chat.postMessage",
     "data": {
       "channel": "   ",
-      "text": "_ this is secret test text _"
+      "text": "_ this is secret test text _",
+      "thread": "normal_thread"
     }
   },
   {