added integration test

Author: chillaq

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

@@ -1013,6 +1013,84 @@ public MockResponse dispatch(RecordedRequest request) {
         Assert.assertTrue(check3);
     }
 
+    @Test
+    public void ImpressionPropertiesTest() throws Exception {
+        String splits = new String(Files.readAllBytes(Paths.get("src/test/resources/splits_imp_toggle.json")), StandardCharsets.UTF_8);
+        List<RecordedRequest> allRequests = new ArrayList<>();
+
+        Dispatcher dispatcher = new Dispatcher() {
+            @Override
+            public MockResponse dispatch(RecordedRequest request) {
+                allRequests.add(request);
+                switch (request.getPath()) {
+                    case "/api/splitChanges?s=1.1&since=-1":
+                        return new MockResponse().setResponseCode(200).setBody(splits);
+                    case "/api/splitChanges?s=1.1&since=1602796638344":
+                        return new MockResponse().setResponseCode(200).setBody("{\"splits\": [], \"since\":1602796638344, \"till\":1602796638344}");
+                    case "/api/testImpressions/bulk":
+                        return new MockResponse().setResponseCode(200);
+                    case "/api/testImpressions/count":
+                        return new MockResponse().setResponseCode(200);
+                    case "/v1/keys/ss":
+                        return new MockResponse().setResponseCode(200);
+                    case "/v1/metrics/usage":
+                        return new MockResponse().setResponseCode(200);
+                    case "/v1/metrics/config":
+                        return new MockResponse().setResponseCode(200);
+                }
+                return new MockResponse().setResponseCode(404);
+            }
+        };
+
+        MockWebServer server = new MockWebServer();
+        server.setDispatcher(dispatcher);
+
+        server.start();
+        String serverURL = String.format("http://%s:%s", server.getHostName(), server.getPort());
+        SplitClientConfig config = SplitClientConfig.builder()
+                .setBlockUntilReadyTimeout(10000)
+                .endpoint(serverURL, serverURL)
+                .telemetryURL(serverURL + "/v1")
+                .authServiceURL(String.format("%s/api/auth/enabled", serverURL))
+                .streamingEnabled(false)
+                .featuresRefreshRate(5)
+                .impressionsMode(ImpressionsManager.Mode.DEBUG)
+                .build();
+
+        SplitFactory factory = SplitFactoryBuilder.build("fake-api-token", config);
+        SplitClient client = factory.client();
+        client.blockUntilReady();
+
+        Assert.assertEquals("off", client.getTreatment("user1", "without_impression_toggle", new HashMap<>(), "{\"prop1\": \"val1\"}"));
+        Assert.assertEquals("off", client.getTreatment("user2", "impression_toggle_on", new HashMap<>(), "{\"prop1\": \"val1\", \"prop2\": \"val2\"}"));
+        Assert.assertEquals("off", client.getTreatment("user3", "impression_toggle_on", new HashMap<>()));
+        client.destroy();
+        boolean check1 = false, check2 = false, check3 = false;
+        for (int i=0; i < allRequests.size(); i++ ) {
+            if (allRequests.get(i).getPath().equals("/api/testImpressions/bulk") ) {
+                String body = allRequests.get(i).getBody().readUtf8();
+                if (body.contains("user1")) {
+                    check1 = true;
+                    Assert.assertTrue(body.contains("without_impression_toggle"));
+                    Assert.assertTrue(body.contains("\"properties\":\"{\\\"prop1\\\":\\\"val1\\\"}\""));
+                }
+                if (body.contains("user2")) {
+                    check2 = true;
+                    Assert.assertTrue(body.contains("impression_toggle_on"));
+                    Assert.assertTrue(body.contains("\"properties\":\"{\\\"prop2\\\":\\\"val2\\\",\\\"prop1\\\":\\\"val1\\\"}\""));
+                }
+                if (body.contains("user3")) {
+                    check3 = true;
+                    Assert.assertTrue(body.contains("impression_toggle_on"));
+                    Assert.assertTrue(body.contains("\"properties\":null"));
+                }
+            }
+        }
+        server.shutdown();
+        Assert.assertTrue(check1);
+        Assert.assertTrue(check2);
+    }
+
     private SSEMockServer buildSSEMockServer(SSEMockServer.SseEventQueue eventQueue) {
         return new SSEMockServer(eventQueue, (token, version, channel) -> {
             if (!"1.1".equals(version)) {