1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
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";
}
}
|
