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
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
|
/*
* Copyright (c) 2017. Lorem ipsum dolor sit amet, consectetur adipiscing elit.
* Morbi non lorem porttitor neque feugiat blandit. Ut vitae ipsum eget quam lacinia accumsan.
* Etiam sed turpis ac ipsum condimentum fringilla. Maecenas magna.
* Proin dapibus sapien vel ante. Aliquam erat volutpat. Pellentesque sagittis ligula eget metus.
* Vestibulum commodo. Ut rhoncus gravida arcu.
*/
package org.onap.ccsdk.sli.northbound.dmaapclient;
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.assertEquals;
import java.util.Properties;
import org.junit.Before;
import org.junit.Test;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;
public class TestSdncPserverDmaapReceiver {
private static final String aaiInput = "{\r\n" +
" \"cambria.partition\": \"AAI\",\r\n" +
" \"event-header\": {\r\n" +
" \"severity\": \"NORMAL\",\r\n" +
" \"entity-type\": \"pserver\",\r\n" +
" \"top-entity-type\": \"pserver\",\r\n" +
" \"entity-link\": \"https://aai.com:8443/aai/v11/cloud-infrastructure/pservers/pserver/a3d3d3d3/\",\r\n" +
" \"event-type\": \"AAI-EVENT\",\r\n" +
" \"domain\": \"e2e\",\r\n" +
" \"action\": \"UPDATE\",\r\n" +
" \"sequence-number\": \"0\",\r\n" +
" \"id\": \"20170415000111-1234\",\r\n" +
" \"source-name\": \"testclient\",\r\n" +
" \"version\": \"v11\",\r\n" +
" \"timestamp\": \"20170415-00:01:11:979\"\r\n" +
" },\r\n" +
" \"entity\": {\r\n" +
" \"hostname\": \"host1\",\r\n" +
" \"ptnii-equip-name\": \"lat111\",\r\n" +
" \"equip-type\": \"server\",\r\n" +
" \"equip-vendor\": \"HP\",\r\n" +
" \"equip-model\": \"model1\",\r\n" +
" \"fqdn\": \"l.global.net\",\r\n" +
" \"ipv4-oam-address\": \"12.12.12.12\",\r\n" +
" \"in-maint\": false,\r\n" +
" \"resource-version\": \"11111111111\",\r\n" +
" \"purpose\": \"Gamma\",\r\n" +
" \"relationship-list\": {\r\n" +
" \"relationship\": [\r\n" +
" {\r\n" +
" \"related-to\": \"complex\",\r\n" +
" \"relationship-data\": [\r\n" +
" {\r\n" +
" \"relationship-value\": \"L1L2L3\",\r\n" +
" \"relationship-key\": \"complex.physical-location-id\"\r\n" +
" }\r\n" +
" ],\r\n" +
" \"related-link\": \"https://aai.com:8443/aai/v11/cloud-infrastructure/complexes/complex/cmpl1\"\r\n" +
" }\r\n" +
" ]\r\n" +
" },\r\n" +
" \"p-interfaces\": {\r\n" +
" \"p-interface\": []\r\n" +
" },\r\n" +
" \"lag-interfaces\": {\r\n" +
" \"lag-interface\": []\r\n" +
" }\r\n" +
" }\r\n" +
"}";
@Before
public void setUp() throws Exception {
}
@Test
public void test() throws Exception {
Properties props = new Properties();
String rpcMsgbody = new SdncAaiDmaapConsumer(props).publish("src/main/resources/template-pserver.vt", aaiInput);
ObjectMapper oMapper = new ObjectMapper();
JsonNode aaiRootNode;
try {
aaiRootNode = oMapper.readTree(rpcMsgbody);
} catch (Exception e) {
throw new InvalidMessageException("Cannot parse json object", e);
}
assertTrue(aaiRootNode.get("input").get("payload") != null);
assertTrue(aaiRootNode.get("input").get("common-header") != null);
assertEquals(aaiRootNode.get("input").get("action-identifiers").get("action-name").textValue(), "dmaap-notification");
assertEquals(aaiRootNode.get("input").get("action-identifiers").get("mode").textValue(), "async");
}
}
|
