Version 3.1.2

* Add Limit option to reactions client filter method

Author: Max Klyga

README.md

@@ -12,14 +12,14 @@ Add the following dependency to your pom.xml:
 <dependency>
     <groupId>io.getstream.client</groupId>
     <artifactId>stream-java</artifactId>
-    <version>3.1.1</version>
+    <version>3.1.2</version>
 </dependency>
 ```
 
 or in your build.gradle:
 
 ```gradle
-compile 'io.getstream.client:stream-java:3.1.1'
+compile 'io.getstream.client:stream-java:3.1.2'
 ```
 
 In case you want to download the artifact and put it manually into your project,

build.gradle

@@ -9,7 +9,7 @@ plugins {
 }
 
 group 'io.getstream.client'
-version = '3.1.1'
+version = '3.1.2'
 
 dependencies {
     testCompile 'org.junit.jupiter:junit-jupiter-api:5.3.1'

src/main/java/io/getstream/client/ReactionsClient.java

@@ -8,6 +8,7 @@
 import io.getstream.core.models.FeedID;
 import io.getstream.core.models.Reaction;
 import io.getstream.core.options.Filter;
+import io.getstream.core.options.Limit;
 import io.getstream.core.utils.Auth.TokenAction;
 import io.getstream.core.utils.DefaultOptions;
 
@@ -33,20 +34,32 @@ public CompletableFuture<Reaction> get(String id) throws StreamException {
     }
 
     public CompletableFuture<List<Reaction>> filter(LookupKind lookup, String id) throws StreamException {
-        return filter(lookup, id, "");
+        return filter(lookup, id, DefaultOptions.DEFAULT_FILTER, DefaultOptions.DEFAULT_LIMIT, "");
+    }
+
+    public CompletableFuture<List<Reaction>> filter(LookupKind lookup, String id, Limit limit) throws StreamException {
+        return filter(lookup, id, DefaultOptions.DEFAULT_FILTER, limit, "");
     }
 
     public CompletableFuture<List<Reaction>> filter(LookupKind lookup, String id, Filter filter) throws StreamException {
-        return filter(lookup, id, filter, "");
+        return filter(lookup, id, filter, DefaultOptions.DEFAULT_LIMIT, "");
     }
 
     public CompletableFuture<List<Reaction>> filter(LookupKind lookup, String id, String kind) throws StreamException {
-        return filter(lookup, id, DefaultOptions.DEFAULT_FILTER, kind);
+        return filter(lookup, id, DefaultOptions.DEFAULT_FILTER, DefaultOptions.DEFAULT_LIMIT, kind);
+    }
+
+    public CompletableFuture<List<Reaction>> filter(LookupKind lookup, String id, Filter filter, Limit limit) throws StreamException {
+        return filter(lookup, id, filter, limit, "");
+    }
+
+    public CompletableFuture<List<Reaction>> filter(LookupKind lookup, String id, Limit limit, String kind) throws StreamException {
+        return filter(lookup, id, DefaultOptions.DEFAULT_FILTER, limit, kind);
     }
 
-    public CompletableFuture<List<Reaction>> filter(LookupKind lookup, String id, Filter filter, String kind) throws StreamException {
+    public CompletableFuture<List<Reaction>> filter(LookupKind lookup, String id, Filter filter, Limit limit, String kind) throws StreamException {
         final Token token = buildReactionsToken(secret, TokenAction.READ);
-        return reactions.filter(token, lookup, id, filter, kind);
+        return reactions.filter(token, lookup, id, filter, limit, kind);
     }
 
     public CompletableFuture<Reaction> add(String userID, String kind, String activityID, Iterable<FeedID> targetFeeds) throws StreamException {

src/main/java/io/getstream/cloud/CloudReactionsClient.java

@@ -8,6 +8,7 @@
 import io.getstream.core.models.FeedID;
 import io.getstream.core.models.Reaction;
 import io.getstream.core.options.Filter;
+import io.getstream.core.options.Limit;
 import io.getstream.core.utils.DefaultOptions;
 
 import java.util.List;
@@ -32,19 +33,31 @@ public CompletableFuture<Reaction> get(String id) throws StreamException {
     }
 
     public CompletableFuture<List<Reaction>> filter(LookupKind lookup, String id) throws StreamException {
-        return filter(lookup, id, "");
+        return filter(lookup, id, DefaultOptions.DEFAULT_FILTER, DefaultOptions.DEFAULT_LIMIT, "");
+    }
+
+    public CompletableFuture<List<Reaction>> filter(LookupKind lookup, String id, Limit limit) throws StreamException {
+        return filter(lookup, id, DefaultOptions.DEFAULT_FILTER, limit, "");
     }
 
     public CompletableFuture<List<Reaction>> filter(LookupKind lookup, String id, Filter filter) throws StreamException {
-        return filter(lookup, id, filter, "");
+        return filter(lookup, id, filter, DefaultOptions.DEFAULT_LIMIT, "");
     }
 
     public CompletableFuture<List<Reaction>> filter(LookupKind lookup, String id, String kind) throws StreamException {
-        return filter(lookup, id, DefaultOptions.DEFAULT_FILTER, kind);
+        return filter(lookup, id, DefaultOptions.DEFAULT_FILTER, DefaultOptions.DEFAULT_LIMIT, kind);
+    }
+
+    public CompletableFuture<List<Reaction>> filter(LookupKind lookup, String id, Filter filter, Limit limit) throws StreamException {
+        return filter(lookup, id, filter, limit, "");
+    }
+
+    public CompletableFuture<List<Reaction>> filter(LookupKind lookup, String id, Limit limit, String kind) throws StreamException {
+        return filter(lookup, id, DefaultOptions.DEFAULT_FILTER, limit, kind);
     }
 
-    public CompletableFuture<List<Reaction>> filter(LookupKind lookup, String id, Filter filter, String kind) throws StreamException {
-        return reactions.filter(token, lookup, id, filter, kind);
+    public CompletableFuture<List<Reaction>> filter(LookupKind lookup, String id, Filter filter, Limit limit, String kind) throws StreamException {
+        return reactions.filter(token, lookup, id, filter, limit, kind);
     }
 
     public CompletableFuture<Reaction> add(String kind, String activityID, Iterable<FeedID> targetFeeds) throws StreamException {

src/main/java/io/getstream/core/StreamReactions.java

@@ -9,6 +9,7 @@
 import io.getstream.core.models.Reaction;
 import io.getstream.core.options.CustomQueryParameter;
 import io.getstream.core.options.Filter;
+import io.getstream.core.options.Limit;
 import io.getstream.core.options.RequestOption;
 
 import java.io.IOException;
@@ -58,7 +59,7 @@ public CompletableFuture<Reaction> get(Token token, String id) throws StreamExce
         }
     }
 
-    public CompletableFuture<List<Reaction>> filter(Token token, LookupKind lookup, String id, Filter filter, String kind) throws StreamException {
+    public CompletableFuture<List<Reaction>> filter(Token token, LookupKind lookup, String id, Filter filter, Limit limit, String kind) throws StreamException {
         checkNotNull(lookup, "Lookup kind can't be null");
         checkNotNull(id, "Reaction ID can't be null");
         checkArgument(!id.isEmpty(), "Reaction ID can't be empty");
@@ -69,7 +70,7 @@ public CompletableFuture<List<Reaction>> filter(Token token, LookupKind lookup,
             final URL url = buildReactionsURL(baseURL, lookup.getKind() + '/' + id + '/');
             RequestOption reactionType = new CustomQueryParameter("kind", kind);
             RequestOption withActivityData = new CustomQueryParameter("with_activity_data", Boolean.toString(lookup == LookupKind.ACTIVITY_WITH_DATA));
-            return httpClient.execute(buildGet(url, key, token, filter, reactionType, withActivityData))
+            return httpClient.execute(buildGet(url, key, token, filter, limit, reactionType, withActivityData))
                     .thenApply(response -> {
                         try {
                             return deserializeContainer(response, Reaction.class);