opendaylight/md-sal/messagebus-impl/src/main/java/org/opendaylight/controller/messagebus/app/impl/Topic.java

   1 /*
   2  * Copyright (c) 2013 Cisco Systems, Inc. and others.  All rights reserved.
   3  *
   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
   7  */
   8
   9 package org.opendaylight.controller.messagebus.app.impl;
  10
  11 import com.google.common.base.Preconditions;
  12 import java.util.regex.Pattern;
  13 import org.opendaylight.controller.md.sal.binding.api.DataChangeListener;
  14 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeEvent;
  15 import org.opendaylight.controller.mdsal.MdSAL;
  16 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.messagebus.eventaggregator.rev141202.NotificationPattern;
  17 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.messagebus.eventaggregator.rev141202.TopicId;
  18 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.messagebus.eventsource.rev141202.EventSourceService;
  19 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.messagebus.eventsource.rev141202.JoinTopicInput;
  20 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.messagebus.eventsource.rev141202.JoinTopicInputBuilder;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRef;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
  24 import org.opendaylight.yangtools.yang.binding.DataObject;
  25 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  26 import org.slf4j.LoggerFactory;
  27
  28 public class Topic implements DataChangeListener {
  29     private static final org.slf4j.Logger LOG = LoggerFactory.getLogger(Topic.class);
  30     private final NotificationPattern notificationPattern;
  31     private final Pattern nodeIdPattern;
  32     private final TopicId topicId;
  33     private final MdSAL mdSal;
  34
  35     public Topic(final NotificationPattern notificationPattern, final String nodeIdPattern, final MdSAL mdSal) {
  36         this.notificationPattern = Preconditions.checkNotNull(notificationPattern);
  37
  38         // FIXME: regex should be the language of nodeIdPattern
  39         final String regex = Util.wildcardToRegex(nodeIdPattern);
  40         this.nodeIdPattern = Pattern.compile(regex);
  41         this.mdSal = Preconditions.checkNotNull(mdSal);
  42
  43         // FIXME: We need to perform some salting in order to make
  44         //        the topic IDs less predictable.
  45         this.topicId = new TopicId(Util.md5String(notificationPattern + nodeIdPattern));
  46     }
  47
  48     public TopicId getTopicId() {
  49         return topicId;
  50     }
  51
  52     @Override
  53     public void onDataChanged(final AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> event) {
  54         // TODO: affected must return topologyNode !!!
  55         final Node node = Util.getAffectedNode(event);
  56         if (nodeIdPattern.matcher(node.getId().getValue()).matches()) {
  57             notifyNode(node.getId());
  58         } else {
  59             LOG.debug("Skipping node {}", node.getId());
  60         }
  61     }
  62
  63     public void notifyNode(final NodeId nodeId) {
  64         JoinTopicInput jti = getJoinTopicInputArgument(nodeId);
  65         EventSourceService ess = mdSal.getRpcService(EventSourceService.class);
  66         Preconditions.checkState(ess != null, "EventSourceService is not registered");
  67
  68         ess.joinTopic(jti);
  69     }
  70
  71     private JoinTopicInput getJoinTopicInputArgument(final NodeId nodeId) {
  72         NodeRef nodeRef = MdSAL.createNodeRef(nodeId);
  73         JoinTopicInput jti =
  74                 new JoinTopicInputBuilder()
  75                         .setNode(nodeRef.getValue())
  76                         .setTopicId(topicId)
  77                         .setNotificationPattern(notificationPattern)
  78                         .build();
  79         return jti;
  80     }
  81 }