enabled posting impressionCount in debug mode

Author: Bilal Al

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

@@ -630,11 +630,10 @@ private ImpressionsManagerImpl buildImpressionsManager(SplitClientConfig config,
                     .collect(Collectors.toCollection(() -> impressionListeners));
         }
         ProcessImpressionStrategy processImpressionStrategy = null;
-        ImpressionCounter counter = null;
+        ImpressionCounter counter = new ImpressionCounter();
         ImpressionListener listener = !impressionListeners.isEmpty()
                 ? new ImpressionListener.FederatedImpressionListener(impressionListeners)
                 : null;
-        counter = new ImpressionCounter();
         ProcessImpressionNone processImpressionNone = new ProcessImpressionNone(listener != null, _uniqueKeysTracker, counter);
 
         switch (config.impressionsMode()) {

client/src/main/java/io/split/client/impressions/HttpImpressionsSender.java

@@ -91,11 +91,6 @@ public void postImpressionsBulk(List<TestImpressions> impressions) {
     @Override
     public void postCounters(HashMap<ImpressionCounter.Key, Integer> raw) {
         long initTime = System.currentTimeMillis();
-        if (_mode.equals(ImpressionsManager.Mode.DEBUG)) {
-            _logger.warn("Attempted to submit counters in impressions debugging mode. Ignoring");
-            return;
-        }
-
         try {
 
             Map<String, List<String>> additionalHeaders = new HashMap<>();

client/src/main/java/io/split/client/impressions/ImpressionsManagerImpl.java

@@ -112,6 +112,8 @@ public void start(){
                 break;
             case DEBUG:
                 _scheduler.scheduleAtFixedRate(this::sendImpressions, BULK_INITIAL_DELAY_SECONDS, _impressionsRefreshRate, TimeUnit.SECONDS);
+                _scheduler.scheduleAtFixedRate(this::sendImpressionCounters, COUNT_INITIAL_DELAY_SECONDS, COUNT_REFRESH_RATE_SECONDS,
+                        TimeUnit.SECONDS);
                 break;
             case NONE:
                 _scheduler.scheduleAtFixedRate(this::sendImpressionCounters, COUNT_INITIAL_DELAY_SECONDS, COUNT_REFRESH_RATE_SECONDS,

client/src/test/java/io/split/client/SplitClientIntegrationTest.java

@@ -907,7 +907,7 @@ public MockResponse dispatch(RecordedRequest request) {
         Assert.assertEquals("off", client.getTreatment("user3", "impression_toggle_off", null));
         Thread.sleep(1000);
         client.destroy();
-        boolean check1 = false, check2 = false;
+        boolean check1 = false, check2 = false, check3 = false;
         for (int i=0; i < allRequests.size(); i++ ) {
             if (allRequests.get(i).getPath().equals("/api/testImpressions/bulk") ) {
                 check1 = true;
@@ -923,10 +923,18 @@ public MockResponse dispatch(RecordedRequest request) {
                 Assert.assertFalse(body.contains("impression_toggle_on"));
                 Assert.assertTrue(body.contains("impression_toggle_off"));
             }
+            if (allRequests.get(i).getPath().equals("/api/testImpressions/count")) {
+                check3 = true;
+                String body = allRequests.get(i).getBody().readUtf8();
+                Assert.assertFalse(body.contains("without_impression_toggle"));
+                Assert.assertFalse(body.contains("impression_toggle_on"));
+                Assert.assertTrue(body.contains("impression_toggle_off"));
+            }
         }
         server.shutdown();
         Assert.assertTrue(check1);
         Assert.assertTrue(check2);
+        Assert.assertTrue(check3);
     }
 
     @Test

client/src/test/java/io/split/client/impressions/HttpImpressionsSenderTest.java

@@ -125,28 +125,6 @@ public void testImpressionCountsEndpointOptimized() throws URISyntaxException, I
                 new ImpressionCount.CountPerFeature("test2", 0, 5)));
     }
 
-    @Test
-    public void testImpressionCountsEndpointDebug() throws URISyntaxException, IOException, IllegalAccessException,
-            NoSuchMethodException, InvocationTargetException {
-        URI rootTarget = URI.create("https://kubernetesturl.com/split");
-
-        // Setup response mock
-        CloseableHttpClient httpClient = TestHelper.mockHttpClient("", HttpStatus.SC_OK);
-        SplitHttpClient splitHtpClient = SplitHttpClientImpl.create(httpClient, new RequestDecorator(null), "qwerty",
-                metadata());
-
-        // Send counters
-        HttpImpressionsSender sender = HttpImpressionsSender.create(splitHtpClient, rootTarget,
-                ImpressionsManager.Mode.DEBUG, TELEMETRY_STORAGE);
-        HashMap<ImpressionCounter.Key, Integer> toSend = new HashMap<>();
-        toSend.put(new ImpressionCounter.Key("test1", 0), 4);
-        toSend.put(new ImpressionCounter.Key("test2", 0), 5);
-        sender.postCounters(toSend);
-
-        // Assert that the HTTP client was not called
-        verify(httpClient, Mockito.never()).execute(Mockito.any());
-    }
-
     @Test
     public void testImpressionBulksEndpoint() throws URISyntaxException, IOException, IllegalAccessException,
             NoSuchMethodException, InvocationTargetException {