2 * Copyright © 2020 Orange, Inc. and others. All rights reserved.
4 * This program and the accompanying materials are made available under the
5 * terms of the Eclipse Public License v1.0 which accompanies this distribution,
6 * and is available at http://www.eclipse.org/legal/epl-v10.html
8 package org.opendaylight.transportpce.nbinotifications.utils;
10 import java.io.IOException;
11 import java.io.InputStream;
12 import java.util.HashMap;
14 import java.util.Properties;
15 import org.opendaylight.yang.gen.v1.nbi.notifications.rev211013.NotificationTapiService;
16 import org.opendaylight.yang.gen.v1.nbi.notifications.rev211013.NotificationTapiServiceBuilder;
17 import org.opendaylight.yang.gen.v1.nbi.notifications.rev211013.PublishTapiNotificationService;
18 import org.opendaylight.yang.gen.v1.nbi.notifications.rev211013.notification.tapi.service.AdditionalInfo;
19 import org.opendaylight.yang.gen.v1.nbi.notifications.rev211013.notification.tapi.service.AdditionalInfoBuilder;
20 import org.opendaylight.yang.gen.v1.nbi.notifications.rev211013.notification.tapi.service.AdditionalInfoKey;
21 import org.opendaylight.yang.gen.v1.nbi.notifications.rev211013.notification.tapi.service.AlarmInfoBuilder;
22 import org.opendaylight.yang.gen.v1.nbi.notifications.rev211013.notification.tapi.service.ChangedAttributes;
23 import org.opendaylight.yang.gen.v1.nbi.notifications.rev211013.notification.tapi.service.ChangedAttributesBuilder;
24 import org.opendaylight.yang.gen.v1.nbi.notifications.rev211013.notification.tapi.service.ChangedAttributesKey;
25 import org.opendaylight.yang.gen.v1.nbi.notifications.rev211013.notification.tapi.service.TargetObjectName;
26 import org.opendaylight.yang.gen.v1.nbi.notifications.rev211013.notification.tapi.service.TargetObjectNameBuilder;
27 import org.opendaylight.yang.gen.v1.nbi.notifications.rev211013.notification.tapi.service.TargetObjectNameKey;
28 import org.opendaylight.yang.gen.v1.nbi.notifications.rev211013.notification.tapi.service.TcaInfoBuilder;
29 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.global._class.Name;
30 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.global._class.NameBuilder;
31 import org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev181210.global._class.NameKey;
32 import org.slf4j.Logger;
33 import org.slf4j.LoggerFactory;
35 public final class NbiNotificationsUtils {
37 private static final Logger LOG = LoggerFactory.getLogger(NbiNotificationsUtils.class);
39 private NbiNotificationsUtils() {
42 public static Properties loadProperties(String propertyFileName) {
43 Properties props = new Properties();
44 InputStream inputStream = NbiNotificationsUtils.class.getClassLoader().getResourceAsStream(propertyFileName);
46 if (inputStream != null) {
47 props.load(inputStream);
49 LOG.warn("Kafka property file '{}' is empty", propertyFileName);
51 } catch (IOException e) {
52 LOG.error("Kafka property file '{}' was not found in the classpath", propertyFileName, e);
57 public static NotificationTapiService transformTapiNotification(PublishTapiNotificationService notification) {
58 Map<AdditionalInfoKey, AdditionalInfo> addInfoMap = new HashMap<>();
59 if (notification.getAdditionalInfo() != null) {
60 for (org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.notification.rev181210.notification.AdditionalInfo
61 addInfo:notification.getAdditionalInfo().values()) {
62 AdditionalInfo transAddInfo = new AdditionalInfoBuilder(addInfo).build();
63 addInfoMap.put(transAddInfo.key(), transAddInfo);
66 Map<ChangedAttributesKey, ChangedAttributes> changedAttMap = new HashMap<>();
67 if (notification.getChangedAttributes() != null) {
68 for (org.opendaylight.yang.gen.v1
69 .urn.onf.otcc.yang.tapi.notification.rev181210.notification.ChangedAttributes
70 changedAtt:notification.getChangedAttributes().values()) {
71 ChangedAttributes transChangedAtt = new ChangedAttributesBuilder(changedAtt).build();
72 changedAttMap.put(transChangedAtt.key(), transChangedAtt);
75 Map<NameKey, Name> nameMap = new HashMap<>();
76 if (notification.getName() != null) {
77 for (Name name:notification.getName().values()) {
78 Name transName = new NameBuilder(name).build();
79 nameMap.put(transName.key(), transName);
82 Map<TargetObjectNameKey, TargetObjectName> targetObjNameMap = new HashMap<>();
83 if (notification.getTargetObjectName() != null) {
84 for (org.opendaylight.yang.gen.v1
85 .urn.onf.otcc.yang.tapi.notification.rev181210.notification.TargetObjectName
86 targetObjectName:notification.getTargetObjectName().values()) {
87 TargetObjectName transTargetObjName = new TargetObjectNameBuilder(targetObjectName).build();
88 targetObjNameMap.put(transTargetObjName.key(), transTargetObjName);
91 LOG.info("Notification uuid = {}", notification.getUuid());
92 return new NotificationTapiServiceBuilder()
93 .setAlarmInfo(notification.getAlarmInfo() == null ? null
94 : new AlarmInfoBuilder(notification.getAlarmInfo()).build())
95 .setAdditionalText(notification.getAdditionalText())
96 .setAdditionalInfo(addInfoMap)
97 .setNotificationType(notification.getNotificationType())
98 .setChangedAttributes(changedAttMap)
99 .setEventTimeStamp(notification.getEventTimeStamp())
100 .setLayerProtocolName(notification.getLayerProtocolName())
102 .setSequenceNumber(notification.getSequenceNumber())
103 .setSourceIndicator(notification.getSourceIndicator())
104 .setTargetObjectIdentifier(notification.getTargetObjectIdentifier())
105 .setTargetObjectName(targetObjNameMap)
106 .setTargetObjectType(notification.getTargetObjectType())
107 .setTcaInfo(notification.getTcaInfo() == null ? null
108 : new TcaInfoBuilder(notification.getTcaInfo()).build())
109 .setUuid(notification.getUuid())