--- /dev/null
+/*******************************************************************************
+ * ============LICENSE_START========================================================================
+ * ONAP : ccsdk feature sdnr wt
+ * =================================================================================================
+ * Copyright (C) 2019 highstreet technologies GmbH Intellectual Property. All rights reserved.
+ * =================================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
+ * in compliance with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software distributed under the License
+ * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
+ * or implied. See the License for the specific language governing permissions and limitations under
+ * the License.
+ * ============LICENSE_END==========================================================================
+ ******************************************************************************/
+package org.onap.ccsdk.features.sdnr.wt.devicemanager.datamanager;
+
+import java.util.List;
+import org.eclipse.jdt.annotation.NonNull;
+import org.eclipse.jdt.annotation.Nullable;
+import org.onap.ccsdk.features.sdnr.wt.common.HtAssert;
+import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.DataProvider;
+import org.onap.ccsdk.features.sdnr.wt.devicemanager.impl.xml.AttributeValueChangedNotificationXml;
+import org.onap.ccsdk.features.sdnr.wt.devicemanager.impl.xml.ObjectCreationNotificationXml;
+import org.onap.ccsdk.features.sdnr.wt.devicemanager.impl.xml.ObjectDeletionNotificationXml;
+import org.onap.ccsdk.features.sdnr.wt.devicemanager.impl.xml.ProblemNotificationXml;
+import org.onap.ccsdk.features.sdnr.wt.devicemanager.impl.xml.WebSocketServiceClientInternal;
+import org.onap.ccsdk.features.sdnr.wt.devicemanager.service.EquipmentService;
+import org.onap.ccsdk.features.sdnr.wt.devicemanager.service.FaultService;
+import org.onap.ccsdk.features.sdnr.wt.devicemanager.service.NotificationService;
+import org.onap.ccsdk.features.sdnr.wt.devicemanager.types.EquipmentData;
+import org.onap.ccsdk.features.sdnr.wt.devicemanager.types.EventlogNotificationBuilder;
+import org.onap.ccsdk.features.sdnr.wt.devicemanager.types.FaultData;
+import org.onap.ccsdk.features.sdnr.wt.devicemanager.types.FaultNotificationBuilder2;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.DateAndTime;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.EventlogEntity;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.Faultcurrent;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.FaultcurrentBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.FaultlogEntity;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.Inventory;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.SeverityType;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev190801.SourceType;
+import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
+
+/**
+ * @author herbert
+ *
+ */
+public class DeviceManagerDatabaseNotificationService implements NotificationService, EquipmentService, FaultService {
+
+ private final DataProvider databaseService;
+ private final WebSocketServiceClientInternal webSocketService;
+
+ /**
+ * @param databaseService to access database
+ * @param webSocketService to send notifications
+ */
+ public DeviceManagerDatabaseNotificationService(DataProvider databaseService,
+ WebSocketServiceClientInternal webSocketService) {
+ super();
+ HtAssert.nonnull(databaseService);
+ HtAssert.nonnull(webSocketService);
+
+ this.databaseService = databaseService;
+ this.webSocketService = webSocketService;
+ }
+
+ @Override
+ public void eventNotification(@NonNull EventlogEntity eventNotification) {
+ String nodeId = eventNotification.getNodeId();
+ if (nodeId == null) {
+ nodeId = "EmptyNodeId";
+ }
+ databaseService.writeEventLog(eventNotification);
+ webSocketService.sendViaWebsockets(nodeId, new AttributeValueChangedNotificationXml(eventNotification));
+ }
+
+ @Override
+ public void changeNotification(NodeId nodeId, @Nullable Integer counter, @Nullable DateAndTime timeStamp,
+ @Nullable String objectId, @Nullable String attributeName, @Nullable String newValue) {
+ EventlogEntity eventlogEntity = new EventlogNotificationBuilder(nodeId, counter, timeStamp, objectId, attributeName, newValue).build();
+ databaseService.writeEventLog(eventlogEntity);
+ webSocketService.sendViaWebsockets(nodeId.getValue(), new AttributeValueChangedNotificationXml(eventlogEntity));
+ }
+
+ @Override
+ public void creationNotification(NodeId nodeId, @Nullable Integer counter, @Nullable DateAndTime timeStamp,
+ @Nullable String objectId) {
+ EventlogEntity eventlogEntity = new EventlogNotificationBuilder(nodeId, counter, timeStamp, objectId, "creation", null).build();
+ databaseService.writeEventLog(eventlogEntity);
+ webSocketService.sendViaWebsockets(nodeId.getValue(), new ObjectCreationNotificationXml(eventlogEntity));
+ }
+
+
+ @Override
+ public void deletionNotification(NodeId nodeId, @Nullable Integer counter, @Nullable DateAndTime timeStamp,
+ @Nullable String objectId) {
+ EventlogEntity eventlogEntity = new EventlogNotificationBuilder(nodeId, counter, timeStamp, objectId, "deletion", null).build();
+ databaseService.writeEventLog(eventlogEntity);
+ webSocketService.sendViaWebsockets(nodeId.getValue(), new ObjectDeletionNotificationXml(eventlogEntity));
+ }
+
+ @Override
+ public void writeEquipment(@NonNull EquipmentData equipment) {
+ //equipment.getList().forEach(card -> databaseService.writeInventory(card));
+ HtAssert.nonnull(equipment);
+ List<Inventory> list = equipment.getList();
+ HtAssert.nonnull(list);
+ for (Inventory card : list) {
+ databaseService.writeInventory(card);
+ }
+ }
+
+ @Override
+ public void faultNotification(@NonNull FaultlogEntity faultNotification) {
+ databaseService.writeFaultLog(faultNotification);
+ databaseService.updateFaultCurrent(getFaultCurrent(faultNotification));
+
+ ProblemNotificationXml notificationXml = new ProblemNotificationXml(faultNotification);
+ String nodeName = faultNotification.getNodeId();
+ // ToggleAlarmFilter functionality
+// if (delayFilter.processNotification(notificationXml.getSeverity() == InternalSeverity.NonAlarmed, notificationXml.getProblem(), notificationXml))
+// {
+// dcaeForwarder.sendProblemNotificationUsingMaintenanceFilter(nodeName, notificationXml);
+// }
+ // end of ToggleAlarmFilter
+
+ this.webSocketService.sendViaWebsockets(nodeName, notificationXml);
+ }
+
+ @Override
+ public void faultNotification(@NonNull NodeId nodeId, @Nullable Integer counter, @Nullable DateAndTime timeStamp,
+ @Nullable String objectId, @Nullable String problem, @Nullable SeverityType severity) {
+ FaultNotificationBuilder2 bFaultlog = new FaultNotificationBuilder2(nodeId, counter, timeStamp, objectId, problem, severity, SourceType.Netconf);
+ faultNotification(bFaultlog.build());
+
+ }
+
+ @Override
+ public int removeAllCurrentProblemsOfNode(@NonNull NodeId nodeId) {
+ int deleted = databaseService.clearFaultsCurrentOfNode(nodeId.getValue());
+ return deleted;
+ }
+
+ @Override
+ public void initCurrentProblemStatus(@NonNull NodeId nodeId, FaultData resultList) {
+ resultList.getProblemList().forEach(problem -> {
+ FaultcurrentBuilder bFaultcurrent = new FaultcurrentBuilder();
+ bFaultcurrent.fieldsFrom(problem);
+ databaseService.updateFaultCurrent(bFaultcurrent.build());
+ });
+ }
+
+ @Override
+ public int removeObjectsCurrentProblemsOfNode(@NonNull NodeId nodeId, String objectId) {
+ int deleted = databaseService.clearFaultsCurrentOfNodeWithObjectId(nodeId.getValue(), objectId);
+ return deleted;
+ }
+
+ private Faultcurrent getFaultCurrent(@NonNull FaultlogEntity problem) {
+ FaultcurrentBuilder bFaultcurrent = new FaultcurrentBuilder();
+ bFaultcurrent.fieldsFrom(problem);
+ return bFaultcurrent.build();
+
+ }
+}
Code Review / ccsdk / features.git / blobdiff