chore: delete batch reactions

Author: itsmeadi

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

@@ -371,6 +371,11 @@ public CompletableFuture<Object> deleteActivities(BatchDeleteActivitiesRequest r
     return stream.deleteActivities(token, request);
   }
 
+  public CompletableFuture<Object> deleteReactions(BatchDeleteReactionsRequest request) throws StreamException {
+    final Token token = buildDataPrivacyToken(secret, Auth.TokenAction.WRITE);
+    return stream.deleteReactions(token, request);
+  }
+
   public CompletableFuture<ExportIDsResponse> exportUserActivities(String userId) throws StreamException {
     final Token token = buildDataPrivacyToken(secret, Auth.TokenAction.READ);
     return stream.exportUserActivities(token, userId);

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

@@ -528,8 +528,8 @@ public CompletableFuture<Response> updateUser(Token token, String userID, Data u
 
   public CompletableFuture<Object> deleteActivities(Token token, BatchDeleteActivitiesRequest request) throws StreamException {
     try {
-//            final URL url = deleteActivitiesURL(baseURL);
-      final URL url = deleteActivitiesURL(new URL("https://oregon-api.stream-io-api.com"));//$$ need to deploy proxy
+            final URL url = deleteActivitiesURL(baseURL);
+//      final URL url = deleteActivitiesURL(new URL("https://oregon-api.stream-io-api.com"));//$$ need to deploy proxy
 
       final byte[] payload = toJSON(request);
       io.getstream.core.http.Request httpRequest = buildPost(url, key, token, payload);
@@ -539,14 +539,30 @@ public CompletableFuture<Object> deleteActivities(Token token, BatchDeleteActivi
     }
   }
 
+  public CompletableFuture<Object> deleteReactions(Token token, BatchDeleteReactionsRequest request) throws StreamException {
+    try {
+      final URL url = deleteReactionsURL(baseURL);
+//      final URL url = deleteReactionsURL(new URL("https://oregon-api.stream-io-api.com"));//$$ need to deploy proxy
+
+      final byte[] payload = toJSON(request);
+      io.getstream.core.http.Request httpRequest = buildPost(url, key, token, payload);
+
+      //print the response
+
+      return httpClient.execute(httpRequest).thenApply(response -> null);
+    } catch (Exception e) {
+      throw new StreamException(e);
+    }
+  }
+
   public CompletableFuture<ExportIDsResponse> exportUserActivities(Token token, String userId) throws StreamException {
     if (userId == null || userId.isEmpty()) {
       throw new IllegalArgumentException("User ID can't be null or empty");
     }
 
     try {
-//            final URL url = buildExportIDsURL(baseURL, userId);
-      final URL url = buildExportIDsURL(new URL("https://oregon-api.stream-io-api.com"), userId);//$$ need to deploy proxy
+            final URL url = buildExportIDsURL(baseURL, userId);
+//      final URL url = buildExportIDsURL(new URL("https://oregon-api.stream-io-api.com"), userId);//$$ need to deploy proxy
       io.getstream.core.http.Request request = buildGet(url, key, token);
       return httpClient
               .execute(request)

src/main/java/io/getstream/core/utils/Routes.java

@@ -30,6 +30,7 @@ public final class Routes {
 
   private static final String exportIDsPath = "data_privacy/export_ids/";
   private static final String deleteActivitiesPath = "data_privacy/delete_activities/";
+  private static final String deleteReactionsPath = "data_privacy/delete_reactions/";
 
   private Routes() {
     /* nothing to see here */
@@ -129,6 +130,10 @@ public static URL deleteActivitiesURL(URL baseURL) throws MalformedURLException
     return new URL(baseURL, basePath + deleteActivitiesPath);
   }
 
+  public static URL deleteReactionsURL(URL baseURL) throws MalformedURLException {
+    return new URL(baseURL, basePath + deleteReactionsPath);
+  }
+
   public static URL followStatsPath(URL baseURL) throws MalformedURLException {
     return new URL(baseURL, basePath + followStatsPath);
   }

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

@@ -3,9 +3,12 @@
 import static org.junit.Assert.*;
 
 import com.google.common.collect.Lists;
+import io.getstream.core.http.Response;
 import io.getstream.core.models.BatchDeleteActivitiesRequest;
 import io.getstream.core.models.BatchDeleteActivitiesRequest.ActivityToDelete;
 import io.getstream.core.models.Activity;
+import io.getstream.core.models.BatchDeleteReactionsRequest;
+import io.getstream.core.models.Reaction;
 import io.getstream.core.options.Filter;
 import io.getstream.core.options.Limit;
 import java8.util.concurrent.CompletableFuture;
@@ -83,6 +86,71 @@ public void testDeleteActivities() throws Exception {
         assertEquals(0, deletedActivity2.size());
     }
 
+    @Test
+    public void testDeleteReactions() throws Exception {
+        String uuid1 = UUID.randomUUID().toString().replace("-", "");
+        FlatFeed feed = client.flatFeed("user", uuid1);
+
+        // Insert some activities
+        Activity activity1 = Activity.builder()
+                .actor("user1")
+                .verb("post")
+                .object("object1")
+                .build();
+        Activity activity1Res = feed.addActivity(activity1).join();
+
+        Activity activity2 = Activity.builder()
+                .actor("user1")
+                .verb("like")
+                .object("object2")
+                .build();
+        Activity activity2Res = feed.addActivity(activity2).join();
+
+        //add reactions for activity1
+        Reaction u1=client.reactions().add("user1", "like", activity1Res.getID()).join();
+        Reaction u2=client.reactions().add("user2", "like", activity1Res.getID()).join();
+
+        Reaction u3=client.reactions().add("user1", "like", activity2Res.getID()).join();
+        Reaction u4=client.reactions().add("user2", "like", activity2Res.getID()).join();
+
+
+        //fetch test reactions
+        Reaction r1=client.reactions().get(u1.getId()).join();
+        assertNotNull(r1);
+
+        Reaction r2=client.reactions().get(u2.getId()).join();
+        assertNotNull(r2);
+
+        Reaction r3=client.reactions().get(u3.getId()).join();
+        assertNotNull(r3);
+
+        Reaction r4=client.reactions().get(u4.getId()).join();
+        assertNotNull(r4);
+
+        // Create reaction delete request
+        BatchDeleteReactionsRequest deleteReactionsRequest=
+                new BatchDeleteReactionsRequest(Arrays.asList
+                        (u1.getId(), u2.getId(), u3.getId()));
+
+
+        client.deleteReactions(deleteReactionsRequest).join();
+
+        //fetch test reactions
+
+        // DoesNotExistException
+        assertThrows(Exception.class, () -> {
+            client.reactions().get(u1.getId()).join();
+        });
+        assertThrows(Exception.class, () -> {
+            client.reactions().get(u2.getId()).join();
+        });
+        assertThrows(Exception.class, () -> {
+            client.reactions().get(u3.getId()).join();
+        });
+
+
+    }
+
     @Test
     public void testDeleteActivitis() throws Exception {