Fix a bug where parsing assistant thread message event fails for beta feature enabled apps (#1389)

Author: seratch

bolt/src/main/java/com/slack/api/bolt/middleware/builtin/Assistant.java

@@ -12,7 +12,10 @@
 import com.slack.api.bolt.service.AssistantThreadContextService;
 import com.slack.api.bolt.service.builtin.DefaultAssistantThreadContextService;
 import com.slack.api.model.assistant.AssistantThreadContext;
-import com.slack.api.model.event.*;
+import com.slack.api.model.event.AssistantThreadContextChangedEvent;
+import com.slack.api.model.event.AssistantThreadStartedEvent;
+import com.slack.api.model.event.MessageEvent;
+import com.slack.api.model.event.MessageFileShareEvent;
 import com.slack.api.util.thread.DaemonThreadExecutorServiceProvider;
 import lombok.Getter;
 import lombok.Setter;

bolt/src/main/java/com/slack/api/bolt/request/builtin/EventRequest.java

@@ -111,7 +111,7 @@ public EventRequest(
             this.getContext().setChannelId(event.get("channel_id").getAsString());
         }
         // assistant thread events
-        if (event.get("assistant_thread") != null) {
+        if (EventsApiPayloadParser.isAssistantThreadStartedOrContextChangedEvent(event)) {
             this.getContext().setAssistantThreadEvent(true);
             // assistant_thread_started, assistant_thread_context_changed events
             JsonObject thread = event.get("assistant_thread").getAsJsonObject();

bolt/src/main/java/com/slack/api/bolt/util/EventsApiPayloadParser.java

@@ -71,6 +71,12 @@ public static final <E extends Event> Class<E> getEventClass(String eventType) {
         return null;
     }
 
+    public static boolean isAssistantThreadStartedOrContextChangedEvent(JsonObject event) {
+        return event.get("assistant_thread") != null
+                && event.get("assistant_thread").getAsJsonObject().get("channel_id") != null
+                && event.get("assistant_thread").getAsJsonObject().get("thread_ts") != null;
+    }
+
     public static boolean isMessageEventInAssistantThread(JsonObject event) {
         if (event.get("channel_type") != null && event.get("channel_type").getAsString().equals("im")) {
             if (event.get("thread_ts") != null) return true;

bolt/src/test/java/test_locally/app/EventAssistantTest.java

@@ -119,6 +119,28 @@ public void test() throws Exception {
         response = app.run(new EventRequest(userMessage, new RequestHeaders(rawHeaders)));
         assertEquals(200L, response.getStatusCode().longValue());
 
+        String userMessageWithAssistantThread = buildPayload("{\n" +
+                "  \"user\": \"W222\",\n" +
+                "  \"type\": \"message\",\n" +
+                "  \"ts\": \"1726133700.887259\",\n" +
+                "  \"text\": \"When Slack was released?\",\n" +
+                "  \"team\": \"T111\",\n" +
+                "  \"user_team\": \"T111\",\n" +
+                "  \"source_team\": \"T222\",\n" +
+                "  \"user_profile\": {},\n" +
+                "  \"thread_ts\": \"1726133698.626339\",\n" +
+                "  \"parent_user_id\": \"W222\",\n" +
+                "  \"channel\": \"D111\",\n" +
+                "  \"event_ts\": \"1726133700.887259\",\n" +
+                "  \"assistant_thread\": {\"XXX\": \"YYY\"},\n" +
+                "  \"channel_type\": \"im\"\n" +
+                "}");
+        rawHeaders = new HashMap<>();
+        timestamp = String.valueOf(System.currentTimeMillis() / 1000);
+        setRequestHeaders(userMessageWithAssistantThread, rawHeaders, timestamp);
+        response = app.run(new EventRequest(userMessageWithAssistantThread, new RequestHeaders(rawHeaders)));
+        assertEquals(200L, response.getStatusCode().longValue());
+
         String assistantMessageChanged = buildPayload("{\n" +
                 "  \"type\": \"message\",\n" +
                 "  \"subtype\": \"message_changed\",\n" +