Merge pull request #155 from GetStream/reaction_filter

[MOD-0]chore: reactionFilters add filterUserID

Author: itsmeadi

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

@@ -38,6 +38,13 @@ public CompletableFuture<List<Reaction>> filter(LookupKind lookup, String id)
     return filter(lookup, id, DefaultOptions.DEFAULT_FILTER, DefaultOptions.DEFAULT_LIMIT, "");
   }
 
+  public CompletableFuture<List<Reaction>> filter(
+          LookupKind lookup, String id, Filter filter, Limit limit, String kind, Boolean withOwnChildren, String filterUserID)
+          throws StreamException {
+    final Token token = buildReactionsToken(secret, TokenAction.READ);
+    return reactions.filter(token, lookup, id, filter, limit, kind, withOwnChildren, filterUserID);
+  }
+
   public CompletableFuture<List<Reaction>> filter(LookupKind lookup, String id, Limit limit)
       throws StreamException {
     return filter(lookup, id, DefaultOptions.DEFAULT_FILTER, limit, "");
@@ -74,7 +81,7 @@ public CompletableFuture<List<Reaction>> filter(
       LookupKind lookup, String id, Filter filter, Limit limit, String kind, Boolean withOwnChildren)
       throws StreamException {
     final Token token = buildReactionsToken(secret, TokenAction.READ);
-    return reactions.filter(token, lookup, id, filter, limit, kind, withOwnChildren);
+    return reactions.filter(token, lookup, id, filter, limit, kind, withOwnChildren, "");
   }
 
   public CompletableFuture<Paginated<Reaction>> paginatedFilter(LookupKind lookup, String id)

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

@@ -101,7 +101,7 @@ private CompletableFuture<List<Reaction>> filter(Params params) throws StreamExc
         params.getFilter(),
         params.getLimit(),
         params.getKind(),
-        params.getWithOwnChildren());
+        params.getWithOwnChildren(), "");
   }
 
   public CompletableFuture<Reaction> add(

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

@@ -87,17 +87,18 @@ public CompletableFuture<Paginated> getPaginated(Token token, String id) throws
   public CompletableFuture<List<Reaction>> filter(
       Token token, LookupKind lookup, String id, Filter filter, Limit limit, String kind)
       throws StreamException {
-    return filter(token, lookup, id, filter, limit, kind, null);
+    return filter(token, lookup, id, filter, limit, kind, null, "");
   }
 
   public CompletableFuture<List<Reaction>> filter(
-      Token token,
-      LookupKind lookup,
-      String id,
-      Filter filter,
-      Limit limit,
-      String kind,
-      Boolean withOwnChildren)
+          Token token,
+          LookupKind lookup,
+          String id,
+          Filter filter,
+          Limit limit,
+          String kind,
+          Boolean withOwnChildren,
+          String filterUserId)
       throws StreamException {
     checkNotNull(lookup, "Lookup kind can't be null");
     checkNotNull(id, "Reaction ID can't be null");
@@ -113,8 +114,12 @@ public CompletableFuture<List<Reaction>> filter(
       RequestOption ownChildren =
           new CustomQueryParameter(
               "withOwnChildren", Boolean.toString(withOwnChildren != null && withOwnChildren));
+      RequestOption filterByUser =
+          new CustomQueryParameter(
+              "filter_user_id", filterUserId);
+
       return httpClient
-          .execute(buildGet(url, key, token, filter, limit, withActivityData, ownChildren))
+          .execute(buildGet(url, key, token, filter, limit, withActivityData, ownChildren, filterByUser))
           .thenApply(
               response -> {
                 try {

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

@@ -6,8 +6,13 @@
 import io.getstream.core.models.Paginated;
 import io.getstream.core.models.Reaction;
 import java.util.List;
+
+import io.getstream.core.options.Filter;
+import io.getstream.core.options.Limit;
 import org.junit.Test;
 
+import static org.junit.Assert.assertEquals;
+
 public class ReactionsClientTest {
   private static final String apiKey =
       System.getenv("STREAM_KEY") != null
@@ -49,6 +54,37 @@ public void filter() throws Exception {
             .join();
   }
 
+  @Test
+  public void filterWithUserID() throws Exception {
+    Client client = Client.builder(apiKey, secret).build();
+
+    Activity activity =
+        client
+            .flatFeed("flat", "reactor")
+            .addActivity(Activity.builder().actor("this").verb("done").object("that").build())
+            .join();
+
+    client.reactions().add("user1", "like", activity.getID()).join();
+    client.reactions().add("user1", "comment", activity.getID()).join();
+    client.reactions().add("user1", "share", activity.getID()).join();
+    client.reactions().add("user2", "like", activity.getID()).join();
+    client.reactions().add("user2", "comment", activity.getID()).join();
+    client.reactions().add("user3", "comment", activity.getID()).join();
+
+    List<Reaction> result = client.reactions().filter(LookupKind.ACTIVITY, activity.getID(), new Filter(), new Limit(10), "",false,  "user1").join();
+    assertEquals(3, result.size());
+
+    result = client.reactions().filter(LookupKind.ACTIVITY, activity.getID(), new Filter(), new Limit(10), "like",false, "user1").join();
+    assertEquals(1, result.size());
+
+
+    result = client.reactions().filter(LookupKind.ACTIVITY, activity.getID(), new Filter(), new Limit(10), "",false, "user2").join();
+    assertEquals(2, result.size());
+
+    result = client.reactions().filter(LookupKind.ACTIVITY, activity.getID(), new Filter(), new Limit(10), "",false, "user3").join();
+    assertEquals(1, result.size());
+  }
+
   @Test
   public void pagedFilter() throws Exception {
     Client client = Client.builder(apiKey, secret).build();