test: update Redis tests to assert fallback treatments

Author: EmilianoSanchez

src/__tests__/consumer/node_redis.spec.js

@@ -550,7 +550,14 @@ tape('Node.js Redis', function (t) {
   t.test('Connection error', assert => {
     initializeRedisServer()
       .then((server) => {
-        const sdk = SplitFactory(config);
+        const sdk = SplitFactory({
+          ...config,
+          fallbackTreatments: {
+            byFlag: {
+              'always-on': 'control_always_on'
+            }
+          }
+        });
         const client = sdk.client();
 
         client.once(client.Event.SDK_READY_TIMED_OUT, assert.fail);
@@ -585,7 +592,7 @@ tape('Node.js Redis', function (t) {
               assert.equal(await client.getTreatment('UT_Segment_member', 'UT_NOT_SET_MATCHER', {
                 permissions: ['not_matching']
               }), 'control', 'In the event of a Redis error like a disconnection, getTreatments should not hang but resolve to "control".');
-              assert.equal(await client.getTreatment('UT_Segment_member', 'always-on'), 'control', 'In the event of a Redis error like a disconnection, getTreatments should not hang but resolve to "control".');
+              assert.equal(await client.getTreatment('UT_Segment_member', 'always-on'), 'control_always_on', 'In the event of a Redis error like a disconnection, getTreatments should not hang but resolve to fallback treatment or "control".');
 
               assert.false(await client.track('nicolas@split.io', 'user', 'test.redis.event', 18), 'In the event of a Redis error like a disconnection, track should resolve to false.');
 

ts-tests/index.ts

@@ -263,7 +263,7 @@ promise = client.destroy();
 promise = SDK.destroy();
 // @TODO not public yet
 // promise = client.flush();
-const promiseWhenReadyFromCache: Promise<boolean> = client.whenReadyFromCache();
+let promiseWhenReadyFromCache: Promise<boolean> = client.whenReadyFromCache();
 
 // Get readiness status
 let status: SplitIO.ReadinessStatus = client.getStatus();
@@ -378,10 +378,15 @@ nodeEventEmitter = asyncClient;
 
 // Ready, destroy and flush (same as for sync client, just for interface checking)
 promise = asyncClient.ready();
+promise = asyncClient.whenReady();
 promise = asyncClient.destroy();
 promise = AsyncSDK.destroy();
 // @TODO not public yet
 // promise = asyncClient.flush();
+promiseWhenReadyFromCache = asyncClient.whenReadyFromCache();
+
+// Get readiness status
+status = asyncClient.getStatus();
 
 // We can call getTreatment but always with a key.
 asyncTreatment = asyncClient.getTreatment(splitKey, 'mySplit');