feat: allow sending invites when creating a channel (#124)

GetStream · Nov 2, 2023 · 937dc3a · 937dc3a
1 parent 2d40d2f
commit 937dc3a
Show file tree

Hide file tree

Showing 2 changed files with 41 additions and 0 deletions.
diff --git a/src/main/java/io/getstream/chat/java/models/Channel.java b/src/main/java/io/getstream/chat/java/models/Channel.java
@@ -231,6 +231,11 @@ public static class ChannelRequestObject {
     @JsonProperty("members")
     private List<ChannelMemberRequestObject> members;
 
+    @Singular
+    @Nullable
+    @JsonProperty("invites")
+    private List<ChannelMemberRequestObject> invites;
+
     @Nullable
     @JsonProperty("config_overrides")
     private ConfigOverridesRequestObject configOverrides;
@@ -259,6 +264,7 @@ private ChannelRequestObject(
         @Nullable Language autoTranslationLanguage,
         @Nullable Boolean frozen,
         @Nullable List<ChannelMemberRequestObject> members,
+        @Nullable List<ChannelMemberRequestObject> invites,
         @Nullable ConfigOverridesRequestObject configOverrides,
         Map<String, Object> additionalFields) {
       this.createdBy = createdBy;
@@ -267,6 +273,7 @@ private ChannelRequestObject(
       this.autoTranslationLanguage = autoTranslationLanguage;
       this.frozen = frozen;
       this.members = members;
+      this.invites = invites;
       this.configOverrides = configOverrides;
       this.additionalFields = new HashMap<String, Object>(additionalFields);
     }

diff --git a/src/test/java/io/getstream/chat/java/ChannelTest.java b/src/test/java/io/getstream/chat/java/ChannelTest.java
@@ -11,6 +11,7 @@
 import java.util.Arrays;
 import java.util.Date;
 import java.util.List;
+import java.util.stream.Collectors;
 import org.apache.commons.lang3.RandomStringUtils;
 import org.junit.jupiter.api.Assertions;
 import org.junit.jupiter.api.DisplayName;
@@ -32,6 +33,39 @@ void whenRetrievingChannel_thenNoException() {
                 .request());
   }
 
+  @DisplayName("Can create channel with invites")
+  @Test
+  void whenCreatingChannelWithInvites_thenNoException() {
+    var lastUser = testUsersRequestObjects.get(testUsersRequestObjects.size() - 1);
+    // invite last user and add the rest as members
+    var channelReq =
+        ChannelRequestObject.builder()
+            .createdBy(testUserRequestObject)
+            .members(
+                testUsersRequestObjects.stream()
+                    .limit(testUsersRequestObjects.size() - 1)
+                    .map(user -> ChannelMemberRequestObject.builder().user(user).build())
+                    .collect(Collectors.toList()))
+            .invite(ChannelMemberRequestObject.builder().user(lastUser).build())
+            .build();
+    var channel =
+        Assertions.assertDoesNotThrow(
+            () -> Channel.getOrCreate(testChannel.getType()).data(channelReq).request());
+
+    var invitedMember =
+        channel.getMembers().stream()
+            .filter(
+                channelMember -> {
+                  var invited = channelMember.getInvited();
+                  return invited != null && invited;
+                })
+            .findFirst()
+            .get();
+
+    Assertions.assertNotNull(invitedMember);
+    Assertions.assertEquals(invitedMember.getUserId(), lastUser.getId());
+  }
+
   @DisplayName("Can set custom field on channel")
   @Test
   void whenSettingCustomField_thenNoException() {