Add wiring tests

Author: ZamoraEmmanuel

CHANGES.txt

@@ -1,3 +1,7 @@
+2.10.0 (Dec 16, 2025)
+  - Updated @splitsoftware/splitio library, using @splitsoftware/splitio-commons:2.10.0 instead that includes
+    - Added property `impressionsDisabled` in getTreatment(s) `evaluationOptions` parameter, to disable impressions per evaluations.
+
 2.8.1 (Oct 13, 2025)
   - Updated base image to node:24.10.0-alpine3.22
 

listener/manager.js

@@ -1,4 +1,4 @@
-const fetch = require('node-fetch');
+const fetch = require('../sdk/platform/getFetch').getFetch();
 const config = require('config');
 const repeat = require('./repeat');
 const ImpressionQueue = require('./queue');

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "split-evaluator",
-  "version": "2.9.1",
+  "version": "2.9.0",
   "description": "Split-Evaluator",
   "repository": "splitio/split-evaluator",
   "homepage": "https://github.com/splitio/split-evaluator#readme",
@@ -57,6 +57,7 @@
     "@babel/preset-env": "^7.15.6",
     "babel-jest": "^29.7.0",
     "eslint": "^8.9.0",
+    "fetch-mock": "^11.1.5",
     "jest": "^29.7.0",
     "nodemon": "^3.1.0",
     "superagent": "^8.0.9",

package.json

@@ -0,0 +1,103 @@
+const { isConsumerMode } = require('@splitsoftware/splitio-commons/cjs/utils/settingsValidation/mode');
+const { getSplitFactory } = require('../../sdk');
+
+describe('SDK Wiring & Glue Code Integration', () => {
+  const baseConfig = {
+    core: {
+      authorizationKey: 'localhost',
+    },
+    features: {
+      'test_feature': 'on',
+    },
+  };
+
+  test('Should initialize correctly in OPTIMIZED mode - bloomFilter', async () => {
+    const optimizedConfig = {
+      ...baseConfig,
+      sync: {
+        impressionsMode: 'OPTIMIZED',
+      },
+    };
+
+    const { factory } = getSplitFactory(optimizedConfig);
+    const client = factory.client();
+
+    await client.ready();
+    
+    const treatment = client.getTreatment('test', 'my-experiment');
+    expect(treatment).toBe('on');
+
+    await expect(client.destroy()).resolves.toBeUndefined();
+  });
+
+  test('SDK_READY event must be emitted and resolved', (done) => {
+    const { factory } = getSplitFactory(baseConfig);
+    const client = factory.client();
+
+    let readyCalled = false;
+
+    client.on(client.Event.SDK_READY, () => {
+      readyCalled = true;
+      client.destroy().then(async () => {
+        expect(readyCalled).toBe(true);
+        await expect(client.destroy()).resolves.toBeUndefined();
+
+        done();
+      });
+    });
+
+    setTimeout(() => {
+      if (!readyCalled) {
+        client.destroy();
+        done(new Error('SDK_READY event was not emitted within timeout'));
+      }
+    }, 2000);
+  });
+
+  test('ExtraProps adds getRolloutPlan to Manager', async () => {
+    const { factory } = getSplitFactory(baseConfig);
+
+    expect(typeof factory.getRolloutPlan).toBe('function');
+
+    const plan = factory.getRolloutPlan({ feature: 'my-experiment' });
+    expect(plan).toBeDefined();
+    expect(plan.splitChanges).toBeDefined();
+
+    await expect(factory.destroy()).resolves.toBeUndefined();
+
+  });
+
+  test('Destroy must resolve and clean up resources', async () => {
+    const { factory } = getSplitFactory(baseConfig);
+    const client = factory.client();
+
+    await client.ready();
+
+    await expect(client.destroy()).resolves.toBeUndefined();
+  });
+
+  test('Must force STANDALONE mode if it receives CONSUMER mode', async () => {
+    const consumerConfig = {
+      ...baseConfig,
+      mode: 'consumer',
+      storage: {
+        type: 'REDIS',
+        prefix: 'test',
+      },
+    };
+    
+    const { factory } = getSplitFactory(consumerConfig);
+    
+    expect(isConsumerMode(factory.settings)).toBe(false);
+
+    const client = factory.client();
+    expect(client).toBeDefined();
+
+    await client.ready();
+
+    const treatment = client.getTreatment('test', 'my-experiment');
+    expect(treatment).toBe('on');
+
+    await expect(client.destroy()).resolves.toBeUndefined();
+  });
+});

sdk/__tests__/integrationOffline.test.js

@@ -0,0 +1,59 @@
+const { SplitFactory } = require('../'); 
+const { fetchMock } = require('./utils/fetchMock');
+
+const splitChangesMock1 = require('./mocks/splitchanges.since.-1.json');
+const splitChangesMock2 = require('./mocks/splitchanges.since.1457552620999.json');
+
+
+describe('Evaluator Integration (Online Mode)', () => {
+  const apiKey = 'sdk-test-api-key';
+  const testUrls = {
+    sdk: 'https://sdk.baseurl',
+    events: 'https://events.baseurl',
+    auth: 'https://auth.baseurl',
+    telemetry: 'https://telemetry.baseurl',
+  };
+
+  fetchMock.get(testUrls.sdk + '/splitChanges?s=1.3&since=-1&rbSince=-1', { status: 200, body: splitChangesMock1 });
+  fetchMock.get(testUrls.sdk + '/splitChanges?s=1.3&since=1457552620999&rbSince=100', { status: 200, body: splitChangesMock2 });
+  fetchMock.get(testUrls.auth + '/v2/auth?s=1.3', 200);
+  fetchMock.getOnce(testUrls.sdk + '/segmentChanges/employees?since=-1', { status: 200, body: { name: 'employees', added: [], removed: [], since: -1, till: 100 } });
+  fetchMock.getOnce(testUrls.sdk + '/segmentChanges/splitters?since=-1', { status: 200, body: { name: 'splitters', added: [], removed: [], since: -1, till: 100 } });
+  fetchMock.getOnce(testUrls.sdk + '/segmentChanges/developers?since=-1', { status: 200, body: { name: 'developers', added: [], removed: [], since: -1, till: 100 } });
+  fetchMock.get(testUrls.sdk + '/segmentChanges/employees?since=100', { status: 200, body: { name: 'employees', added: [], removed: [], since: 100, till: 100 } });
+  fetchMock.get(testUrls.sdk + '/segmentChanges/splitters?since=100', { status: 200, body: { name: 'splitters', added: [], removed: [], since: 100, till: 100 } });
+  fetchMock.get(testUrls.sdk + '/segmentChanges/developers?since=100', { status: 200, body: { name: 'developers', added: [], removed: [], since: 100, till: 100 } });
+  fetchMock.postOnce(testUrls.events + '/testImpressions/bulk', 200);
+  fetchMock.postOnce(testUrls.events + '/testImpressions/count', 200);
+  fetchMock.get(testUrls.sdk + '/segmentChanges/segment_excluded_by_rbs?since=-1', { status: 200, body: { added: ['emi@split.io'], removed: [], since: -1, till: 1 } });
+  fetchMock.get(testUrls.sdk + '/segmentChanges/segment_excluded_by_rbs?since=1', { status: 200, body: { added: [], removed: [], since: 1, till: 1 } });
+  fetchMock.post(testUrls.events + '/testImpressions/bulk', 200);
+  fetchMock.post(testUrls.events + '/testImpressions/count', 200);
+  fetchMock.post(testUrls.telemetry + '/v1/metrics/config', 200);
+  fetchMock.post(testUrls.telemetry + '/v1/metrics/usage', 200);
+
+  afterAll(() => {
+    fetchMock.reset();
+  });
+
+  test('Full Lifecycle: Init -> Download -> Evaluate -> Destroy', async () => {
+    const factory = SplitFactory({
+      core: { authorizationKey: apiKey },
+      startup: { readyTimeout: 2 },
+      urls: testUrls,
+    });
+    const client = factory.client();
+
+    await new Promise((resolve, reject) => {
+      client.on(client.Event.SDK_READY, resolve);
+      client.on(client.Event.SDK_READY_TIMED_OUT, () => reject(new Error('Timeout waiting for SDK_READY')));
+    });
+
+    // 2. Verify Evaluation (Storage working)
+    const treatment = client.getTreatment('user1', 'always_on');
+    expect(treatment).toBe('on');
+
+    // 3. Verify Cleanup
+    await client.destroy();
+  });
+});