feat: add new field to Message (#112)

* feat: add deleted_reply_count field to Message

* fix: print stream key

* fix: delete channels before running tests

* fix: wait until channel deletion task completes

* fix: remove unwanted sleep

Author: shaljam

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

@@ -97,6 +97,10 @@ public class Message {
   @JsonProperty("reply_count")
   private Integer replyCount;
 
+  @Nullable
+  @JsonProperty("deleted_reply_count")
+  private Integer deletedReplyCount;
+
   @Nullable
   @JsonProperty("quoted_message_id")
   private String quotedMessageId;

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

@@ -6,6 +6,7 @@
 import io.getstream.chat.java.models.Channel.ChannelMemberRequestObject;
 import io.getstream.chat.java.models.Channel.ChannelRequestObject;
 import io.getstream.chat.java.models.Message.MessageRequestObject;
+import io.getstream.chat.java.models.TaskStatus.TaskStatusGetResponse;
 import io.getstream.chat.java.models.User.UserRequestObject;
 import io.getstream.chat.java.models.User.UserUpsertRequestData.UserUpsertRequest;
 import java.util.ArrayList;
@@ -29,6 +30,7 @@ public class BasicTest {
   static void setup() throws StreamException, SecurityException, IllegalArgumentException {
     // failOnUnknownProperties();
     setProperties();
+    cleanChannels();
     cleanChannelTypes();
     cleanBlocklists();
     cleanCommands();
@@ -37,6 +39,43 @@ static void setup() throws StreamException, SecurityException, IllegalArgumentEx
     createTestMessage();
   }
 
+  private static void cleanChannels() throws StreamException {
+    while (true) {
+      List<String> channels =
+          Channel.list().request().getChannels().stream()
+              .map(channel -> channel.getChannel().getCId())
+              .collect(Collectors.toList());
+
+      if (channels.size() == 0) {
+        break;
+      }
+
+      var deleteManyResponse =
+          Channel.deleteMany(channels).setDeleteStrategy(DeleteStrategy.HARD).request();
+      String taskId = deleteManyResponse.getTaskId();
+      Assertions.assertNotNull(taskId);
+
+      System.out.printf("Waiting for channel deletion task %s to complete...\n", taskId);
+
+      while (true) {
+        TaskStatusGetResponse response = TaskStatus.get(taskId).request();
+        String status = response.getStatus();
+
+        if (status.equals("completed") || status.equals("ok")) {
+          break;
+        }
+        if (status.equals("failed") || status.equals("error")) {
+          throw new StreamException(
+              String.format("Failed to delete channel(task_id: %s): %s", response.getId(), status),
+              (Throwable) null);
+        }
+
+        // wait for the channels to delete
+        Assertions.assertDoesNotThrow(() -> Thread.sleep(500));
+      }
+    }
+  }
+
   private static void cleanChannelTypes() throws StreamException {
     ChannelType.list()
         .request()

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

@@ -510,6 +510,15 @@ void whenRetrievingReplies_thenAreRetrieved() {
             .getMessages();
     // This assertion is for now commented as there is an issue on the backend
     // Assertions.assertEquals(1, repliesAfterFirstMessage.size());
+
+    // test deleted reply count
+    Assertions.assertDoesNotThrow(() -> Message.delete(firstReply.getId()).request());
+    Message m =
+        Assertions.assertDoesNotThrow(() -> Message.get(parentMessage.getId()).request())
+            .getMessage();
+
+    Assertions.assertEquals(2, m.getReplyCount());
+    Assertions.assertEquals(1, m.getDeletedReplyCount());
   }
 
   @DisplayName("Can execute command action")