2 * Copyright 2018 ZTE Corporation.
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
8 * http://www.apache.org/licenses/LICENSE-2.0
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
16 package org.onap.aai.esr.wrapper;
18 import static org.junit.Assert.assertEquals;
19 import java.util.ArrayList;
20 import java.util.List;
21 import javax.ws.rs.core.Response;
22 import org.junit.Assert;
23 import org.junit.Test;
24 import org.mockito.Mockito;
25 import org.onap.aai.esr.common.MsbConfig;
26 import org.onap.aai.esr.entity.aai.EsrEmsDetail;
27 import org.onap.aai.esr.entity.rest.AlarmAddr;
28 import org.onap.aai.esr.entity.rest.EmsRegisterInfo;
29 import org.onap.aai.esr.entity.rest.FtpAddr;
30 import org.onap.aai.esr.exception.ExtsysException;
31 import org.onap.aai.esr.externalservice.aai.ExternalSystemProxy;
32 import org.onap.aai.esr.util.ExtsysUtil;
34 public class EmsManagerWrapperTest {
37 MsbConfig.setMsbServerAddr("http://127.0.0.1:80");
41 public void test_registerEms() throws ExtsysException {
43 EmsRegisterInfo emsRegisterInfo = new EmsRegisterInfo();
44 AlarmAddr alarmAddr = new AlarmAddr();
45 FtpAddr resourceAddr = new FtpAddr();
46 FtpAddr performanceAddr = new FtpAddr();
47 alarmAddr.setIp("ip");
48 alarmAddr.setPassword("987654");
49 alarmAddr.setPort("5000");
50 alarmAddr.setUser("nancy");
51 resourceAddr.setFtptype("sftp");
52 resourceAddr.setIp("ip");
53 resourceAddr.setPassive(true);
54 resourceAddr.setPassword("asdf");
55 resourceAddr.setPort("5000");
56 resourceAddr.setRemotepath("/home/per");
57 resourceAddr.setUser("nancy");
58 performanceAddr.setFtptype("sftp");
59 performanceAddr.setIp("ip");
60 performanceAddr.setPassive(true);
61 performanceAddr.setPassword("asdf");
62 performanceAddr.setPort("5000");
63 performanceAddr.setRemotepath("/home/per");
64 performanceAddr.setUser("nancy");
65 emsRegisterInfo.setName("EMS_TEST");
66 emsRegisterInfo.setVendor("ZTE");
67 emsRegisterInfo.setVersion("V1");
68 emsRegisterInfo.setAlarmAddr(alarmAddr);
69 emsRegisterInfo.setResourceAddr(resourceAddr);
70 emsRegisterInfo.setPerformanceAddr(performanceAddr);
71 ExternalSystemProxy mockExternalSystemProxy = Mockito.mock(ExternalSystemProxy.class);
72 Mockito.doNothing().when(mockExternalSystemProxy).registerEms(Mockito.anyString(), (EsrEmsDetail)Mockito.anyObject());
73 EmsManagerWrapper emsManagerWrapper = new EmsManagerWrapper(mockExternalSystemProxy);
74 Response response = emsManagerWrapper.registerEms(emsRegisterInfo);
75 if (response != null) {
76 Assert.assertTrue(response.getStatus() == 200);
81 public void test_queryEmsById() throws ExtsysException {
82 ExtsysUtil extsysUtil = new ExtsysUtil();
83 EmsRegisterInfo emsRegisterInfo = new EmsRegisterInfo();
84 AlarmAddr alarmAddr = new AlarmAddr();
85 FtpAddr resourceAddr = new FtpAddr();
86 FtpAddr performanceAddr = new FtpAddr();
87 alarmAddr.setIp("ip");
88 alarmAddr.setPassword("987654");
89 alarmAddr.setPort("5000");
90 alarmAddr.setUser("nancy");
91 resourceAddr.setFtptype("sftp");
92 resourceAddr.setIp("ip");
93 resourceAddr.setPassive(true);
94 resourceAddr.setPassword("asdf");
95 resourceAddr.setPort("5000");
96 resourceAddr.setRemotepath("/home/per");
97 resourceAddr.setUser("nancy");
98 performanceAddr.setFtptype("sftp");
99 performanceAddr.setIp("ip");
100 performanceAddr.setPassive(true);
101 performanceAddr.setPassword("asdf");
102 performanceAddr.setPort("5000");
103 performanceAddr.setRemotepath("/home/per");
104 performanceAddr.setUser("nancy");
105 emsRegisterInfo.setName("EMS_TEST");
106 emsRegisterInfo.setVendor("ZTE");
107 emsRegisterInfo.setVersion("V1");
108 emsRegisterInfo.setAlarmAddr(alarmAddr);
109 emsRegisterInfo.setResourceAddr(resourceAddr);
110 emsRegisterInfo.setPerformanceAddr(performanceAddr);
111 emsRegisterInfo.setEmsId("123456");
112 String emsDetailStr = "{\"ems-id\":\"123456\",\"esr-system-info-list\":{\"esr-system-info\":"
113 + "[{\"esr-system-info-id\":\"234567\",\"system-name\":\"EMS_TEST\",\"type\":\"sftp\","
114 + "\"vendor\":\"ZTE\",\"version\":\"V1\",\"user-name\":\"nancy\",\"password\":\"asdf\","
115 + "\"system-type\":\"EMS_RESOUCE\",\"ip-address\":\"ip\",\"port\":\"5000\","
116 + "\"passive\":true,\"remote-path\":\"/home/per\"},{\"esr-system-info-id\":\"345678\","
117 + "\"system-name\":\"EMS_TEST\",\"type\":\"sftp\",\"vendor\":\"ZTE\",\"version\":\"V1\","
118 + "\"user-name\":\"nancy\",\"password\":\"asdf\",\"system-type\":\"EMS_PERFORMANCE\","
119 + "\"ip-address\":\"ip\",\"port\":\"5000\",\"passive\":true,"
120 + "\"remote-path\":\"/home/per\"},{\"esr-system-info-id\":\"456789\","
121 + "\"system-name\":\"EMS_TEST\",\"vendor\":\"ZTE\",\"version\":\"V1\","
122 + "\"user-name\":\"nancy\",\"password\":\"987654\",\"system-type\":\"EMS_ALARM\","
123 + "\"ip-address\":\"ip\",\"port\":\"5000\"}]}}";
124 ExternalSystemProxy mockExternalSystemProxy = Mockito.mock(ExternalSystemProxy.class);
125 Mockito.when(mockExternalSystemProxy.queryEmsDetail(Mockito.anyString())).thenReturn(emsDetailStr);
126 EmsManagerWrapper emsManagerWrapper = new EmsManagerWrapper(mockExternalSystemProxy);
128 Response response = emsManagerWrapper.queryEmsById("123456");
129 if (response != null) {
130 Assert.assertTrue(response.getStatus() == 200);
131 assertEquals(extsysUtil.objectToString(emsRegisterInfo), extsysUtil.objectToString(response.getEntity()));
136 public void test_queryEmsList() throws ExtsysException {
137 ExtsysUtil extsysUtil = new ExtsysUtil();
138 List<EmsRegisterInfo> emsList = new ArrayList<>();
139 EmsRegisterInfo emsRegisterInfo = new EmsRegisterInfo();
140 AlarmAddr alarmAddr = new AlarmAddr();
141 FtpAddr resourceAddr = new FtpAddr();
142 FtpAddr performanceAddr = new FtpAddr();
143 alarmAddr.setIp("ip");
144 alarmAddr.setPassword("987654");
145 alarmAddr.setPort("5000");
146 alarmAddr.setUser("nancy");
147 resourceAddr.setFtptype("sftp");
148 resourceAddr.setIp("ip");
149 resourceAddr.setPassive(true);
150 resourceAddr.setPassword("asdf");
151 resourceAddr.setPort("5000");
152 resourceAddr.setRemotepath("/home/per");
153 resourceAddr.setUser("nancy");
154 performanceAddr.setFtptype("sftp");
155 performanceAddr.setIp("ip");
156 performanceAddr.setPassive(true);
157 performanceAddr.setPassword("asdf");
158 performanceAddr.setPort("5000");
159 performanceAddr.setRemotepath("/home/per");
160 performanceAddr.setUser("nancy");
161 emsRegisterInfo.setName("EMS_TEST");
162 emsRegisterInfo.setVendor("ZTE");
163 emsRegisterInfo.setVersion("V1");
164 emsRegisterInfo.setAlarmAddr(alarmAddr);
165 emsRegisterInfo.setResourceAddr(resourceAddr);
166 emsRegisterInfo.setPerformanceAddr(performanceAddr);
167 emsRegisterInfo.setEmsId("123456");
168 emsList.add(emsRegisterInfo);
169 String emsDetailStr = "{\"ems-id\":\"123456\",\"esr-system-info-list\":{\"esr-system-info\":"
170 + "[{\"esr-system-info-id\":\"234567\",\"system-name\":\"EMS_TEST\",\"type\":\"sftp\","
171 + "\"vendor\":\"ZTE\",\"version\":\"V1\",\"user-name\":\"nancy\",\"password\":\"asdf\","
172 + "\"system-type\":\"EMS_RESOUCE\",\"ip-address\":\"ip\",\"port\":\"5000\","
173 + "\"passive\":true,\"remote-path\":\"/home/per\"},{\"esr-system-info-id\":\"345678\","
174 + "\"system-name\":\"EMS_TEST\",\"type\":\"sftp\",\"vendor\":\"ZTE\",\"version\":\"V1\","
175 + "\"user-name\":\"nancy\",\"password\":\"asdf\",\"system-type\":\"EMS_PERFORMANCE\","
176 + "\"ip-address\":\"ip\",\"port\":\"5000\",\"passive\":true,"
177 + "\"remote-path\":\"/home/per\"},{\"esr-system-info-id\":\"456789\","
178 + "\"system-name\":\"EMS_TEST\",\"vendor\":\"ZTE\",\"version\":\"V1\","
179 + "\"user-name\":\"nancy\",\"password\":\"987654\",\"system-type\":\"EMS_ALARM\","
180 + "\"ip-address\":\"ip\",\"port\":\"5000\"}]}}";
181 String emsListStr = "{\"esr-ems\": [ {\"ems-id\": \"123456\",\"resource-version\": \"1\"}]}";
182 ExternalSystemProxy mockExternalSystemProxy = Mockito.mock(ExternalSystemProxy.class);
183 Mockito.when(mockExternalSystemProxy.queryEmsDetail(Mockito.anyString())).thenReturn(emsDetailStr);
184 Mockito.when(mockExternalSystemProxy.queryEmsList()).thenReturn(emsListStr);
185 EmsManagerWrapper emsManagerWrapper = new EmsManagerWrapper(mockExternalSystemProxy);
186 Response response = emsManagerWrapper.queryEmsList();
187 if (response != null) {
188 Assert.assertTrue(response.getStatus() == 200);
189 assertEquals(extsysUtil.objectToString(emsList), extsysUtil.objectToString(response.getEntity()));
194 public void test_updateEms() throws ExtsysException {
195 EmsRegisterInfo emsRegisterInfo = new EmsRegisterInfo();
196 AlarmAddr alarmAddr = new AlarmAddr();
197 FtpAddr resourceAddr = new FtpAddr();
198 FtpAddr performanceAddr = new FtpAddr();
199 alarmAddr.setIp("ip");
200 alarmAddr.setPassword("987654");
201 alarmAddr.setPort("5000");
202 alarmAddr.setUser("nancy");
203 resourceAddr.setFtptype("sftp");
204 resourceAddr.setIp("ip");
205 resourceAddr.setPassive(true);
206 resourceAddr.setPassword("asdf");
207 resourceAddr.setPort("5000");
208 resourceAddr.setRemotepath("/home/per");
209 resourceAddr.setUser("nancy");
210 performanceAddr.setFtptype("sftp");
211 performanceAddr.setIp("ip");
212 performanceAddr.setPassive(true);
213 performanceAddr.setPassword("asdf");
214 performanceAddr.setPort("5000");
215 performanceAddr.setRemotepath("/home/per");
216 performanceAddr.setUser("nancy");
217 emsRegisterInfo.setName("EMS_TEST");
218 emsRegisterInfo.setVendor("ZTE");
219 emsRegisterInfo.setVersion("V1");
220 emsRegisterInfo.setAlarmAddr(alarmAddr);
221 emsRegisterInfo.setResourceAddr(resourceAddr);
222 emsRegisterInfo.setPerformanceAddr(performanceAddr);
223 emsRegisterInfo.setEmsId("123456");
224 String emsDetailStr = "{\"ems-id\":\"123456\",\"esr-system-info-list\":{\"esr-system-info\":"
225 + "[{\"esr-system-info-id\":\"234567\",\"system-name\":\"EMS_TEST\",\"type\":\"sftp\","
226 + "\"vendor\":\"ZTE\",\"version\":\"V1\",\"user-name\":\"nancy\",\"password\":\"asdf\","
227 + "\"system-type\":\"EMS_RESOUCE\",\"ip-address\":\"ip\",\"port\":\"5000\","
228 + "\"passive\":true,\"remote-path\":\"/home/per\"},{\"esr-system-info-id\":\"345678\","
229 + "\"system-name\":\"EMS_TEST\",\"type\":\"sftp\",\"vendor\":\"ZTE\",\"version\":\"V1\","
230 + "\"user-name\":\"nancy\",\"password\":\"asdf\",\"system-type\":\"EMS_PERFORMANCE\","
231 + "\"ip-address\":\"ip\",\"port\":\"5000\",\"passive\":true,"
232 + "\"remote-path\":\"/home/per\"},{\"esr-system-info-id\":\"456789\","
233 + "\"system-name\":\"EMS_TEST\",\"vendor\":\"ZTE\",\"version\":\"V1\","
234 + "\"user-name\":\"nancy\",\"password\":\"987654\",\"system-type\":\"EMS_ALARM\","
235 + "\"ip-address\":\"ip\",\"port\":\"5000\"}]}}";
236 ExternalSystemProxy mockExternalSystemProxy = Mockito.mock(ExternalSystemProxy.class);
237 Mockito.when(mockExternalSystemProxy.queryEmsDetail(Mockito.anyString())).thenReturn(emsDetailStr);
238 Mockito.doNothing().when(mockExternalSystemProxy).registerEms(Mockito.anyString(), (EsrEmsDetail)Mockito.anyObject());
239 EmsManagerWrapper emsManagerWrapper = new EmsManagerWrapper(mockExternalSystemProxy);
240 Response response = emsManagerWrapper.updateEms(emsRegisterInfo, "123456");
241 if (response != null) {
242 Assert.assertTrue(response.getStatus() == 200);
247 public void test_delEms() throws ExtsysException {
248 String emsDetailStr = "{\"ems-id\":\"123456\",\"esr-system-info-list\":{\"esr-system-info\":"
249 + "[{\"esr-system-info-id\":\"234567\",\"system-name\":\"EMS_TEST\",\"type\":\"sftp\","
250 + "\"vendor\":\"ZTE\",\"version\":\"V1\",\"user-name\":\"nancy\",\"password\":\"asdf\","
251 + "\"system-type\":\"EMS_RESOUCE\",\"ip-address\":\"ip\",\"port\":\"5000\","
252 + "\"passive\":true,\"remote-path\":\"/home/per\"},{\"esr-system-info-id\":\"345678\","
253 + "\"system-name\":\"EMS_TEST\",\"type\":\"sftp\",\"vendor\":\"ZTE\",\"version\":\"V1\","
254 + "\"user-name\":\"nancy\",\"password\":\"asdf\",\"system-type\":\"EMS_PERFORMANCE\","
255 + "\"ip-address\":\"ip\",\"port\":\"5000\",\"passive\":true,"
256 + "\"remote-path\":\"/home/per\"},{\"esr-system-info-id\":\"456789\","
257 + "\"system-name\":\"EMS_TEST\",\"vendor\":\"ZTE\",\"version\":\"V1\","
258 + "\"user-name\":\"nancy\",\"password\":\"987654\",\"system-type\":\"EMS_ALARM\","
259 + "\"ip-address\":\"ip\",\"port\":\"5000\"}]}}";
260 ExternalSystemProxy mockExternalSystemProxy = Mockito.mock(ExternalSystemProxy.class);
261 Mockito.when(mockExternalSystemProxy.queryEmsDetail(Mockito.anyString())).thenReturn(emsDetailStr);
262 Mockito.doNothing().when(mockExternalSystemProxy).deleteEms(Mockito.anyString(), Mockito.anyString());
263 EmsManagerWrapper emsManagerWrapper = new EmsManagerWrapper(mockExternalSystemProxy);
264 Response response = emsManagerWrapper.delEms("123456");
265 if (response != null) {
266 Assert.assertTrue(response.getStatus() == 204);