Add bulk deactivate/reactivate users APIs and tests

src/main/java/io/getstream/chat/java/models/User.java

@@ -10,7 +10,6 @@
 import io.getstream.chat.java.models.User.UserBanRequestData.UserBanRequest;
 import io.getstream.chat.java.models.User.UserCreateGuestRequestData.UserCreateGuestRequest;
 import io.getstream.chat.java.models.User.UserDeactivateRequestData.UserDeactivateRequest;
-import io.getstream.chat.java.models.User.UserDeleteManyRequestData.UserDeleteManyRequest;
 import io.getstream.chat.java.models.User.UserListRequestData.UserListRequest;
 import io.getstream.chat.java.models.User.UserMuteRequestData.UserMuteRequest;
 import io.getstream.chat.java.models.User.UserPartialUpdateRequestData.UserPartialUpdateRequest;
@@ -927,6 +926,94 @@ public static class UserDeleteManyResponse extends StreamResponseObject {
     private String taskId;
   }
 
+  @Builder(
+      builderClassName = "UserDeactivateManyRequest",
+      builderMethodName = "",
+      buildMethodName = "internalBuild")
+  @Getter
+  @EqualsAndHashCode
+  public static class UserDeactivateManyRequestData {
+    @NotNull
+    @JsonProperty("user_ids")
+    private List<String> userIds;
+
+    @Nullable
+    @JsonProperty("created_by_id")
+    private String createdById;
+
+    @Nullable
+    @JsonProperty("mark_channels_deleted")
+    private Boolean markChannelsDeleted;
+
+    @Nullable
+    @JsonProperty("mark_messages_deleted")
+    private Boolean markMessagesDeleted;
+
+    public static class UserDeactivateManyRequest
+        extends StreamRequest<UserDeactivateManyResponse> {
+      @Override
+      protected Call<UserDeactivateManyResponse> generateCall(Client client)
+          throws StreamException {
+        var data = this.internalBuild();
+        return client.create(UserService.class).deactivateUsers(data);
+      }
+    }
+  }
+
+  @Data
+  @EqualsAndHashCode(callSuper = true)
+  public static class UserDeactivateManyResponse extends StreamResponseObject {
+    @JsonProperty("task_id")
+    private String taskId;
+
+    @JsonProperty("duration")
+    private String duration;
+  }
+
+  @Builder(
+      builderClassName = "UserReactivateManyRequest",
+      builderMethodName = "",
+      buildMethodName = "internalBuild")
+  @Getter
+  @EqualsAndHashCode
+  public static class UserReactivateManyRequestData {
+    @NotNull
+    @JsonProperty("user_ids")
+    private List<String> userIds;
+
+    @Nullable
+    @JsonProperty("created_by_id")
+    private String createdById;
+
+    @Nullable
+    @JsonProperty("restore_channels")
+    private Boolean restoreChannels;
+
+    @Nullable
+    @JsonProperty("restore_messages")
+    private Boolean restoreMessages;
+
+    public static class UserReactivateManyRequest
+        extends StreamRequest<UserReactivateManyResponse> {
+      @Override
+      protected Call<UserReactivateManyResponse> generateCall(Client client)
+          throws StreamException {
+        var data = this.internalBuild();
+        return client.create(UserService.class).reactivateUsers(data);
+      }
+    }
+  }
+
+  @Data
+  @EqualsAndHashCode(callSuper = true)
+  public static class UserReactivateManyResponse extends StreamResponseObject {
+    @JsonProperty("task_id")
+    private String taskId;
+
+    @JsonProperty("duration")
+    private String duration;
+  }
+
   @Builder(
       builderClassName = "UserReactivateRequest",
       builderMethodName = "",
@@ -1334,8 +1421,33 @@ public static UserDeleteRequest delete(@NotNull String userId) {
    * @return the created request
    */
   @NotNull
-  public static UserDeleteManyRequest deleteMany(@NotNull List<String> userIds) {
-    return new UserDeleteManyRequest().userIds(userIds);
+  public static UserDeleteManyRequestData.UserDeleteManyRequest deleteMany(
+      @NotNull List<String> userIds) {
+    return new UserDeleteManyRequestData.UserDeleteManyRequest().userIds(userIds);
+  }
+
+  /**
+   * Creates a deactivate users request
+   *
+   * @param userIds list of user ids to be deactivated
+   * @return the created request
+   */
+  @NotNull
+  public static UserDeactivateManyRequestData.UserDeactivateManyRequest deactivateUsers(
+      @NotNull List<String> userIds) {
+    return new UserDeactivateManyRequestData.UserDeactivateManyRequest().userIds(userIds);
+  }
+
+  /**
+   * Creates a reactivate users request
+   *
+   * @param userIds list of user ids to be reactivated
+   * @return the created request
+   */
+  @NotNull
+  public static UserReactivateManyRequestData.UserReactivateManyRequest reactivateUsers(
+      @NotNull List<String> userIds) {
+    return new UserReactivateManyRequestData.UserReactivateManyRequest().userIds(userIds);
   }
 
   /**

src/main/java/io/getstream/chat/java/services/UserService.java

@@ -39,6 +39,10 @@ Call<UserDeleteResponse> delete(
       @Nullable @Query("hard_delete") Boolean hardDelete,
       @Nullable @Query("delete_conversation_channels") Boolean deleteConversationChannels);
 
+  @POST("users/deactivate")
+  Call<UserDeactivateManyResponse> deactivateUsers(
+      @NotNull @Body UserDeactivateManyRequestData userDeactivateManyRequestData);
+
   @POST("users/delete")
   Call<UserDeleteManyResponse> deleteMany(@NotNull @Body UserDeleteManyRequestData data);
 
@@ -47,6 +51,10 @@ Call<UserReactivateResponse> reactivate(
       @NotNull @Path("user_id") String userId,
       @NotNull @Body UserReactivateRequestData userReactivateRequestData);
 
+  @POST("users/reactivate")
+  Call<UserReactivateManyResponse> reactivateUsers(
+      @NotNull @Body UserReactivateManyRequestData userReactivateManyRequestData);
+
   @POST("moderation/mute")
   Call<UserMuteResponse> mute(@NotNull @Body UserMuteRequestData userMuteRequestData);
 

src/test/java/io/getstream/chat/java/UserTest.java

@@ -356,6 +356,68 @@ void whenDeleteManyUsersWithIllegalCondition_thenItFails() {
         });
   }
 
+  @Test
+  @DisplayName("Can deactivate many users")
+  void whenDeactivateManyUsers_thenTaskIdIsReturned() {
+    var userIds = new ArrayList<String>();
+
+    for (var i = 0; i < 3; i++) {
+      String userId = RandomStringUtils.randomAlphabetic(10);
+      UserUpsertRequest usersUpsertRequest = User.upsert();
+      var userObject = UserRequestObject.builder().id(userId).name("User to deactivate").build();
+      usersUpsertRequest.user(userObject);
+      Assertions.assertDoesNotThrow(
+          (ThrowingSupplier<UserUpsertResponse>) usersUpsertRequest::request);
+      userIds.add(userId);
+    }
+
+    Assertions.assertDoesNotThrow(
+        () -> {
+          var taskId =
+              User.deactivateUsers(userIds)
+                  .createdById(testUserRequestObject.getId())
+                  .request()
+                  .getTaskId();
+
+          Assertions.assertNotNull(taskId);
+        });
+  }
+
+  @Test
+  @DisplayName("Can reactivate many users")
+  void whenReactivateManyUsers_thenTaskIdIsReturned() {
+    var userIds = new ArrayList<String>();
+
+    for (var i = 0; i < 3; i++) {
+      String userId = RandomStringUtils.randomAlphabetic(10);
+      UserUpsertRequest usersUpsertRequest = User.upsert();
+      var userObject = UserRequestObject.builder().id(userId).name("User to reactivate").build();
+      usersUpsertRequest.user(userObject);
+      Assertions.assertDoesNotThrow(
+          (ThrowingSupplier<UserUpsertResponse>) usersUpsertRequest::request);
+      userIds.add(userId);
+    }
+
+    // First deactivate them in bulk so they can be reactivated
+    Assertions.assertDoesNotThrow(
+        () ->
+            User.deactivateUsers(userIds)
+                .createdById(testUserRequestObject.getId())
+                .request()
+                .getTaskId());
+
+    Assertions.assertDoesNotThrow(
+        () -> {
+          var taskId =
+              User.reactivateUsers(userIds)
+                  .createdById(testUserRequestObject.getId())
+                  .request()
+                  .getTaskId();
+
+          Assertions.assertNotNull(taskId);
+        });
+  }
+
   @DisplayName("Can mute user")
   @Test
   void whenMutingUser_thenIsMuted() {