Cleaning metrics and adding Telemetry config initializer

Author: ldecheverz-split

client/src/main/java/io/split/client/ApiKeyCounter.java

@@ -6,6 +6,9 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.util.HashMap;
+import java.util.Map;
+
 public class ApiKeyCounter {
 
     private static final Logger _log = LoggerFactory.getLogger(ApiKeyCounter.class);
@@ -63,4 +66,13 @@ boolean isApiKeyPresent(String apiKey) {
     int getCount(String apiKey) {
         return USED_API_KEYS.count(apiKey);
     }
+
+    public Map<String, Long> getFactoryInstances() {
+        Map<String, Long> factoryInstances = new HashMap<>();
+        for (String factory :USED_API_KEYS) {
+            factoryInstances.putIfAbsent(factory, new Long(getCount(factory)));
+        }
+
+        return factoryInstances;
+    }
 }

client/src/main/java/io/split/client/SplitFactoryImpl.java

@@ -8,7 +8,6 @@
 import io.split.client.interceptors.GzipDecoderResponseInterceptor;
 import io.split.client.interceptors.GzipEncoderRequestInterceptor;
 import io.split.client.interceptors.SdkMetadataInterceptorFilter;
-import io.split.client.metrics.HttpMetrics;
 import io.split.cache.InMemoryCacheImp;
 import io.split.cache.SplitCache;
 import io.split.engine.evaluator.Evaluator;
@@ -29,6 +28,7 @@
 import io.split.telemetry.storage.InMemoryTelemetryStorage;
 import io.split.telemetry.storage.TelemetryStorage;
 import io.split.telemetry.synchronizer.SynchronizerMemory;
+import io.split.telemetry.synchronizer.TelemetryConfigInitializer;
 import io.split.telemetry.synchronizer.TelemetrySyncTask;
 import io.split.telemetry.synchronizer.TelemetrySynchronizer;
 import org.apache.hc.client5.http.auth.AuthScope;
@@ -95,6 +95,7 @@ public class SplitFactoryImpl implements SplitFactory {
     private final TelemetrySynchronizer _telemetrySynchronizer;
     private final TelemetrySyncTask _telemetrySyncTask;
     private final long _startTime;
+    private final TelemetryConfigInitializer _telemetryConfigInitializer;
 
     public SplitFactoryImpl(String apiToken, SplitClientConfig config) throws URISyntaxException {
         _startTime = System.currentTimeMillis();
@@ -126,6 +127,8 @@ public SplitFactoryImpl(String apiToken, SplitClientConfig config) throws URISyn
         _splitCache = new InMemoryCacheImp();
         _telemetrySynchronizer = new SynchronizerMemory(_httpclient, URI.create(config.get_telemetryURL()), _telemetryStorage, _splitCache, _segmentCache, _telemetryStorage);
         _telemetrySyncTask = new TelemetrySyncTask(config.get_telemetryRefreshRate(), _telemetrySynchronizer);
+        _telemetryConfigInitializer = new TelemetryConfigInitializer(_telemetrySynchronizer,_gates,config);
+
 
         // Segments
         _segmentSynchronizationTaskImp = buildSegments(config);