2 * Copyright (C) 2019 CMCC, Inc. and others. All rights reserved.
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.usecaseui.server.service.nsmf.impl;
18 import static org.mockito.Mockito.mock;
19 import static org.mockito.Mockito.when;
20 import static org.onap.usecaseui.server.util.CallStub.failedCall;
21 import static org.onap.usecaseui.server.util.CallStub.successfulCall;
23 import java.util.ArrayList;
24 import java.util.List;
25 import okhttp3.RequestBody;
26 import org.junit.Before;
27 import org.junit.Test;
28 import org.onap.usecaseui.server.bean.nsmf.monitor.ServiceInfo;
29 import org.onap.usecaseui.server.bean.nsmf.monitor.ServiceList;
30 import org.onap.usecaseui.server.service.slicingdomain.kpi.KpiSliceService;
31 import org.onap.usecaseui.server.service.slicingdomain.kpi.bean.KpiTotalBandwidth;
32 import org.onap.usecaseui.server.service.slicingdomain.kpi.bean.KpiTotalTraffic;
33 import org.onap.usecaseui.server.service.slicingdomain.kpi.bean.KpiUserNumber;
35 public class ResourceMonitorServiceImplTest {
37 ResourceMonitorServiceImpl resourceMonitorService = null;
38 KpiSliceService kpiSliceService = null;
41 public void before() throws Exception {
42 kpiSliceService = mock(KpiSliceService.class);
43 resourceMonitorService = new ResourceMonitorServiceImpl(kpiSliceService);
47 public void itCanInitConfig() {
48 resourceMonitorService.initConfig();
52 public void itCanQuerySlicingUsageTraffic() {
53 ServiceList serviceList = new ServiceList();
54 List<ServiceInfo> serviceInfoList = new ArrayList<>();
55 ServiceInfo serviceInfo = new ServiceInfo();
56 serviceInfo.setServiceId("123e-456t-567t-yui8");
57 serviceInfoList.add(serviceInfo);
58 serviceList.setServiceInfoList(serviceInfoList);
59 String queryTimestamp = "1577071879000";
61 KpiTotalTraffic kpiTotalTraffic = new KpiTotalTraffic();
62 RequestBody body = null;
63 when(kpiSliceService.listTotalTraffic(body)).thenReturn(successfulCall(kpiTotalTraffic));
64 resourceMonitorService.querySlicingUsageTraffic(queryTimestamp, serviceList);
68 public void querySlicingUsageTrafficWithThrowsException() {
69 ServiceList serviceList = new ServiceList();
70 List<ServiceInfo> serviceInfoList = new ArrayList<>();
71 ServiceInfo serviceInfo = new ServiceInfo();
72 serviceInfo.setServiceId("123e-456t-567t-yui8");
73 serviceInfoList.add(serviceInfo);
74 serviceList.setServiceInfoList(serviceInfoList);
75 String queryTimestamp = "1577071879000";
77 RequestBody body = null;
78 when(kpiSliceService.listTotalTraffic(body)).thenReturn(failedCall("kpi is not exist!"));
79 resourceMonitorService.querySlicingUsageTraffic(queryTimestamp, serviceList);
83 public void itCanQuerySlicingOnlineUserNumber() {
84 ServiceList serviceList = new ServiceList();
85 List<ServiceInfo> serviceInfoList = new ArrayList<>();
86 ServiceInfo serviceInfo = new ServiceInfo();
87 serviceInfo.setServiceId("123e-456t-567t-yui8");
88 serviceInfoList.add(serviceInfo);
89 serviceList.setServiceInfoList(serviceInfoList);
90 String queryTimestamp = "1577071879000";
92 KpiUserNumber kpiUserNumber = new KpiUserNumber();
93 RequestBody body = null;
94 when(kpiSliceService.listUserNumber(body)).thenReturn(successfulCall(kpiUserNumber));
95 resourceMonitorService.querySlicingOnlineUserNumber(queryTimestamp, serviceList);
99 public void querySlicingOnlineUserNumberWithThrowsException() {
100 ServiceList serviceList = new ServiceList();
101 List<ServiceInfo> serviceInfoList = new ArrayList<>();
102 ServiceInfo serviceInfo = new ServiceInfo();
103 serviceInfo.setServiceId("123e-456t-567t-yui8");
104 serviceInfoList.add(serviceInfo);
105 serviceList.setServiceInfoList(serviceInfoList);
106 String queryTimestamp = "1577071879000";
108 RequestBody body = null;
109 when(kpiSliceService.listUserNumber(body)).thenReturn(failedCall("kpi is not exist!"));
110 resourceMonitorService.querySlicingOnlineUserNumber(queryTimestamp, serviceList);
114 public void itCanQuerySlicingTotalBandwidth() {
115 ServiceList serviceList = new ServiceList();
116 List<ServiceInfo> serviceInfoList = new ArrayList<>();
117 ServiceInfo serviceInfo = new ServiceInfo();
118 serviceInfo.setServiceId("123e-456t-567t-yui8");
119 serviceInfoList.add(serviceInfo);
120 serviceList.setServiceInfoList(serviceInfoList);
121 String queryTimestamp = "1577071879000";
123 KpiTotalBandwidth kpiTotalBandwidth = new KpiTotalBandwidth();
124 RequestBody body = null;
125 when(kpiSliceService.listTotalBandwidth(body)).thenReturn(successfulCall(kpiTotalBandwidth));
126 resourceMonitorService.querySlicingTotalBandwidth(queryTimestamp, serviceList);
130 public void querySlicingTotalBandwidthWithThrowsException() {
131 ServiceList serviceList = new ServiceList();
132 List<ServiceInfo> serviceInfoList = new ArrayList<>();
133 ServiceInfo serviceInfo = new ServiceInfo();
134 serviceInfo.setServiceId("123e-456t-567t-yui8");
135 serviceInfoList.add(serviceInfo);
136 serviceList.setServiceInfoList(serviceInfoList);
137 String queryTimestamp = "1577071879000";
139 RequestBody body = null;
140 when(kpiSliceService.listTotalBandwidth(body)).thenReturn(failedCall("kpi is not exist!"));
141 resourceMonitorService.querySlicingTotalBandwidth(queryTimestamp, serviceList);
145 public void querySlicingPDUSessionEstSRWithThrowsException() {
146 ServiceList serviceList = new ServiceList();
147 List<ServiceInfo> serviceInfoList = new ArrayList<>();
148 ServiceInfo serviceInfo = new ServiceInfo();
149 serviceInfo.setServiceId("123e-456t-567t-yui8");
150 serviceInfoList.add(serviceInfo);
151 serviceList.setServiceInfoList(serviceInfoList);
152 String queryTimestamp = "1577071879000";
154 RequestBody body = null;
155 when(kpiSliceService.listPDUSessionEstSR(body)).thenReturn(failedCall("kpi is not exist!"));
156 resourceMonitorService.querySlicingPDUSessionEstSR(queryTimestamp, serviceList);