Update tests

Author: EmilianoSanchez

CHANGES.txt

@@ -1,6 +1,6 @@
 11.5.0 (August XX, 2025)
- - Added `factory.getCache()` method for standalone server-side SDKs, which returns the rollout plan snapshot from the storage.
- - Added `preloadedData` configuration option for standalone client-side SDKs, which allows preloading the SDK storage with a snapshot of the rollout plan.
+ - Added `factory.getRolloutPlan()` method for standalone server-side SDKs, which returns the rollout plan snapshot from the storage.
+ - Added `initialRolloutPlan` configuration option for standalone client-side SDKs, which allows preloading the SDK storage with a snapshot of the rollout plan.
 
 11.4.1 (June 3, 2025)
  - Updated @splitsoftware/splitio-commons package to version 2.4.1, which improves the Proxy fallback to flag spec version 1.2 by handling the case when the Proxy does not return an end-of-stream marker in 400 status code responses.

src/__tests__/browserSuites/ready-from-cache.spec.js

@@ -20,6 +20,25 @@ const alwaysOnSplitInverted = JSON.stringify({
   'killed': false,
   'defaultTreatment': 'off',
   'conditions': [
+    {
+      'matcherGroup': {
+        'combiner': 'AND',
+        'matchers': [
+          {
+            'matcherType': 'IN_SEGMENT',
+            'userDefinedSegmentMatcherData': {
+              'segmentName': 'employees'
+            },
+          }
+        ]
+      },
+      'partitions': [
+        {
+          'treatment': 'on',
+          'size': 100
+        }
+      ]
+    },
     {
       'matcherGroup': {
         'combiner': 'AND',
@@ -472,17 +491,17 @@ export default function (fetchMock, assert) {
     });
   });
 
-  assert.test(t => { // Testing when we start with preloaded data and MEMORY storage type (is ready from cache immediately)
+  assert.test(t => { // Testing when we start with initial rollout plan data and MEMORY storage type (is ready from cache immediately)
     const testUrls = {
-      sdk: 'https://sdk.baseurl/readyFromCacheWithPreloadedData',
-      events: 'https://events.baseurl/readyFromCacheWithPreloadedData'
+      sdk: 'https://sdk.baseurl/readyFromCacheWithInitialRolloutPlan',
+      events: 'https://events.baseurl/readyFromCacheWithInitialRolloutPlan'
     };
 
     t.plan(5);
 
     fetchMock.getOnce(testUrls.sdk + '/splitChanges?s=1.3&since=25&rbSince=-1', { status: 200, body: { ff: { ...splitChangesMock1.ff, s: 25 } } });
     fetchMock.getOnce(testUrls.sdk + '/memberships/nicolas%40split.io', { status: 200, body: membershipsNicolas });
-    fetchMock.getOnce(testUrls.sdk + '/memberships/nicolas2%40split.io', { status: 200, body: { 'ms': {} } });
+    fetchMock.getOnce(testUrls.sdk + '/memberships/emi%40split.io', { status: 200, body: { 'ms': {} } });
 
     fetchMock.postOnce(testUrls.events + '/testImpressions/bulk', 200);
     fetchMock.postOnce(testUrls.events + '/testImpressions/count', 200);
@@ -493,19 +512,26 @@ export default function (fetchMock, assert) {
         type: 'MEMORY',
       },
       urls: testUrls,
-      preloadedData: {
-        since: 25,
-        flags: [JSON.parse(alwaysOnSplitInverted)]
+      initialRolloutPlan: {
+        splitChanges: {
+          ff: {
+            t: 25,
+            d: [JSON.parse(alwaysOnSplitInverted)]
+          }
+        },
+        memberships: {
+          '[email protected]': { ms: { k: [{ n: 'employees' }] } }
+        }
       }
     });
 
     const client = splitio.client();
-    const client2 = splitio.client('nicolas2@split.io');
+    const client2 = splitio.client('emi@split.io');
 
     t.equal(client.__getStatus().isReadyFromCache, true, 'Client is ready from cache');
 
-    t.equal(client.getTreatment('always_on'), 'off', 'It should evaluate treatments with data from cache instead of control due to Input Validation');
-    t.equal(client2.getTreatment('always_on'), 'off', 'It should evaluate treatments with data from cache instead of control due to Input Validation');
+    t.equal(client.getTreatment('always_on'), 'off', 'It should evaluate treatments with data from cache. Key without memberships');
+    t.equal(client2.getTreatment('always_on'), 'on', 'It should evaluate treatments with data from cache. Key with memberships');
 
     client.on(client.Event.SDK_READY_TIMED_OUT, () => {
       t.fail('It should not timeout in this scenario.');

src/__tests__/nodeSuites/evaluations.spec.js

@@ -281,17 +281,29 @@ export default async function (config, key, assert) {
     getTreatmentsTests(client, i);
     getTreatmentsWithConfigTests(client, i);
 
-    // getCache method
-    const serverSideState = splitio.getCache();
-    assert.equal(serverSideState.since, 1457552620999);
-    assert.equal(serverSideState.flags.length, splitChangesMock1.ff.d.length);
-    assert.deepEqual(serverSideState.segments, { employees: [], splitters: [], developers: [], segment_excluded_by_rbs: ['[email protected]'] });
-    assert.deepEqual(serverSideState.memberships, undefined);
-    const clientSideState = splitio.getCache(['user1']);
-    assert.equal(clientSideState.since, 1457552620999);
-    assert.equal(clientSideState.flags.length, splitChangesMock1.ff.d.length);
-    assert.deepEqual(clientSideState.segments, undefined);
-    assert.deepEqual(clientSideState.memberships, { user1: { ms: { k: [] }, ls: { k: [] } } });
+    // getRolloutPlan method
+    const expectedRolloutPlan = {
+      splitChanges: splitChangesMock1,
+      segmentChanges: [
+        { name: 'employees', added: [], removed: [], till: 1 },
+        { name: 'splitters', added: [], removed: [], till: 1 },
+        { name: 'developers', added: [], removed: [], till: 1 },
+        { name: 'segment_excluded_by_rbs', added: ['[email protected]'], removed: [], till: 1 }
+      ],
+      memberships: { '[email protected]': { ms: { k: [{ n: 'segment_excluded_by_rbs' }] }, ls: { k: [] } } }
+    };
+
+    const rolloutPlan = splitio.getRolloutPlan();
+    assert.deepEqual(rolloutPlan, { ...expectedRolloutPlan, segmentChanges: undefined, memberships: undefined });
+
+    const rolloutPlanWithMemberships = splitio.getRolloutPlan({ keys: ['[email protected]'] });
+    assert.deepEqual(rolloutPlanWithMemberships, { ...expectedRolloutPlan, segmentChanges: undefined });
+
+    const rolloutPlanWithSegments = splitio.getRolloutPlan({ exposeSegments: true });
+    assert.deepEqual(rolloutPlanWithSegments, { ...expectedRolloutPlan, memberships: undefined });
+
+    const rolloutPlanWithMembershipsAndSegments = splitio.getRolloutPlan({ keys: [{ matchingKey: '[email protected]', bucketingKey: 'bucketingKey' }], exposeSegments: true });
+    assert.deepEqual(rolloutPlanWithMembershipsAndSegments, expectedRolloutPlan);
 
     await client.destroy();
 

src/factory/node.js

@@ -4,7 +4,7 @@ import { pushManagerFactory } from '@splitsoftware/splitio-commons/src/sync/stre
 import { pollingManagerSSFactory } from '@splitsoftware/splitio-commons/src/sync/polling/pollingManagerSS';
 import { InRedisStorage } from '@splitsoftware/splitio-commons/src/storages/inRedis';
 import { InMemoryStorageFactory } from '@splitsoftware/splitio-commons/src/storages/inMemory/InMemoryStorage';
-import { getCache } from '@splitsoftware/splitio-commons/src/storages/dataLoader';
+import { getRolloutPlan } from '@splitsoftware/splitio-commons/src/storages/dataLoader';
 import { sdkManagerFactory } from '@splitsoftware/splitio-commons/src/sdkManager';
 import { sdkClientMethodFactory } from '@splitsoftware/splitio-commons/src/sdkClient/sdkClientMethod';
 import { impressionObserverSSFactory } from '@splitsoftware/splitio-commons/src/trackers/impressionObserver/impressionObserverSS';
@@ -54,8 +54,8 @@ function getModules(settings) {
     extraProps: (params) => {
       if (params.settings.mode !== CONSUMER_MODE) {
         return {
-          getCache(userKeys) {
-            return getCache(params.settings.log, params.storage, userKeys);
+          getRolloutPlan(userKeys) {
+            return getRolloutPlan(params.settings.log, params.storage, userKeys);
           }
         };
       }

ts-tests/index.ts

@@ -687,3 +687,8 @@ let fullAsyncSettings: SplitIO.INodeAsyncSettings = {
 fullBrowserSettings.debug = 'ERROR';
 fullNodeSettings.debug = 'WARN';
 fullAsyncSettings.debug = 'INFO';
+
+// Preload rollout plan
+let rolloutPlanSnapshot: SplitIO.RolloutPlan = SDK.getRolloutPlan();
+rolloutPlanSnapshot = SDK.getRolloutPlan({ keys: ['key1', { matchingKey: 'key2', bucketingKey: 'bucketingKey' }], exposeSegments: true });
+browserSettings.initialRolloutPlan = rolloutPlanSnapshot;