chore: discard_actors

Author: itsmeadi

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

@@ -127,6 +127,29 @@ limit, offset, filter, DefaultOptions.DEFAULT_MARKER, new Ranking(ranking), rank
             });
   }
 
+  public CompletableFuture<List<Activity>> getActivities(RequestOption... options)
+      throws StreamException {
+    // If no options provided, use defaults
+    if (options == null || options.length == 0) {
+      options = new RequestOption[] {
+          DefaultOptions.DEFAULT_LIMIT,
+          DefaultOptions.DEFAULT_OFFSET,
+          DefaultOptions.DEFAULT_FILTER,
+          DefaultOptions.DEFAULT_MARKER
+      };
+    }
+    
+    return getClient()
+        .getActivities(getID(), options)
+        .thenApply(
+            response -> {
+              try {
+                return deserializeContainer(response, Activity.class);
+              } catch (StreamException | IOException e) {
+                throw new CompletionException(e);
+              }
+            });
+  }
 
   public <T> CompletableFuture<List<T>> getCustomActivities(Class<T> type) throws StreamException {
     return getCustomActivities(

src/main/java/io/getstream/core/options/DiscardActors.java

@@ -0,0 +1,41 @@
+package io.getstream.core.options;
+
+import static com.google.common.base.Preconditions.checkNotNull;
+
+import io.getstream.core.http.Request;
+import java.util.List;
+
+public final class DiscardActors implements RequestOption {
+  private final String actors;
+  private final String separator;
+
+  public DiscardActors(String... actors) {
+    this(actors, ",");
+  }
+
+  public DiscardActors(List<String> actors) {
+    this(actors, ",");
+  }
+
+  public DiscardActors(String[] actors, String separator) {
+    checkNotNull(actors, "Actors list cannot be null");
+    this.actors = String.join(separator != null ? separator : ",", actors);
+    this.separator = separator;
+  }
+
+  public DiscardActors(List<String> actors, String separator) {
+    checkNotNull(actors, "Actors list cannot be null");
+    this.actors = String.join(separator != null ? separator : ",", actors);
+    this.separator = separator;
+  }
+
+  @Override
+  public void apply(Request.Builder builder) {
+    if (actors != null && !actors.isEmpty()) {
+      builder.addQueryParameter("discard_actors", actors);
+      if (separator != null && !separator.equals(",")) {
+        builder.addQueryParameter("discard_actors_sep", separator);
+      }
+    }
+  }
+}

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

@@ -7,7 +7,11 @@
 import io.getstream.core.models.Activity;
 import io.getstream.core.models.Data;
 import io.getstream.core.models.EnrichedActivity;
+import io.getstream.core.options.DiscardActors;
 import io.getstream.core.options.EnrichmentFlags;
+import io.getstream.core.options.Filter;
+import io.getstream.core.options.Limit;
+import io.getstream.core.options.Offset;
 import java.util.Collections;
 import java.util.List;
 import java8.util.concurrent.CompletionException;
@@ -101,6 +105,60 @@ public void invalidFeedType() throws Exception {
             .build();
 
     FlatFeed feed = client.flatFeed("aggregated", "1");
-    List<Activity> result = feed.getActivities().join();
+    feed.getActivities().join();
+  }
+
+
+  @Test
+  public void testDiscardActorsOptions() {
+    // Test DiscardActors with array
+    DiscardActors discardActors1 = new DiscardActors("user1", "user2", "user3");
+    
+    // Test DiscardActors with List
+    List<String> actors = java.util.Arrays.asList("user4", "user5");
+    DiscardActors discardActors2 = new DiscardActors(actors);
+    
+    // Test DiscardActors with custom separator
+    DiscardActors discardActors3 = new DiscardActors(new String[]{"user6", "user7"}, ";");
+    
+    // Test DiscardActors with List and custom separator
+    DiscardActors discardActors4 = new DiscardActors(actors, "|");
+    
+    // Basic validation that objects were created
+    assert discardActors1 != null;
+    assert discardActors2 != null;
+    assert discardActors3 != null;
+    assert discardActors4 != null;
+  }
+
+  @Test
+  public void testGetActivitiesWithRequestOptions() throws Exception {
+    Client client =
+        Client.builder(apiKey, secret)
+            .httpClient(new OKHTTPClientAdapter(new OkHttpClient()))
+            .build();
+
+    FlatFeed feed = client.flatFeed("flat", "test-request-options");
+    
+    // Test with just DiscardActors
+    DiscardActors discardActors = new DiscardActors("actor1", "actor2", "actor3");
+    List<Activity> result1 = feed.getActivities(discardActors).join();
+    assert result1 != null;
+    
+    // Test with DiscardActors + Limit + Filter
+    List<String> actors = java.util.Arrays.asList("actor4", "actor5");
+    DiscardActors discardActors2 = new DiscardActors(actors);
+    Filter filter = new Filter().refresh();
+    List<Activity> result2 = feed.getActivities(new Limit(10), filter, discardActors2).join();
+    assert result2 != null;
+    
+    // Test with all parameters
+    List<Activity> result3 = feed.getActivities(
+        new Limit(20), 
+        new Offset(5), 
+        new Filter().refresh(), 
+        new DiscardActors("actor6", "actor7")
+    ).join();
+    assert result3 != null;
   }
 }