fix: fix tests

Author: itsmeadi

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

@@ -23,14 +23,14 @@ public class ModerationClient {
   }
 
   public CompletableFuture<Response> flagUser(
-      String flaggedUserId, String reason, Map<String, Object> options) throws StreamException {
-    return flag("stream:user", flaggedUserId, "", reason, options);
+      String flaggedUserId,String reportingUser, String reason, Map<String, Object> options) throws StreamException {
+    return flag("stream:user", flaggedUserId, reportingUser, reason, options);
   }
 
   public CompletableFuture<Response> flagActivity(
-      String entityId, String entityCreatorId, String reason, Map<String, Object> options)
+      String entityId, String reportingUser, String reason, Map<String, Object> options)
       throws StreamException {
-    return flag("stream:feeds:v2:activity", entityId, entityCreatorId, reason, options);
+    return flag("stream:feeds:v2:activity", entityId, reportingUser, reason, options);
   }
 
   public CompletableFuture<Response> flagReaction(

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

@@ -45,14 +45,10 @@ public CompletableFuture<Response> flag(
                 public final String reason = Reason;
               });
 
-        String strsing = new String(payload);
-        System.out.println(strsing);
-        final URL url = buildModerationFlagURL(baseURL);
+      final URL url = buildModerationFlagURL(baseURL);
       return httpClient.execute(buildPost(url, key, token, payload));
     } catch (JsonProcessingException | MalformedURLException | URISyntaxException e) {
       throw new CompletionException(e);
-    } catch (Exception e){
-        throw e;
     }
   }
 }

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

@@ -6,9 +6,7 @@
 import io.getstream.core.models.*;
 import io.getstream.core.models.Activity;
 
-import java.io.BufferedReader;
-import java.io.InputStreamReader;
-import java.nio.Buffer;
+import java.sql.Time;
 import java.util.Date;
 import java.util.UUID;
 import org.junit.*;
@@ -32,51 +30,50 @@ public void setUp() throws Exception {
   }
 
   @Test
-  public void testFlagUser() throws Exception {
-
+  public void testFlagActivity() throws Exception {
     ModerationClient moderationClient = client.moderation();
 
-    String userId = UUID.randomUUID().toString();
-    User user = client.user(userId);
-    user.getOrCreate().join();
-    Data result = user.get().join();
+    Activity activity = Activity.builder().actor("bad-user").verb("test").object("test").moderationTemplate("moderation_template_activity").time(new Date()).foreignID("fid").build();
+    Activity activityResponse = client.flatFeed("user", "1").addActivity(activity).join();
 
-    Response flagResponse = moderationClient.flagUser(userId, "blood", null).join();
+    String reportingUser="reporting-user";
+    Activity activity1 = Activity.builder().actor(reportingUser).verb("verb").object("test").moderationTemplate("moderation_template_activity").time(new Date()).foreignID("fid").build();
+    Activity activityResponse1 = client.flatFeed("user", "1").addActivity(activity1).join();
+    assertNotNull(activityResponse);
+
+    Response flagResponse =
+        moderationClient.flagActivity(activityResponse.getID(), reportingUser, "blood", null).join();
     assertNotNull(flagResponse);
+    assertEquals(201, flagResponse.getCode());
   }
 
   @Test
-  public void testFlagActivity() throws Exception {
-    ModerationClient moderationClient = client.moderation();
-
-    Activity activity = Activity.builder().actor("test").verb("test").object("test").build();
+  public void testFlagUser() throws Exception {
 
-    Activity activityResponse = client.flatFeed("flat", "1").addActivity(activity).join();
-    assertNotNull(activityResponse);
+    ModerationClient moderationClient = client.moderation();
 
-    Response flagResponse =
-        moderationClient.flagActivity(activityResponse.getID(), "vishal", "blood", null).join();
+    Response flagResponse = moderationClient.flagUser("bad-user", "reporting-user", "blood", null).join();
     assertNotNull(flagResponse);
+    assertEquals(201, flagResponse.getCode());
   }
 
   @Test
   public void testFlagReaction() throws Exception {
     ModerationClient moderationClient = client.moderation();
 
-    Activity activity = Activity.builder().actor("test").verb("test").object("test").build();
+    Activity activity = Activity.builder().actor("bad-user").verb("test").object("test").moderationTemplate("moderation_template_reaction").time(new Date()).foreignID("fid").build();
 
     Activity activityResponse = client.flatFeed("flat", "1").addActivity(activity).join();
     assertNotNull(activityResponse);
 
     Reaction reactionResponse =
-        client.reactions().add("test", "like", activityResponse.getID()).join();
+        client.reactions().add("bad-user", "like", activityResponse.getID()).join();
     assertNotNull(reactionResponse);
 
     Response flagResponse =
-        moderationClient.flagReaction(reactionResponse.getId(), "test", "blood", null).join();
+        moderationClient.flagReaction(reactionResponse.getId(), "reporting-user", "blood", null).join();
     assertNotNull(flagResponse);
     assertEquals(201, flagResponse.getCode());
-    assertNotNull(flagResponse);
 
   }