1 files changed, 80 insertions, 0 deletions
diff --git a/integration/src/test/java/org/onap/pnfsimulator/integration/VariablesReplacement.java b/integration/src/test/java/org/onap/pnfsimulator/integration/VariablesReplacement.java
new file mode 100644
index 0000000..ae7970c
--- /dev/null
+++ b/integration/src/test/java/org/onap/pnfsimulator/integration/VariablesReplacement.java
@@ -0,0 +1,80 @@
+package org.onap.pnfsimulator.integration;
+
+import static io.restassured.RestAssured.given;
+import static org.assertj.core.api.AssertionsForClassTypes.assertThat;
+import static org.hamcrest.Matchers.equalTo;
+import static org.onap.pnfsimulator.integration.TestUtils.getCurrentIpAddress;
+
+import com.google.gson.JsonObject;
+import java.net.Inet4Address;
+import java.net.NetworkInterface;
+import java.net.SocketException;
+import java.util.Collections;
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.mockito.ArgumentCaptor;
+import org.mockito.Mockito;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+@RunWith(SpringRunner.class)
+@SpringBootTest(classes = {Main.class, TestConfiguration.class},
+        webEnvironment = SpringBootTest.WebEnvironment.DEFINED_PORT)
+public class VariablesReplacement {
+
+    @Autowired
+    private VesSimulatorService vesSimulatorService;
+
+    private String currentVesSimulatorIp;
+
+    @Before
+    public void setUp() throws Exception {
+        currentVesSimulatorIp = getCurrentIpAddress();
+    }
+
+    @Test
+    public void whenTriggeredSimulatorShouldReplaceStringKeyword() {
+        String startUrl = prepareRequestUrl();
+        String body = "{\n" + "\"templateName\": \"cmNotification.json\",\n" + "\"patch\":{},\n" + "\"variables\":{\n"
+                              + "\"dN\": \"NRNB=5, NRCEL=1234\",\n" + "\"attributeList\":{\n"
+                              + "\"threshXHighQ\": \"50\",\n" + "\"threshXHighP\": \"52\"\n" + "}\n" + "},\n"
+                              + "\"simulatorParams\": {\n" + "\"vesServerUrl\": \"https://" + currentVesSimulatorIp
+                              + ":9443/ves-simulator/eventListener/v5\",\n" + "\"repeatInterval\": 1,\n"
+                              + "\"repeatCount\": 1\n" + "}\n" + "}";
+        ArgumentCaptor<JsonObject> parameterCaptor = ArgumentCaptor.forClass(JsonObject.class);
+
+        given().contentType("application/json").body(body).when().post(startUrl).then().statusCode(200)
+                .body("message", equalTo("Request started"));
+
+        Mockito.verify(vesSimulatorService, Mockito.timeout(3000)).sendEventToDmaapV5(parameterCaptor.capture());
+
+        assertAttributeList(parameterCaptor);
+        assertDn(parameterCaptor);
+    }
+
+    private void assertDn(ArgumentCaptor<JsonObject> parameterCaptor) {
+        String dn = parameterCaptor.getValue().getAsJsonObject("event").getAsJsonObject("otherFields")
+                            .getAsJsonArray("jsonObjects").get(0)
+                            .getAsJsonObject().getAsJsonArray("objectInstances")
+                            .get(0).getAsJsonObject().getAsJsonObject("objectInstance")
+                            .getAsJsonObject("cm3gppNotifyFields").getAsJsonPrimitive("dN").getAsString();
+        assertThat(dn).isEqualTo("NRNB=5, NRCEL=1234");
+    }
+
+    private void assertAttributeList(ArgumentCaptor<JsonObject> parameterCaptor) {
+        JsonObject attributeList = parameterCaptor.getValue().getAsJsonObject("event").getAsJsonObject("otherFields")
+                                           .getAsJsonArray("jsonObjects").get(0).getAsJsonObject()
+                                           .getAsJsonArray("objectInstances").get(0).getAsJsonObject()
+                                           .getAsJsonObject("objectInstance").getAsJsonObject("cm3gppNotifyFields")
+                                           .getAsJsonObject("attributeList");
+        assertThat(attributeList.get("threshXHighQ").getAsString()).isEqualTo("50");
+        assertThat(attributeList.get("threshXHighP").getAsString()).isEqualTo("52");
+    }
+
+    private String prepareRequestUrl() {
+        return "http://0.0.0.0:5000/simulator/start";
+    }
+
+}