feat: add unseen, unread to notificationfeed response

gradle/wrapper/gradle-wrapper.properties

@@ -1,5 +1,5 @@
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-6.2.2-bin.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-6.3-all.zip
 zipStoreBase=GRADLE_USER_HOME
 zipStorePath=wrapper/dists

src/main/java/io/getstream/core/http/OKHTTPClientAdapter.java

@@ -103,8 +103,8 @@ public void onFailure(Call call, IOException e) {
 
               @Override
               public void onResponse(Call call, okhttp3.Response response) {
-                io.getstream.core.http.Response httpResponse = buildResponse(response);
-                try (InputStream ignored = httpResponse.getBody()) {
+                try {
+                  io.getstream.core.http.Response httpResponse = buildResponse(response);
                   result.complete(httpResponse);
                 } catch (Exception e) {
                   result.completeExceptionally(e);

src/main/java/io/getstream/core/models/Paginated.java

@@ -31,7 +31,7 @@ public String getDuration() {
   }
 
   @JsonCreator
-  private Paginated(
+  public Paginated(
       @JsonProperty("next") String next,
       @JsonProperty("results") List<T> results,
       @JsonProperty("duration") String duration) {

src/main/java/io/getstream/core/models/PaginatedNotificationGroup.java

@@ -0,0 +1,33 @@
+package io.getstream.core.models;
+
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import com.fasterxml.jackson.annotation.JsonProperty;
+import java.util.List;
+
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class PaginatedNotificationGroup<T> extends Paginated<NotificationGroup<T>> {
+  private final int unread;
+  private final int unseen;
+
+  @JsonCreator
+  public PaginatedNotificationGroup(
+      @JsonProperty("next") String next,
+      @JsonProperty("results") List<NotificationGroup<T>> results,
+      @JsonProperty("duration") String duration,
+      @JsonProperty("unread") int unread,
+      @JsonProperty("unseen") int unseen) {
+    super(next, results, duration);
+
+    this.unread = unread;
+    this.unseen = unseen;
+  }
+
+  public int getUnread() {
+    return this.unread;
+  }
+
+  public int getUnseen() {
+    return this.unseen;
+  }
+}

src/test/java/io/getstream/client/NotificationFeedTest.java

@@ -1,10 +1,11 @@
 package io.getstream.client;
 
+import static org.junit.Assert.*;
+
 import io.getstream.core.http.OKHTTPClientAdapter;
 import io.getstream.core.models.Activity;
 import io.getstream.core.models.EnrichedActivity;
-import io.getstream.core.models.NotificationGroup;
-import java.util.List;
+import io.getstream.core.models.PaginatedNotificationGroup;
 import okhttp3.OkHttpClient;
 import org.junit.Test;
 
@@ -26,7 +27,9 @@ public void getActivityGroups() throws Exception {
             .build();
 
     NotificationFeed feed = client.notificationFeed("notification", "1");
-    List<NotificationGroup<Activity>> result = feed.getActivities().join();
+    PaginatedNotificationGroup<Activity> result = feed.getActivities().join();
+    assertFalse(result.getResults().isEmpty());
+    assertNotNull(result.getResults().get(0).getID());
   }
 
   @Test
@@ -37,6 +40,8 @@ public void getEnrichedActivityGroups() throws Exception {
             .build();
 
     NotificationFeed feed = client.notificationFeed("notification", "1");
-    List<NotificationGroup<EnrichedActivity>> result = feed.getEnrichedActivities().join();
+    PaginatedNotificationGroup<EnrichedActivity> result = feed.getEnrichedActivities().join();
+    assertFalse(result.getResults().isEmpty());
+    assertNotNull(result.getResults().get(0).getID());
   }
 }

src/test/java/io/getstream/cloud/CloudNotificationFeedTest.java

@@ -1,13 +1,14 @@
 package io.getstream.cloud;
 
+import static org.junit.Assert.*;
+
 import io.getstream.client.Client;
 import io.getstream.core.http.Token;
 import io.getstream.core.models.Activity;
 import io.getstream.core.models.EnrichedActivity;
-import io.getstream.core.models.NotificationGroup;
+import io.getstream.core.models.PaginatedNotificationGroup;
 import io.getstream.core.utils.Enrichment;
 import java.net.MalformedURLException;
-import java.util.List;
 import org.junit.BeforeClass;
 import org.junit.Test;
 
@@ -53,14 +54,16 @@ public void getActivityGroups() throws Exception {
     CloudClient client = CloudClient.builder(apiKey, token, userID).build();
 
     CloudNotificationFeed feed = client.notificationFeed("notification", userID);
-    List<NotificationGroup<Activity>> result = feed.getActivities().join();
+    PaginatedNotificationGroup<Activity> result = feed.getActivities().join();
+    assertFalse(result.getResults().isEmpty());
+    assertNotNull(result.getResults().get(0).getID());
   }
 
   @Test
   public void getEnrichedActivityGroups() throws Exception {
     CloudClient client = CloudClient.builder(apiKey, token, userID).build();
 
     CloudNotificationFeed feed = client.notificationFeed("rich_notification", userID);
-    List<NotificationGroup<EnrichedActivity>> result = feed.getEnrichedActivities().join();
+    PaginatedNotificationGroup<EnrichedActivity> result = feed.getEnrichedActivities().join();
   }
 }