d03ee6bba0f720cbc26005bd8fd38db939e8d165
[usecase-ui/server.git] /
1 /*
2  * Copyright (C) 2019 CMCC, Inc. and others. All rights reserved.
3  *
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
7  *
8  *     http://www.apache.org/licenses/LICENSE-2.0
9  *
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.
15  */
16 package org.onap.usecaseui.server.service.nsmf.impl;
17
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;
22
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;
34
35 public class ResourceMonitorServiceImplTest {
36
37     ResourceMonitorServiceImpl resourceMonitorService = null;
38     KpiSliceService kpiSliceService = null;
39
40     @Before
41     public void before() throws Exception {
42         kpiSliceService = mock(KpiSliceService.class);
43         resourceMonitorService = new ResourceMonitorServiceImpl(kpiSliceService);
44     }
45
46     @Test
47     public void itCanInitConfig() {
48         resourceMonitorService.initConfig();
49     }
50
51     @Test
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";
60
61         KpiTotalTraffic kpiTotalTraffic = new KpiTotalTraffic();
62         RequestBody body = null;
63         when(kpiSliceService.listTotalTraffic(body)).thenReturn(successfulCall(kpiTotalTraffic));
64         resourceMonitorService.querySlicingUsageTraffic(queryTimestamp, serviceList);
65     }
66
67     @Test
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";
76
77         RequestBody body = null;
78         when(kpiSliceService.listTotalTraffic(body)).thenReturn(failedCall("kpi is not exist!"));
79         resourceMonitorService.querySlicingUsageTraffic(queryTimestamp, serviceList);
80     }
81
82     @Test
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";
91
92         KpiUserNumber kpiUserNumber = new KpiUserNumber();
93         RequestBody body = null;
94         when(kpiSliceService.listUserNumber(body)).thenReturn(successfulCall(kpiUserNumber));
95         resourceMonitorService.querySlicingOnlineUserNumber(queryTimestamp, serviceList);
96     }
97
98     @Test
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";
107
108         RequestBody body = null;
109         when(kpiSliceService.listUserNumber(body)).thenReturn(failedCall("kpi is not exist!"));
110         resourceMonitorService.querySlicingOnlineUserNumber(queryTimestamp, serviceList);
111     }
112
113     @Test
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";
122
123         KpiTotalBandwidth kpiTotalBandwidth = new KpiTotalBandwidth();
124         RequestBody body = null;
125         when(kpiSliceService.listTotalBandwidth(body)).thenReturn(successfulCall(kpiTotalBandwidth));
126         resourceMonitorService.querySlicingTotalBandwidth(queryTimestamp, serviceList);
127     }
128
129     @Test
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";
138
139         RequestBody body = null;
140         when(kpiSliceService.listTotalBandwidth(body)).thenReturn(failedCall("kpi is not exist!"));
141         resourceMonitorService.querySlicingTotalBandwidth(queryTimestamp, serviceList);
142     }
143
144     @Test
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";
153
154         RequestBody body = null;
155         when(kpiSliceService.listPDUSessionEstSR(body)).thenReturn(failedCall("kpi is not exist!"));
156         resourceMonitorService.querySlicingPDUSessionEstSR(queryTimestamp, serviceList);
157     }
158 }