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.listener;
12 import org.opendaylight.mdsal.binding.api.NotificationService.CompositeListener;
13 import org.opendaylight.transportpce.nbinotifications.producer.Publisher;
14 import org.opendaylight.transportpce.nbinotifications.utils.NbiNotificationsUtils;
15 import org.opendaylight.yang.gen.v1.nbi.notifications.rev230726.NotificationAlarmService;
16 import org.opendaylight.yang.gen.v1.nbi.notifications.rev230726.NotificationAlarmServiceBuilder;
17 import org.opendaylight.yang.gen.v1.nbi.notifications.rev230726.NotificationProcessService;
18 import org.opendaylight.yang.gen.v1.nbi.notifications.rev230726.NotificationProcessServiceBuilder;
19 import org.opendaylight.yang.gen.v1.nbi.notifications.rev230726.NotificationTapiService;
20 import org.opendaylight.yang.gen.v1.nbi.notifications.rev230726.NotificationTapiServiceBuilder;
21 import org.opendaylight.yang.gen.v1.nbi.notifications.rev230726.PublishNotificationAlarmService;
22 import org.opendaylight.yang.gen.v1.nbi.notifications.rev230726.PublishNotificationProcessService;
23 import org.opendaylight.yang.gen.v1.nbi.notifications.rev230726.PublishTapiNotificationService;
24 import org.slf4j.Logger;
25 import org.slf4j.LoggerFactory;
27 public class NbiNotificationsHandler {
28 private static final Logger LOG = LoggerFactory.getLogger(NbiNotificationsHandler.class);
29 private Map<String, Publisher<NotificationProcessService>> publishersServiceMap;
30 private Map<String, Publisher<NotificationAlarmService>> publishersAlarmMap;
31 private Map<String, Publisher<NotificationTapiService>> tapiPublisherMap;
33 public NbiNotificationsHandler(Map<String, Publisher<NotificationProcessService>> publishersServiceMap,
34 Map<String, Publisher<NotificationAlarmService>> publishersAlarmMap,
35 Map<String, Publisher<NotificationTapiService>> tapiPublisherMap) {
36 this.publishersServiceMap = publishersServiceMap;
37 this.publishersAlarmMap = publishersAlarmMap;
38 this.tapiPublisherMap = tapiPublisherMap;
41 public CompositeListener getCompositeListener() {
42 return new CompositeListener(Set.of(
43 new CompositeListener.Component<>(
44 PublishNotificationProcessService.class, this::onPublishNotificationProcessService),
45 new CompositeListener.Component<>(
46 PublishNotificationAlarmService.class, this::onPublishNotificationAlarmService),
47 new CompositeListener.Component<>(
48 PublishTapiNotificationService.class, this::onPublishTapiNotificationService)
52 void onPublishNotificationProcessService(PublishNotificationProcessService notification) {
53 LOG.info("Receiving request for publishing notification service");
54 String publisherName = notification.getPublisherName();
55 if (!publishersServiceMap.containsKey(publisherName)) {
56 LOG.error("Unknown publisher {}", publisherName);
59 Publisher<NotificationProcessService> publisher = publishersServiceMap.get(publisherName);
60 NotificationProcessServiceBuilder notificationProcessServiceBuilder = new NotificationProcessServiceBuilder()
61 .setCommonId(notification.getCommonId())
62 .setConnectionType(notification.getConnectionType())
63 .setMessage(notification.getMessage())
64 .setOperationalState(notification.getOperationalState())
65 .setResponseFailed(notification.getResponseFailed())
66 .setServiceAEnd(notification.getServiceAEnd())
67 .setServiceName(notification.getServiceName())
68 .setServiceZEnd(notification.getServiceZEnd());
70 if (notification.getIsTempService()) {
71 // A-to-Z and Z-to-A containers are only needed for temp-service-create notification
72 publisher.sendEvent(notificationProcessServiceBuilder
73 .setAToZ(notification.getAToZ())
74 .setZToA(notification.getZToA())
75 .build(), notification.getConnectionType().getName());
77 publisher.sendEvent(notificationProcessServiceBuilder
78 .build(), notification.getConnectionType().getName());
82 void onPublishNotificationAlarmService(PublishNotificationAlarmService notification) {
83 LOG.info("Receiving request for publishing notification alarm service");
84 String publisherName = notification.getPublisherName();
85 if (!publishersAlarmMap.containsKey(publisherName)) {
86 LOG.error("Unknown topic {}", publisherName);
89 Publisher<NotificationAlarmService> publisherAlarm = publishersAlarmMap.get(publisherName);
90 publisherAlarm.sendEvent(new NotificationAlarmServiceBuilder()
91 .setConnectionType(notification.getConnectionType())
92 .setMessage(notification.getMessage())
93 .setOperationalState(notification.getOperationalState())
94 .setServiceName(notification.getServiceName())
95 .build(), "alarm" + notification.getConnectionType().getName());
98 void onPublishTapiNotificationService(PublishTapiNotificationService notification) {
99 LOG.info("Receiving request for publishing TAPI notification");
100 String topic = notification.getTopic();
101 if (!tapiPublisherMap.containsKey(topic)) {
102 LOG.error("Unknown topic {}", topic);
105 Publisher<NotificationTapiService> publisher = tapiPublisherMap.get(topic);
106 publisher.sendEvent(new NotificationTapiServiceBuilder(
107 NbiNotificationsUtils.transformTapiNotification(notification)).build(), topic);
110 public void setPublishersServiceMap(Map<String, Publisher<NotificationProcessService>> publishersServiceMap) {
111 this.publishersServiceMap = publishersServiceMap;
114 public void setPublishersAlarmMap(Map<String, Publisher<NotificationAlarmService>> publishersAlarmMap) {
115 this.publishersAlarmMap = publishersAlarmMap;
118 public void setTapiPublishersMap(Map<String, Publisher<NotificationTapiService>> tapiPublishersMap) {
119 this.tapiPublisherMap = tapiPublishersMap;
122 public Publisher<NotificationTapiService> getTapiPublisherFromTopic(String topic) {
123 return this.tapiPublisherMap.get(topic);