Updated commons version and added test cases

Author: nmayorsplit

go.mod

@@ -3,8 +3,9 @@ module github.com/splitio/go-client/v6
 go 1.18
 
 require (
-	github.com/splitio/go-split-commons/v6 v6.1.0
+	github.com/splitio/go-split-commons/v6 v6.1.1-0.20250828154055-c4035408fe61
 	github.com/splitio/go-toolkit/v5 v5.4.0
+
 )
 
 require (
@@ -13,6 +14,7 @@ require (
 	github.com/cespare/xxhash/v2 v2.2.0 // indirect
 	github.com/davecgh/go-spew v1.1.1 // indirect
 	github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f // indirect
+	github.com/kr/text v0.2.0 // indirect
 	github.com/pmezard/go-difflib v1.0.0 // indirect
 	github.com/redis/go-redis/v9 v9.0.4 // indirect
 	github.com/stretchr/objx v0.5.2 // indirect

go.sum

@@ -6,16 +6,20 @@ github.com/bsm/ginkgo/v2 v2.7.0 h1:ItPMPH90RbmZJt5GtkcNvIRuGEdwlBItdNVoyzaNQao=
 github.com/bsm/gomega v1.26.0 h1:LhQm+AFcgV2M0WyKroMASzAzCAJVpAxQXv4SaI9a69Y=
 github.com/cespare/xxhash/v2 v2.2.0 h1:DC2CZ1Ep5Y4k3ZQ899DldepgrayRUGE6BBZ/cd9Cj44=
 github.com/cespare/xxhash/v2 v2.2.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
+github.com/creack/pty v1.1.9/go.mod h1:oKZEueFk5CKHvIhNR5MUki03XCEU+Q6VDXinZuGJ33E=
 github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=
 github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=
 github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f h1:lO4WD4F/rVNCu3HqELle0jiPLLBs70cWOduZpkS1E78=
 github.com/dgryski/go-rendezvous v0.0.0-20200823014737-9f7001d12a5f/go.mod h1:cuUVRXasLTGF7a8hSLbxyZXjz+1KgoB3wDUb6vlszIc=
+github.com/kr/pretty v0.1.0 h1:L/CwN0zerZDmRFUapSPitk6f+Q3+0za1rQkzVuMiMFI=
+github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
+github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
 github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
 github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
 github.com/redis/go-redis/v9 v9.0.4 h1:FC82T+CHJ/Q/PdyLW++GeCO+Ol59Y4T7R4jbgjvktgc=
 github.com/redis/go-redis/v9 v9.0.4/go.mod h1:WqMKv5vnQbRuZstUwxQI195wHy+t4PuXDOjzMvcuQHk=
-github.com/splitio/go-split-commons/v6 v6.1.0 h1:k3mwr12DF6gbEaV8XXU/tSAQlPkIEuzIgTEneYhGg2I=
-github.com/splitio/go-split-commons/v6 v6.1.0/go.mod h1:D/XIY/9Hmfk9ivWsRsJVp439kEdmHbzUi3PKzQQDOXY=
+github.com/splitio/go-split-commons/v6 v6.1.1-0.20250828154055-c4035408fe61 h1:xFXSVWXsaWRIfHCNtsvqDrLULBWnF8SOpkv045CXibI=
+github.com/splitio/go-split-commons/v6 v6.1.1-0.20250828154055-c4035408fe61/go.mod h1:cuW2HjbJJCVjlmmgJyoTs5UFxz8ET8vCgMUvZg1/EBg=
 github.com/splitio/go-toolkit/v5 v5.4.0 h1:g5WFpRhQomnXCmvfsNOWV4s5AuUrWIZ+amM68G8NBKM=
 github.com/splitio/go-toolkit/v5 v5.4.0/go.mod h1:xYhUvV1gga9/1029Wbp5pjnR6Cy8nvBpjw99wAbsMko=
 github.com/stretchr/objx v0.5.2 h1:xuMeJ0Sdp5ZMRXx/aWO6RZxdr3beISkG5/G/aIRr3pY=
@@ -28,7 +32,7 @@ golang.org/x/exp v0.0.0-20231006140011-7918f672742d h1:jtJma62tbqLibJ5sFQz8bKtEM
 golang.org/x/exp v0.0.0-20231006140011-7918f672742d/go.mod h1:ldy0pHrwJyGW56pPQzzkH36rKxoZW1tw7ZJpeKx+hdo=
 golang.org/x/sync v0.3.0 h1:ftCYgMx6zT/asHUrPw8BLLscYtGznsLAnjq5RH9P66E=
 golang.org/x/sync v0.3.0/go.mod h1:FU7BRWz2tNW+3quACPkgCx/L+uEAv1htQ0V83Z9Rj+Y=
-gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
+gopkg.in/check.v1 v1.0.0-20190902080502-41f04d3bba15 h1:YR8cESwS4TdDjEe65xsg0ogRM/Nc3DYOhEAlW+xobZo=
 gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
 gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

splitio/client/client_test.go

@@ -1011,9 +1011,11 @@ func TestBlockUntilReadyInMemoryOk(t *testing.T) {
 		}
 
 		splitChanges := dtos.SplitChangesDTO{
-			Splits: []dtos.SplitDTO{mockedSplit1, mockedSplit2, mockedSplit3},
-			Since:  3,
-			Till:   3,
+			FeatureFlags: dtos.FeatureFlagsDTO{
+				Splits: []dtos.SplitDTO{mockedSplit1, mockedSplit2, mockedSplit3},
+				Since:  3,
+				Till:   3,
+			},
 		}
 
 		raw, err := json.Marshal(splitChanges)
@@ -1362,6 +1364,7 @@ func TestClient(t *testing.T) {
 			},
 		},
 		nil,
+		nil,
 		logger,
 	)
 
@@ -2222,7 +2225,7 @@ func TestUnsupportedMatcherAndSemver(t *testing.T) {
 	ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
 		switch r.URL.Path {
 		case "/api/v2/auth":
-			if r.URL.Query().Get("s") != "1.1" {
+			if r.URL.Query().Get("s") != "1.3" {
 				t.Error("should be parameter s, for flags spec")
 			}
 			fmt.Fprintln(w, "{\"pushEnabled\": false, \"token\": \"token\"}")
@@ -2329,6 +2332,103 @@ func TestUnsupportedMatcherAndSemver(t *testing.T) {
 	}
 }
 
+func TestRuleBasedSegmentMatcher(t *testing.T) {
+	var isDestroyCalled = false
+	var splitsMock, _ = ioutil.ReadFile("../../testdata/splits_mock_4.json")
+
+	postChannel := make(chan string, 1)
+
+	ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
+		switch r.URL.Path {
+		case "/api/v2/auth":
+			if r.URL.Query().Get("s") != "1.3" {
+				t.Error("should be parameter s, for flags spec")
+			}
+			fmt.Fprintln(w, "{\"pushEnabled\": false, \"token\": \"token\"}")
+			return
+		case "/splitChanges":
+			fmt.Fprintln(w, string(splitsMock))
+			return
+		case "/testImpressions/bulk":
+			if r.Header.Get("SplitSDKImpressionsMode") != commonsCfg.ImpressionsModeOptimized {
+				t.Error("Wrong header")
+			}
+
+			if isDestroyCalled {
+				rBody, _ := ioutil.ReadAll(r.Body)
+				var dataInPost []map[string]interface{}
+				err := json.Unmarshal(rBody, &dataInPost)
+				if err != nil {
+					t.Error(err)
+					return
+				}
+				if len(dataInPost) != 1 {
+					t.Error("It should send one impressions in optimized mode")
+				}
+				for _, ki := range dataInPost {
+					if asISlice, ok := ki["i"].([]interface{}); !ok || len(asISlice) != 1 {
+						t.Error("It should send only one impression per featureName", dataInPost)
+					}
+					if ki["f"] == "unsupported" {
+						message := ki["i"].([]interface{})[0].(map[string]interface{})["r"]
+						if message != "targeting rule type unsupported by sdk" {
+							t.Error("message sould be: targeting rule type unsupported by sdk")
+						}
+					}
+				}
+			}
+
+			fmt.Fprintln(w, "ok")
+			postChannel <- "finished"
+		case "/testImpressions/count":
+			fallthrough
+		case "/keys/ss":
+			fallthrough
+		case "/events/bulk":
+			fallthrough
+		case "/segmentChanges":
+		default:
+			fmt.Fprintln(w, "ok")
+			return
+		}
+	}))
+	defer ts.Close()
+
+	cfg := conf.Default()
+	cfg.Advanced.AuthServiceURL = ts.URL
+	cfg.Advanced.EventsURL = ts.URL
+	cfg.Advanced.SdkURL = ts.URL
+	cfg.Advanced.TelemetryServiceURL = ts.URL
+
+	factory, _ := NewSplitFactory("test", cfg)
+	client := factory.Client()
+	client.BlockUntilReady(100)
+
+	// Calls treatments to generate one valid impression
+	time.Sleep(300 * time.Millisecond) // Let's wait until first call of recorders have finished
+	attributes := make(map[string]interface{})
+	attributes["email"] = "test@split.io"
+	evaluation := client.Treatment("user1", "rbs_split", attributes)
+	if evaluation != "on" {
+		t.Error("evaluation for semver should be on")
+	}
+	evaluation = client.Treatment("user1", "unsupported", nil)
+	if evaluation != "control" {
+		t.Error("evaluation for unsupported should be control")
+	}
+
+	isDestroyCalled = true
+	client.Destroy()
+
+	select {
+	case <-postChannel:
+		return
+	case <-time.After(4 * time.Second):
+		t.Error("The test couldn't send impressions to check headers")
+		return
+	}
+}
+
 func TestTelemetryMemory(t *testing.T) {
 	factoryInstances = make(map[string]int64)
 	var metricsInitCalled int64
@@ -2337,14 +2437,15 @@ func TestTelemetryMemory(t *testing.T) {
 	sdkServer := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
 		time.Sleep(100 * time.Millisecond)
 		splitChanges := dtos.SplitChangesDTO{
-			Splits: []dtos.SplitDTO{
-				{Name: "split1", Killed: true, Status: "ACTIVE", DefaultTreatment: "on"},
-				{Name: "split2", Killed: true, Status: "ACTIVE"},
-				{Name: "split3", Killed: true, Status: "INACTIVE"},
-			},
-			Since: 3,
-			Till:  3,
-		}
+			FeatureFlags: dtos.FeatureFlagsDTO{
+				Splits: []dtos.SplitDTO{
+					{Name: "split1", Killed: true, Status: "ACTIVE", DefaultTreatment: "on"},
+					{Name: "split2", Killed: true, Status: "ACTIVE"},
+					{Name: "split3", Killed: true, Status: "INACTIVE"},
+				},
+				Since: 3,
+				Till:  3,
+			}}
 
 		raw, err := json.Marshal(splitChanges)
 		if err != nil {

splitio/client/factory.go

@@ -52,6 +52,7 @@ const (
 type sdkStorages struct {
 	splits              storage.SplitStorageConsumer
 	segments            storage.SegmentStorageConsumer
+	ruleBasedSegments   storage.RuleBasedSegmentStorageConsumer
 	impressionsConsumer storage.ImpressionStorageConsumer
 	impressions         storage.ImpressionStorageProducer
 	events              storage.EventStorageProducer
@@ -83,7 +84,7 @@ type SplitFactory struct {
 func (f *SplitFactory) Client() *SplitClient {
 	return &SplitClient{
 		logger:      f.logger,
-		evaluator:   evaluator.NewEvaluator(f.storages.splits, f.storages.segments, engine.NewEngine(f.logger), f.logger),
+		evaluator:   evaluator.NewEvaluator(f.storages.splits, f.storages.segments, f.storages.ruleBasedSegments, engine.NewEngine(f.logger), f.logger),
 		impressions: f.storages.impressions,
 		events:      f.storages.events,
 		validator: inputValidation{
@@ -275,8 +276,8 @@ func setupInMemoryFactory(
 	metadata dtos.Metadata,
 ) (*SplitFactory, error) {
 	advanced, warnings := conf.NormalizeSDKConf(cfg.Advanced)
-	advanced.AuthSpecVersion = specs.FLAG_V1_1
-	advanced.FlagsSpecVersion = specs.FLAG_V1_1
+	advanced.AuthSpecVersion = specs.FLAG_V1_3
+	advanced.FlagsSpecVersion = specs.FLAG_V1_3
 	printWarnings(logger, warnings)
 	flagSetsInvalid := int64(len(cfg.Advanced.FlagSetsFilter) - len(advanced.FlagSetsFilter))
 	if strings.TrimSpace(cfg.SplitSyncProxyURL) != "" {
@@ -288,6 +289,7 @@ func setupInMemoryFactory(
 	flagSetFilter := flagsets.NewFlagSetFilter(advanced.FlagSetsFilter)
 	splitsStorage := mutexmap.NewMMSplitStorage(flagSetFilter)
 	segmentsStorage := mutexmap.NewMMSegmentStorage()
+	ruleBasedSegmentStorage := mutexmap.NewRuleBasedSegmentsStorage()
 	telemetryStorage, err := inmemory.NewTelemetryStorage()
 	impressionsStorage := mutexqueue.NewMQImpressionsStorage(cfg.Advanced.ImpressionsQueueSize, inMememoryFullQueue, logger, telemetryStorage)
 	eventsStorage := mutexqueue.NewMQEventsStorage(cfg.Advanced.EventsQueueSize, inMememoryFullQueue, logger, telemetryStorage)
@@ -299,7 +301,7 @@ func setupInMemoryFactory(
 
 	splitAPI := api.NewSplitAPI(apikey, advanced, logger, metadata)
 	workers := synchronizer.Workers{
-		SplitUpdater:      split.NewSplitUpdater(splitsStorage, splitAPI.SplitFetcher, logger, telemetryStorage, dummyHC, flagSetFilter),
+		SplitUpdater:      split.NewSplitUpdater(splitsStorage, ruleBasedSegmentStorage, splitAPI.SplitFetcher, logger, telemetryStorage, dummyHC, flagSetFilter),
 		SegmentUpdater:    segment.NewSegmentUpdater(splitsStorage, segmentsStorage, splitAPI.SegmentFetcher, logger, telemetryStorage, dummyHC),
 		EventRecorder:     event.NewEventRecorderSingle(eventsStorage, splitAPI.EventRecorder, logger, metadata, telemetryStorage),
 		TelemetryRecorder: telemetry.NewTelemetrySynchronizer(telemetryStorage, splitAPI.TelemetryRecorder, splitsStorage, segmentsStorage, logger, metadata, telemetryStorage),
@@ -317,6 +319,7 @@ func setupInMemoryFactory(
 		impressionsConsumer: impressionsStorage,
 		impressions:         impressionsStorage,
 		segments:            segmentsStorage,
+		ruleBasedSegments:   ruleBasedSegmentStorage,
 		initTelemetry:       telemetryStorage,
 		evaluationTelemetry: telemetryStorage,
 		runtimeTelemetry:    telemetryStorage,
@@ -468,6 +471,7 @@ func setupLocalhostFactory(
 	flagSetFilter := flagsets.NewFlagSetFilter(flagSets)
 	splitStorage := mutexmap.NewMMSplitStorage(flagSetFilter)
 	segmentStorage := mutexmap.NewMMSegmentStorage()
+	ruleBasedSegmentStorage := mutexmap.NewRuleBasedSegmentsStorage()
 	telemetryStorage, err := inmemory.NewTelemetryStorage()
 	if err != nil {
 		return nil, err
@@ -492,7 +496,7 @@ func setupLocalhostFactory(
 	}
 
 	syncManager, err := synchronizer.NewSynchronizerManager(
-		synchronizer.NewLocal(localConfig, splitAPI, splitStorage, segmentStorage, logger, telemetryStorage, dummyHC),
+		synchronizer.NewLocal(localConfig, splitAPI, splitStorage, segmentStorage, ruleBasedSegmentStorage, logger, telemetryStorage, dummyHC),
 		logger,
 		config.AdvancedConfig{StreamingEnabled: false},
 		nil,
@@ -518,6 +522,7 @@ func setupLocalhostFactory(
 			splits:              splitStorage,
 			impressions:         mutexqueue.NewMQImpressionsStorage(cfg.Advanced.ImpressionsQueueSize, make(chan string, 1), logger, telemetryStorage),
 			events:              mutexqueue.NewMQEventsStorage(cfg.Advanced.EventsQueueSize, make(chan string, 1), logger, telemetryStorage),
+			ruleBasedSegments:   ruleBasedSegmentStorage,
 			segments:            segmentStorage,
 			initTelemetry:       telemetryStorage,
 			evaluationTelemetry: telemetryStorage,

splitio/client/input_validator_test.go

@@ -356,7 +356,7 @@ func TestValidatorOnDestroy(t *testing.T) {
 	logger := getMockedLogger()
 	localConfig := &synchronizer.LocalConfig{RefreshEnabled: false}
 	sync, _ := synchronizer.NewSynchronizerManager(
-		synchronizer.NewLocal(localConfig, &api.SplitAPI{}, mocks.MockSplitStorage{}, mocks.MockSegmentStorage{}, logger, telemetryMockedStorage, &application.Dummy{}),
+		synchronizer.NewLocal(localConfig, &api.SplitAPI{}, mocks.MockSplitStorage{}, mocks.MockSegmentStorage{}, &mocks.MockRuleBasedSegmentStorage{}, logger, telemetryMockedStorage, &application.Dummy{}),
 		logger,
 		commonsCfg.AdvancedConfig{},
 		authMocks.MockAuthClient{},
@@ -533,7 +533,7 @@ func TestInMemoryFactoryFlagSets(t *testing.T) {
 	ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
 		switch r.URL.Path {
 		case "/splitChanges":
-			if r.RequestURI != "/splitChanges?s=1.1&since=-1&sets=a%2Cc%2Cd" {
+			if r.RequestURI != "/splitChanges?s=1.3&since=-1&rbSince=-1&sets=a%2Cc%2Cd" {
 				t.Error("wrong RequestURI for flag sets")
 			}
 			fmt.Fprintln(w, fmt.Sprintf(string(splitsMock), splitMock))

testdata/splits.json

@@ -1 +1 @@
-{"till":300,"since":-1,"splits":[{"changeNumber":1660326991072,"trafficTypeName":"user","name":"feature_flag_1","trafficAllocation":100,"trafficAllocationSeed":-1364119282,"seed":-605938843,"status":"ACTIVE","killed":false,"defaultTreatment":"off","algo":2,"conditions":[{"conditionType":"ROLLOUT","matcherGroup":{"combiner":"AND","matchers":[{"keySelector":{"trafficType":"user","attribute":null},"matcherType":"ALL_KEYS","negate":false,"userDefinedSegmentMatcherData":null,"whitelistMatcherData":null,"unaryNumericMatcherData":null,"betweenMatcherData":null,"dependencyMatcherData":null,"booleanMatcherData":null,"stringMatcherData":null}]},"partitions":[{"treatment":"on","size":100},{"treatment":"off","size":0}],"label":"default rule"}],"configurations":{}},{"changeNumber":1683928900842,"trafficTypeName":"user","name":"feature_flag_2","trafficAllocation":100,"trafficAllocationSeed":-29637986,"seed":651776645,"status":"ACTIVE","killed":false,"defaultTreatment":"off","algo":2,"conditions":[{"conditionType":"WHITELIST","matcherGroup":{"combiner":"AND","matchers":[{"keySelector":null,"matcherType":"IN_SEGMENT","negate":false,"userDefinedSegmentMatcherData":{"segmentName":"segment_1"},"whitelistMatcherData":null,"unaryNumericMatcherData":null,"betweenMatcherData":null,"dependencyMatcherData":null,"booleanMatcherData":null,"stringMatcherData":null}]},"partitions":[{"treatment":"some_treatment","size":100}],"label":"whitelisted segment"},{"conditionType":"ROLLOUT","matcherGroup":{"combiner":"AND","matchers":[{"keySelector":{"trafficType":"user","attribute":null},"matcherType":"ALL_KEYS","negate":false,"userDefinedSegmentMatcherData":null,"whitelistMatcherData":null,"unaryNumericMatcherData":null,"betweenMatcherData":null,"dependencyMatcherData":null,"booleanMatcherData":null,"stringMatcherData":null}]},"partitions":[{"treatment":"on","size":100},{"treatment":"off","size":0},{"treatment":"some_treatment","size":0}],"label":"default rule"}],"configurations":{"off":"{\"color\":\"blue\"}","on":"{\"color\":\"red\"}","some_treatment":"{\"color\":\"white\"}"}},{"changeNumber":1637270255857,"trafficTypeName":"user","name":"feature_flag_3","trafficAllocation":100,"trafficAllocationSeed":-1680947654,"seed":-109151416,"status":"ACTIVE","killed":false,"algo":2},{"changeNumber":1660326991079,"trafficTypeName":"user","name":"feature_flag_4","trafficAllocation":100,"trafficAllocationSeed":-1680947654,"seed":-109151416,"status":"ACTIVE","killed":true,"algo":2}]}
+{"ff":{"d":[{"changeNumber":1660326991072,"trafficTypeName":"user","name":"feature_flag_1","trafficAllocation":100,"trafficAllocationSeed":-1364119282,"seed":-605938843,"status":"ACTIVE","killed":false,"defaultTreatment":"off","algo":2,"conditions":[{"conditionType":"ROLLOUT","matcherGroup":{"combiner":"AND","matchers":[{"keySelector":{"trafficType":"user","attribute":null},"matcherType":"ALL_KEYS","negate":false,"userDefinedSegmentMatcherData":null,"whitelistMatcherData":null,"unaryNumericMatcherData":null,"betweenMatcherData":null,"dependencyMatcherData":null,"booleanMatcherData":null,"stringMatcherData":null}]},"partitions":[{"treatment":"on","size":100},{"treatment":"off","size":0}],"label":"default rule"}],"configurations":{}},{"changeNumber":1683928900842,"trafficTypeName":"user","name":"feature_flag_2","trafficAllocation":100,"trafficAllocationSeed":-29637986,"seed":651776645,"status":"ACTIVE","killed":false,"defaultTreatment":"off","algo":2,"conditions":[{"conditionType":"WHITELIST","matcherGroup":{"combiner":"AND","matchers":[{"keySelector":null,"matcherType":"IN_SEGMENT","negate":false,"userDefinedSegmentMatcherData":{"segmentName":"segment_1"},"whitelistMatcherData":null,"unaryNumericMatcherData":null,"betweenMatcherData":null,"dependencyMatcherData":null,"booleanMatcherData":null,"stringMatcherData":null}]},"partitions":[{"treatment":"some_treatment","size":100}],"label":"whitelisted segment"},{"conditionType":"ROLLOUT","matcherGroup":{"combiner":"AND","matchers":[{"keySelector":{"trafficType":"user","attribute":null},"matcherType":"ALL_KEYS","negate":false,"userDefinedSegmentMatcherData":null,"whitelistMatcherData":null,"unaryNumericMatcherData":null,"betweenMatcherData":null,"dependencyMatcherData":null,"booleanMatcherData":null,"stringMatcherData":null}]},"partitions":[{"treatment":"on","size":100},{"treatment":"off","size":0},{"treatment":"some_treatment","size":0}],"label":"default rule"}],"configurations":{"off":"{\"color\":\"blue\"}","on":"{\"color\":\"red\"}","some_treatment":"{\"color\":\"white\"}"}},{"changeNumber":1637270255857,"trafficTypeName":"user","name":"feature_flag_3","trafficAllocation":100,"trafficAllocationSeed":-1680947654,"seed":-109151416,"status":"ACTIVE","killed":false,"algo":2},{"changeNumber":1660326991079,"trafficTypeName":"user","name":"feature_flag_4","trafficAllocation":100,"trafficAllocationSeed":-1680947654,"seed":-109151416,"status":"ACTIVE","killed":true,"algo":2}],"s":-1,"t":300}}

testdata/splits_mock.json

@@ -1,5 +1,6 @@
-{
-  "splits": [%s],
-  "since": 1491244291288,
-  "till": 1491244291288
+{"ff": {
+    "d": [%s],
+    "s": 1491244291288,
+    "t": 1491244291288
+  }
 }

testdata/splits_mock_2.json

@@ -1,5 +1,6 @@
 {
-  "splits": [
+ "ff": {    
+    "d": [  
     {
       "trafficTypeName": "user",
       "name": "DEMO_MURMUR2",
@@ -142,7 +143,8 @@
         }
       ]
     }
-  ],
-  "since": 1491244291288,
-  "till": 1491244291288
+ ],
+    "s": 1491244291288,
+    "t": 1491244291288
+  }
 }

testdata/splits_mock_3.json

@@ -1,5 +1,6 @@
 {
-    "splits": [
+ "ff": {    
+    "d": [  
       {
         "trafficTypeName": "user",
         "name": "semver",
@@ -313,7 +314,8 @@
           }
         ]
       }
-    ],
-    "since": 1491244291288,
-    "till": 1491244291288
-  }
+  ],
+  "s": 1491244291288,
+  "t": 1491244291288
+  } 
+}