2 * ============LICENSE_START=======================================================
3 * ONAP : ccsdk feature sdnr wt
4 * ================================================================================
5 * Copyright (C) 2019 highstreet technologies GmbH Intellectual Property.
7 * ================================================================================
8 * Licensed under the Apache License, Version 2.0 (the "License");
9 * you may not use this file except in compliance with the License.
10 * You may obtain a copy of the License at
12 * http://www.apache.org/licenses/LICENSE-2.0
14 * Unless required by applicable law or agreed to in writing, software
15 * distributed under the License is distributed on an "AS IS" BASIS,
16 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
17 * See the License for the specific language governing permissions and
18 * limitations under the License.
19 * ============LICENSE_END=========================================================
21 package org.onap.ccsdk.features.sdnr.wt.devicemanager.test;
23 import static org.junit.Assert.assertTrue;
25 import java.util.Arrays;
26 import org.junit.AfterClass;
27 import org.junit.BeforeClass;
28 import org.junit.Test;
29 import org.mockito.Mockito;
30 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.DataProvider;
31 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.HtDatabaseMaintenance;
32 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.IEntityDataProvider;
33 import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.IEsConfig;
34 import org.onap.ccsdk.features.sdnr.wt.devicemanager.impl.DeviceManagerImpl;
35 import org.onap.ccsdk.features.sdnr.wt.devicemanager.impl.util.InternalDateAndTime;
36 import org.onap.ccsdk.features.sdnr.wt.devicemanager.service.FaultService;
37 import org.onap.ccsdk.features.sdnr.wt.devicemanager.service.NotificationService;
38 import org.onap.ccsdk.features.sdnr.wt.devicemanager.test.mock.RpcProviderServiceMock;
39 import org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.NetconfNodeConnectListener;
40 import org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.NetconfNodeStateListener;
41 import org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.NetconfNodeStateService;
42 import org.opendaylight.mdsal.binding.api.DataBroker;
43 import org.opendaylight.mdsal.binding.api.MountPointService;
44 import org.opendaylight.mdsal.binding.api.NotificationPublishService;
45 import org.opendaylight.mdsal.singleton.common.api.ClusterSingletonServiceProvider;
46 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.DateAndTime;
47 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.FaultlogBuilder;
48 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.MaintenanceBuilder;
49 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.devicemanager.rev190109.ClearCurrentFaultByNodenameInputBuilder;
50 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.devicemanager.rev190109.DevicemanagerService;
51 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.devicemanager.rev190109.GetRequiredNetworkElementKeysInputBuilder;
52 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.devicemanager.rev190109.PushAttributeChangeNotificationInputBuilder;
53 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.devicemanager.rev190109.PushFaultNotificationInputBuilder;
54 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.devicemanager.rev190109.ShowRequiredNetworkElementInputBuilder;
55 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.websocketmanager.rev150105.WebsocketmanagerService;
56 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
57 import org.opendaylight.yangtools.concepts.ListenerRegistration;
58 import org.slf4j.Logger;
59 import org.slf4j.LoggerFactory;
61 @SuppressWarnings("deprecation")
62 public class TestDevicemanager extends Mockito {
64 private static final Logger log = LoggerFactory.getLogger(TestDevicemanager.class);
66 private static DeviceManagerImpl deviceManager = new DeviceManagerImpl();
67 private static DevicemanagerService apiService;
68 private static HtDatabaseMaintenance htDataBaseMaintenance = mock(HtDatabaseMaintenance.class);
71 public static void before() throws Exception {
73 DataBroker dataBroker = mock(DataBroker.class);
74 RpcProviderServiceMock rpcProviderRegistry = new RpcProviderServiceMock();
75 NotificationPublishService notificationPublishService = mock(NotificationPublishService.class);
76 MountPointService mountPointService = mock(MountPointService.class);
77 ClusterSingletonServiceProvider clusterSingletonService = mock(ClusterSingletonServiceProvider.class);
78 NetconfNodeStateService netconfNodeStateService = mock(NetconfNodeStateService.class);
80 @SuppressWarnings("unchecked")
81 ListenerRegistration<NetconfNodeConnectListener> lr1 = mock(ListenerRegistration.class);
82 //doNothing().when(lr1).close();
83 when(netconfNodeStateService.registerNetconfNodeConnectListener(mock(NetconfNodeConnectListener.class)))
86 @SuppressWarnings("unchecked")
87 ListenerRegistration<NetconfNodeStateListener> lr2 = mock(ListenerRegistration.class);
88 //doNothing().when(lr2).close();
89 when(netconfNodeStateService.registerNetconfNodeStateListener(mock(NetconfNodeStateListener.class)))
92 WebsocketmanagerService websocketmanagerService = mock(WebsocketmanagerService.class);
94 IEntityDataProvider iEntityDataProvider = mock(IEntityDataProvider.class);
95 doNothing().when(iEntityDataProvider).setReadyStatus(isA(Boolean.class));
97 DataProvider dataProvider = mock(DataProvider.class);
98 when(iEntityDataProvider.getDataProvider()).thenReturn(dataProvider);
100 when(iEntityDataProvider.getHtDatabaseMaintenance()).thenReturn(htDataBaseMaintenance);
103 IEsConfig esConfig = mock(IEsConfig.class);
104 when(iEntityDataProvider.getEsConfig()).thenReturn(esConfig);
107 deviceManager.setDataBroker(dataBroker);
108 deviceManager.setRpcProviderRegistry(rpcProviderRegistry);
109 deviceManager.setNotificationPublishService(notificationPublishService);
110 deviceManager.setMountPointService(mountPointService);
111 deviceManager.setClusterSingletonService(clusterSingletonService);
112 deviceManager.setNetconfNodeStateService(netconfNodeStateService);
113 deviceManager.setWebsocketmanagerService(websocketmanagerService);
114 deviceManager.setEntityDataProvider(iEntityDataProvider);
116 deviceManager.init();
118 apiService = rpcProviderRegistry.getDeviceManagerApiService();
124 public void testInit() {
125 assertTrue(deviceManager.isDevicemanagerInitializationOk());
129 public void testChangeNotification() {
130 NotificationService n = deviceManager.getNotificationService();
132 n.creationNotification(new NodeId("NodeTest1"), 1, InternalDateAndTime.getTestpatternDateAndTime(), "ObjTest1");
134 n.changeNotification(new NodeId("NodeTest1"), 2, InternalDateAndTime.getTestpatternDateAndTime(), "ObjTest1",
135 "AtrributeTest1", "NewTest1");
137 n.deletionNotification(new NodeId("NodeTest1"), 3, InternalDateAndTime.getTestpatternDateAndTime(), "ObjTest1");
142 public void testFaultNotification() {
143 log.info("testFaultNotification");
145 MaintenanceBuilder mb = new MaintenanceBuilder();
146 when(htDataBaseMaintenance.getMaintenance("")).thenReturn(mb.build());
148 FaultService n = deviceManager.getFaultService();
149 FaultlogBuilder faultLogEntityBuilder = new FaultlogBuilder();
150 n.faultNotification(faultLogEntityBuilder.setNodeId("node1").build());
155 public void testGet() {
157 GetRequiredNetworkElementKeysInputBuilder inputBuilder = new GetRequiredNetworkElementKeysInputBuilder();
158 apiService.getRequiredNetworkElementKeys(inputBuilder.build());
163 public void testShow() {
164 log.info("testShow");
165 ShowRequiredNetworkElementInputBuilder inputBuilder = new ShowRequiredNetworkElementInputBuilder();
166 inputBuilder.setMountpointName("test");
167 apiService.showRequiredNetworkElement(inputBuilder.build());
172 public void testResync() {
173 log.info("testResync");
175 ClearCurrentFaultByNodenameInputBuilder inputBuilder = new ClearCurrentFaultByNodenameInputBuilder();
176 inputBuilder.setNodenames(Arrays.asList("test1", "test2"));
177 apiService.clearCurrentFaultByNodename(inputBuilder.build());
182 public void testPushFault() {
183 log.info("testPushFault");
185 PushFaultNotificationInputBuilder inputBuilder = new PushFaultNotificationInputBuilder();
186 inputBuilder.setNodeId("NodeTest23");
187 inputBuilder.setTimestamp(new DateAndTime("2020-01-01T01:02:03.4Z"));
188 apiService.pushFaultNotification(inputBuilder.build());
193 public void testPushChange() {
194 log.info("testPushChange");
196 PushAttributeChangeNotificationInputBuilder inputBuilder = new PushAttributeChangeNotificationInputBuilder();
197 inputBuilder.setNodeId("NodeTest24");
198 apiService.pushAttributeChangeNotification(inputBuilder.build());
204 public static void after() {
205 deviceManager.close();