SplitClientConfigHelperTest.java

package io.split.splitio;

import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertTrue;
import static org.mockito.Mockito.mock;

import org.junit.Test;

import java.util.Arrays;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import io.split.android.client.SplitClientConfig;
import io.split.android.client.SplitFilter;
import io.split.android.client.impressions.ImpressionListener;

public class SplitClientConfigHelperTest {

    @Test
    public void configValuesAreMappedCorrectly() {
        Map<String, Object> configValues = new HashMap<>();

        configValues.put("featuresRefreshRate", 80000);
        configValues.put("segmentsRefreshRate", 70000);
        configValues.put("impressionsRefreshRate", 60000);
        configValues.put("telemetryRefreshRate", 2000);
        configValues.put("eventsQueueSize", 3999);
        configValues.put("impressionsQueueSize", 2999);
        configValues.put("eventFlushInterval", 40000);
        configValues.put("eventsPerPush", 5000);
        configValues.put("trafficType", "none");
        configValues.put("enableDebug", true);
        configValues.put("streamingEnabled", true);
        configValues.put("persistentAttributesEnabled", true);
        configValues.put("sdkEndpoint", "apiEndpoint.split.io");
        configValues.put("eventsEndpoint", "eventsEndpoint.split.io");
        configValues.put("authServiceEndpoint", "sseAuthServiceEndpoint.split.io");
        configValues.put("streamingServiceEndpoint", "streamingServiceEndpoint.split.io");
        configValues.put("telemetryServiceEndpoint", "telemetryServiceEndpoint.split.io");
        Map<String, List<String>> syncConfigMap = new HashMap<>();
        syncConfigMap.put("syncConfigNames", Arrays.asList("split1", "split2"));
        syncConfigMap.put("syncConfigPrefixes", Arrays.asList("split_", "my_split_"));
        configValues.put("syncConfig", syncConfigMap);

        SplitClientConfig splitClientConfig = SplitClientConfigHelper.fromMap(configValues, mock(ImpressionListener.class));

        assertEquals(80000, splitClientConfig.featuresRefreshRate());
        assertEquals(70000, splitClientConfig.segmentsRefreshRate());
        assertEquals(60000, splitClientConfig.impressionsRefreshRate());
        assertEquals(2000, splitClientConfig.telemetryRefreshRate());
        assertEquals(3999, splitClientConfig.eventsQueueSize());
        assertEquals(2999, splitClientConfig.impressionsQueueSize());
        assertEquals(40000, splitClientConfig.eventFlushInterval());
        assertEquals(5000, splitClientConfig.eventsPerPush());
        assertEquals("none", splitClientConfig.trafficType());
        assertTrue(splitClientConfig.debugEnabled());
        assertTrue(splitClientConfig.streamingEnabled());
        assertTrue(splitClientConfig.persistentAttributesEnabled());
        assertEquals("apiEndpoint.split.io", splitClientConfig.endpoint());
        assertEquals("eventsEndpoint.split.io", splitClientConfig.eventsEndpoint());
        assertEquals("sseAuthServiceEndpoint.split.io", splitClientConfig.authServiceUrl());
        assertEquals("streamingServiceEndpoint.split.io", splitClientConfig.streamingServiceUrl());
        assertEquals("telemetryServiceEndpoint.split.io", splitClientConfig.telemetryEndpoint());
        assertEquals(Arrays.asList("split1", "split2"), splitClientConfig.syncConfig().getFilters().get(0).getValues());
        assertEquals(SplitFilter.Type.BY_NAME, splitClientConfig.syncConfig().getFilters().get(0).getType());
        assertEquals(Arrays.asList("split_", "my_split_"), splitClientConfig.syncConfig().getFilters().get(1).getValues());
        assertEquals(SplitFilter.Type.BY_PREFIX, splitClientConfig.syncConfig().getFilters().get(1).getType());
    }
}