sdnr/wt/devicemanager-openroadm/provider/src/main/java/org/onap/ccsdk/features/sdnr/wt/devicemanager/openroadm/impl/OpenroadmFaultNotificationListener.java

   1 /*
   2  * ============LICENSE_START=======================================================
   3  * ONAP : ccsdk features
   4  * ================================================================================
   5  * Copyright (C) 2020 highstreet technologies GmbH Intellectual Property.
   6  * All rights reserved.
   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
  11  *
  12  *     http://www.apache.org/licenses/LICENSE-2.0
  13  *
  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=========================================================
  20  *
  21  */
  22 package org.onap.ccsdk.features.sdnr.wt.devicemanager.openroadm.impl;
  23
  24
  25 import org.eclipse.jdt.annotation.NonNull;
  26 //import org.onap.ccsdk.features.sdnr.wt.dataprovider.model.DataProvider;
  27 import org.onap.ccsdk.features.sdnr.wt.devicemanager.service.DeviceManagerServiceProvider;
  28 import org.onap.ccsdk.features.sdnr.wt.devicemanager.service.FaultService;
  29 import org.onap.ccsdk.features.sdnr.wt.netconfnodestateservice.NetconfAccessor;
  30 import org.opendaylight.yang.gen.v1.http.org.openroadm.alarm.rev191129.AlarmNotification;
  31 import org.opendaylight.yang.gen.v1.http.org.openroadm.alarm.rev191129.OrgOpenroadmAlarmListener;
  32 import org.opendaylight.yang.gen.v1.http.org.openroadm.alarm.rev191129.Severity;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.FaultlogBuilder;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.FaultlogEntity;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.data.provider.rev201110.SeverityType;
  36 import org.slf4j.Logger;
  37 import org.slf4j.LoggerFactory;
  38
  39 /**
  40  * @author Shabnam Sultana
  41  *
  42  *         Listener for Open roadm device specific alarm notifications
  43  **/
  44 public class OpenroadmFaultNotificationListener implements OrgOpenroadmAlarmListener {
  45     private static final Logger log = LoggerFactory.getLogger(OrgOpenroadmAlarmListener.class);
  46     //private final NetconfAccessor accesor;
  47     //private final DataProvider databaseProvider;
  48     private final @NonNull FaultService faultEventListener;
  49     private Integer count = 1;
  50
  51     public OpenroadmFaultNotificationListener(NetconfAccessor netConfAccessor,
  52             DeviceManagerServiceProvider serviceProvider) {
  53         //this.databaseProvider = serviceProvider.getDataProvider();
  54         //this.accesor = netConfAccessor;
  55         this.faultEventListener = serviceProvider.getFaultService();
  56
  57     }
  58
  59     @Override
  60     public void onAlarmNotification(AlarmNotification notification) {
  61
  62         log.info("AlarmNotification {} \t {}", notification.getId(), notification.getAdditionalDetail());
  63
  64         FaultlogEntity faultAlarm = new FaultlogBuilder().setObjectId(notification.getCircuitId())
  65                 .setProblem(notification.getProbableCause().getCause().getName())
  66                 .setTimestamp(notification.getRaiseTime()).setId(notification.getId())
  67                 .setNodeId(notification.getResource().getDevice().getNodeId().getValue())
  68                 .setSeverity(checkSeverityValue(notification.getSeverity())).setCounter(count).build();
  69
  70         //this.databaseProvider.writeFaultLog(faultAlarm);
  71         this.faultEventListener.faultNotification(faultAlarm);
  72         count++;
  73         log.info("Notification is written into the database {}", faultAlarm.getObjectId());
  74
  75     }
  76
  77
  78     // Mapping Severity of AlarmNotification to SeverityType of FaultLog
  79     private SeverityType checkSeverityValue(Severity severity) {
  80         SeverityType severityType = null;
  81         log.info("Device Severity: {}", severity.getName());
  82
  83         switch (severity.getName()) {
  84             case ("warning"):
  85                 severityType = SeverityType.Warning;
  86                 break;
  87             case ("major"):
  88                 severityType = SeverityType.Major;
  89                 break;
  90             case ("minor"):
  91                 severityType = SeverityType.Minor;
  92                 break;
  93             case ("clear"):
  94                 severityType = SeverityType.NonAlarmed;
  95                 break;
  96             case ("critical"):
  97                 severityType = SeverityType.Critical;
  98                 break;
  99             case ("indeterminate"):
 100                 severityType = SeverityType.Critical;
 101                 break;
 102             default:
 103                 severityType = SeverityType.Critical;
 104                 break;
 105         }
 106         return severityType;
 107
 108     }
 109
 110 }