[SDKS-7514] Add flagSetFilter config

client/src/main/java/io/split/client/SplitClientConfig.java

@@ -9,6 +9,9 @@
 import pluggable.CustomStorageWrapper;
 
 import java.io.IOException;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.List;
 import java.util.Properties;
 import java.util.concurrent.ThreadFactory;
 
@@ -80,6 +83,7 @@ public class SplitClientConfig {
     // To be set during startup
     public static String splitSdkVersion;
     private final long _lastSeenCacheSize;
+    private final List<String> _flagSetsFilter;
 
 
     public static Builder builder() {
@@ -133,7 +137,8 @@ private SplitClientConfig(String endpoint,
                               int uniqueKeysRefreshRateRedis,
                               int filterUniqueKeysRefreshRate,
                               long lastSeenCacheSize,
-                              ThreadFactory threadFactory) {
+                              ThreadFactory threadFactory,
+                              List<String> flagSetsFilter) {
         _endpoint = endpoint;
         _eventsEndpoint = eventsEndpoint;
         _featuresRefreshRate = pollForFeatureChangesEveryNSeconds;
@@ -182,6 +187,7 @@ private SplitClientConfig(String endpoint,
         _customStorageWrapper = customStorageWrapper;
         _lastSeenCacheSize = lastSeenCacheSize;
         _threadFactory = threadFactory;
+        _flagSetsFilter = flagSetsFilter;
 
 
         Properties props = new Properties();
@@ -363,6 +369,9 @@ public long getLastSeenCacheSize() {
     public ThreadFactory getThreadFactory() {
         return _threadFactory;
     }
+    public List<String> getSetsFilter() {
+        return _flagSetsFilter;
+    }
 
     public static final class Builder {
 
@@ -417,6 +426,7 @@ public static final class Builder {
         private StorageMode _storageMode = StorageMode.MEMORY;
         private final long _lastSeenCacheSize = 500000;
         private ThreadFactory _threadFactory;
+        private List<String> _flagSetsFilter = Collections.emptyList();
 
         public Builder() {
         }
@@ -882,6 +892,18 @@ public Builder customStorageWrapper(CustomStorageWrapper customStorageWrapper) {
             return this;
         }
 
+        /**
+         * Flag Sets Filter
+         *
+         * @param flagSetsFilter
+         * @return this builder
+         */
+        public Builder flagSetsFilter(List<String> flagSetsFilter) {
+            _flagSetsFilter = flagSetsFilter;
+            //TODO Apply validations
+            return this;
+        }
+
         public SplitClientConfig build() {
             if (_featuresRefreshRate < 5 ) {
                 throw new IllegalArgumentException("featuresRefreshRate must be >= 5: " + _featuresRefreshRate);
@@ -1027,7 +1049,8 @@ public SplitClientConfig build() {
                     _uniqueKeysRefreshRateRedis,
                     _filterUniqueKeysRefreshRate,
                     _lastSeenCacheSize,
-                    _threadFactory);
+                    _threadFactory,
+                    _flagSetsFilter);
         }
     }
 }

client/src/test/java/io/split/client/SplitClientConfigTest.java

@@ -8,6 +8,11 @@
 import org.junit.Assert;
 import org.junit.Test;
 
+import java.util.ArrayList;
+import java.util.List;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+
 import static org.hamcrest.MatcherAssert.assertThat;
 import static org.hamcrest.Matchers.equalTo;
 import static org.hamcrest.Matchers.is;
@@ -182,9 +187,17 @@ public void streamingReconnectBackoffBaseAllowed() {
     }
 
     @Test
-    public void checkDefaultRateForFeatureAndSegment(){
+    public void checkDefaultRateForFeatureAndSegment() {
         SplitClientConfig config = SplitClientConfig.builder().build();
         Assert.assertEquals(60, config.featuresRefreshRate());
         Assert.assertEquals(60, config.segmentsRefreshRate());
     }
+
+    @Test
+    public void checkSetFlagSetsFilter() {
+        List<String> sets = Stream.of("test1", "test2").collect(Collectors.toList());
+        SplitClientConfig config = SplitClientConfig.builder().flagSetsFilter(sets).build();
+        Assert.assertNotNull(config.getSetsFilter());
+        Assert.assertEquals(2, config.getSetsFilter().size());
+    }
 }