chore: add moderation template to reactions

Author: itsmeadi

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

@@ -235,6 +235,9 @@ public CompletableFuture<Reaction> add(
       if (reaction.getExtra() != null) {
         payloadBuilder.put("data", reaction.getExtra());
       }
+      if (reaction.getModerationTemplate() != null) {
+        payloadBuilder.put("moderation_template", reaction.getModerationTemplate());
+      }
       final byte[] payload = toJSON(payloadBuilder.build());
       final URL url = buildReactionsURL(baseURL);
       return httpClient

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

@@ -45,6 +45,7 @@ public String getOriginFeed() {
 class APIError {
     private String Code;
     private String Message;
+    private String Status;
 
     // Default constructor
     public APIError() {}
@@ -53,9 +54,11 @@ public APIError() {}
     @JsonCreator
     public APIError(
         @JsonProperty("code") String code,
-        @JsonProperty("message") String message) {
+        @JsonProperty("message") String message,
+        @JsonProperty("status") String status) {
         this.Code = code;
         this.Message = message;
+        this.Status = status;
     }
 
     // Getters

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

@@ -27,6 +27,8 @@ public class Reaction {
   private final Data userData;
   private final Map<String, Object> activityData;
   private final Map<String, Object> extra;
+  private String moderationTemplate;
+  private Map<String, Object> moderation;
 
   private Reaction(Builder builder) {
     id = builder.id;
@@ -41,6 +43,8 @@ private Reaction(Builder builder) {
     userData = builder.userData;
     activityData = builder.activityData;
     extra = builder.extra;
+    moderationTemplate = builder.moderationTemplate;
+    moderation = builder.moderation;
   }
 
   public String getId() {
@@ -95,6 +99,29 @@ public Map<String, Object> getExtra() {
     return extra;
   }
 
+  @JsonProperty("moderation_template")
+  public String getModerationTemplate() {
+    return moderationTemplate;
+  }
+
+  public void setModerationTemplate(String moderationTemplate) {
+    this.moderationTemplate = moderationTemplate;
+  }
+
+  @JsonProperty("moderation")
+  public Map<String, Object> getModeration() {
+    return moderation;
+  }
+
+  public ModerationResponse getModerationResponseFromMap()throws Exception {
+    String key = "response";
+    if (moderation != null && moderation.containsKey(key)) {
+      return convert(moderation.get(key), ModerationResponse.class);
+    } else {
+      throw new Exception("Key '" + key + "' not found in moderation map.");
+    }
+  }
+
   @Override
   public boolean equals(Object o) {
     if (this == o) return true;
@@ -111,7 +138,9 @@ public boolean equals(Object o) {
         && Objects.equals(childrenCounts, reaction.childrenCounts)
         && Objects.equals(userData, reaction.userData)
         && Objects.equals(activityData, reaction.activityData)
-        && Objects.equals(extra, reaction.extra);
+        && Objects.equals(extra, reaction.extra)
+        && Objects.equals(moderationTemplate, reaction.moderationTemplate)
+        && Objects.equals(moderation, reaction.moderation);
   }
 
   @Override
@@ -128,7 +157,9 @@ public int hashCode() {
         childrenCounts,
         userData,
         activityData,
-        extra);
+        extra,
+        moderationTemplate,
+        moderation);
   }
 
   @Override
@@ -146,6 +177,8 @@ public String toString() {
         .add("userData", this.userData)
         .add("activityData", this.activityData)
         .add("extra", this.extra)
+        .add("moderationTemplate", this.moderationTemplate)
+        .add("moderation", this.moderation)
         .toString();
   }
 
@@ -167,6 +200,8 @@ public static final class Builder {
     private Data userData;
     private Map<String, Object> activityData;
     private Map<String, Object> extra;
+    private String moderationTemplate;
+    private Map<String, Object> moderation;
 
     public Builder id(String id) {
       this.id = id;
@@ -239,6 +274,18 @@ public Builder activityData(Map<String, Object> activityData) {
       return this;
     }
 
+    @JsonProperty("moderation_template")
+    public Builder moderationTemplate(String moderationTemplate) {
+      this.moderationTemplate = moderationTemplate;
+      return this;
+    }
+
+    @JsonProperty("moderation")
+    public Builder moderation(Map<String, Object> moderation) {
+      this.moderation = moderation;
+      return this;
+    }
+
     @JsonIgnore
     public Builder extra(Map<String, Object> extra) {
       this.extra = extra;
@@ -259,6 +306,8 @@ public Builder fromReaction(Reaction reaction) {
       this.userData = reaction.userData;
       this.activityData = reaction.activityData;
       this.extra = reaction.extra;
+      this.moderationTemplate = reaction.moderationTemplate;
+      this.moderation = reaction.moderation;
       return this;
     }
 
@@ -271,4 +320,4 @@ public Reaction build() {
       return new Reaction(this);
     }
   }
-}
+}

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

@@ -1,22 +1,13 @@
 package io.getstream.client;
 
-import io.getstream.client.Client;
-import io.getstream.client.ModerationClient;
 import io.getstream.core.models.*;
 import io.getstream.core.models.Activity;
 import io.getstream.core.http.Response;
 import static org.junit.Assert.*;
-
-
-import java.net.MalformedURLException;
 import java.util.Date;
-import java.util.HashMap;
-import java.util.Map;
 import java.util.UUID;
-import java.util.concurrent.CompletableFuture;
 import org.junit.*;
 
-
 public class ModerationClientTest {
 
     private static final String apiKey =
@@ -28,10 +19,32 @@ public class ModerationClientTest {
                     ? System.getenv("STREAM_SECRET")
                     : System.getProperty("STREAM_SECRET");
 
+    Client client;
+    @Before
+    public void setUp()throws Exception {
+
+        System.out.println("api key-------------------------------------------------");
+        System.out.println(addSpacesAfterEachChar(apiKey));
+//        client =
+//                Client.builder(apiKey, secret)
+//                        .scheme("http")
+//                        .host("localhost")
+//                        .port(18000)
+//                        .build();
+        client= Client.builder(apiKey, secret).build();
+    }
+    public static String addSpacesAfterEachChar(String str) {
+        StringBuilder stringBuilder = new StringBuilder(); // Using StringBuilder for efficiency
+
+        for (int i = 0; i < str.length(); i++) {
+            stringBuilder.append(str.charAt(i)); // Append the character
+            stringBuilder.append(' '); // Append a space
+        }
 
+        return stringBuilder.toString().trim(); // Convert to string and remove the trailing space
+    }
     @Test
     public void testFlagUser() throws Exception {
-        Client client = Client.builder(apiKey, secret).build();
 
         ModerationClient moderationClient = client.moderation();
 
@@ -46,7 +59,6 @@ public void testFlagUser() throws Exception {
 
     @Test
     public void testFlagActivity() throws Exception {
-        Client client = Client.builder(apiKey, secret).build();
         ModerationClient moderationClient = client.moderation();
 
         Activity activity = Activity.builder().actor("test").verb("test").object("test").build();
@@ -60,7 +72,6 @@ public void testFlagActivity() throws Exception {
 
     @Test
     public void testFlagReaction() throws Exception {
-        Client client = Client.builder(apiKey, secret).build();
         ModerationClient moderationClient = client.moderation();
 
         Activity activity = Activity.builder().actor("test").verb("test").object("test").build();
@@ -77,8 +88,6 @@ public void testFlagReaction() throws Exception {
     @Test
     public void testActivityModerated() throws Exception {
 
-        Client client = Client.builder(apiKey, secret).build();
-
         ModerationClient moderationClient = client.moderation();
 
         String[] images = new String[] { "image1", "image2" };
@@ -99,4 +108,36 @@ public void testActivityModerated() throws Exception {
         assertEquals(m.getStatus(), "complete");
         assertEquals(m.getRecommendedAction(), "remove");
     }
+    @Test
+        public void testActivityModeratedReactions() throws Exception {
+
+            ModerationClient moderationClient = client.moderation();
+
+            String[] images = new String[] { "image1", "image2" };
+            Activity activity = Activity.builder().
+                    actor("test").
+                    verb("test").
+                    object("test").
+                    extraField("text", "pissoar").
+                    extraField("attachment", images).
+                    foreignID("for").
+                    time(new Date()).
+                    build();
+
+            Activity activityResponse = client.flatFeed("user", "1").addActivity(activity).join();
+            assertNotNull(activityResponse);
+
+            Reaction r=Reaction.builder().
+                        kind("like").
+                        activityID(activityResponse.getID()).
+                        userID("user123").
+                        extraField("p","pissoar").
+                        moderationTemplate("reaction_test_7").
+                        build();
+
+            Reaction reactionResponse = client.reactions().add("user", r).join();
+            ModerationResponse m=reactionResponse.getModerationResponseFromMap();
+            assertEquals(m.getStatus(), "complete");
+            assertEquals(m.getRecommendedAction(), "remove");
+        }
 }