openstack/net-virt/src/main/java/org/opendaylight/netvirt/openstack/netvirt/translator/iaware/impl/NeutronSecurityGroupDataChangeListener.java

   1 /*
   2  * Copyright (c) 2015 Brocade Communications 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 package org.opendaylight.netvirt.openstack.netvirt.translator.iaware.impl;
   9
  10 import java.util.ArrayList;
  11 import java.util.List;
  12 import java.util.Map.Entry;
  13
  14 import org.opendaylight.controller.md.sal.binding.api.ClusteredDataChangeListener;
  15 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  16 import org.opendaylight.controller.md.sal.binding.api.DataChangeListener;
  17 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataBroker.DataChangeScope;
  18 import org.opendaylight.controller.md.sal.common.api.data.AsyncDataChangeEvent;
  19 import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
  20 import org.opendaylight.netvirt.openstack.netvirt.translator.crud.INeutronSecurityRuleCRUD;
  21 import org.opendaylight.netvirt.openstack.netvirt.translator.NeutronSecurityGroup;
  22 import org.opendaylight.netvirt.openstack.netvirt.translator.NeutronSecurityRule;
  23 import org.opendaylight.netvirt.openstack.netvirt.translator.crud.NeutronCRUDInterfaces;
  24 import org.opendaylight.netvirt.openstack.netvirt.translator.iaware.INeutronSecurityGroupAware;
  25 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.Uuid;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.secgroups.rev150712.security.groups.attributes.SecurityGroups;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.secgroups.rev150712.security.groups.attributes.security.groups.SecurityGroup;
  29 import org.opendaylight.yangtools.concepts.ListenerRegistration;
  30 import org.opendaylight.yangtools.yang.binding.DataObject;
  31 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  32 import org.slf4j.Logger;
  33 import org.slf4j.LoggerFactory;
  34
  35 public class NeutronSecurityGroupDataChangeListener implements ClusteredDataChangeListener, AutoCloseable {
  36     private static final Logger LOG = LoggerFactory
  37             .getLogger(NeutronSecurityGroupDataChangeListener.class);
  38
  39     private ListenerRegistration<DataChangeListener> registration;
  40     private DataBroker db;
  41
  42     public NeutronSecurityGroupDataChangeListener(DataBroker db) {
  43         this.db = db;
  44         InstanceIdentifier<SecurityGroup> path = InstanceIdentifier
  45                 .create(Neutron.class).child(SecurityGroups.class)
  46                 .child(SecurityGroup.class);
  47         LOG.debug("Register listener for Neutron Secutiry group model data changes");
  48         registration = this.db.registerDataChangeListener(
  49                 LogicalDatastoreType.CONFIGURATION, path, this,
  50                 DataChangeScope.ONE);
  51
  52     }
  53
  54     @Override
  55     public void onDataChanged(
  56             AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> changes) {
  57         LOG.trace("Data changes : {}", changes);
  58
  59         Object[] subscribers = NeutronIAwareUtil.getInstances(
  60                 INeutronSecurityGroupAware.class, this);
  61         createSecurityGroup(changes, subscribers);
  62         updateSecurityGroup(changes, subscribers);
  63         deleteSecurityGroup(changes, subscribers);
  64     }
  65
  66     private void createSecurityGroup(
  67             AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> changes,
  68             Object[] subscribers) {
  69         for (Entry<InstanceIdentifier<?>, DataObject> newSecutiryGroup : changes
  70                 .getCreatedData().entrySet()) {
  71             if (newSecutiryGroup.getValue() instanceof SecurityGroup) {
  72                 NeutronSecurityGroup secutiryGroup = fromMd((SecurityGroup) newSecutiryGroup
  73                         .getValue());
  74                 for (Object entry : subscribers) {
  75                     INeutronSecurityGroupAware subscriber = (INeutronSecurityGroupAware) entry;
  76                     subscriber.neutronSecurityGroupCreated(secutiryGroup);
  77                 }
  78             }
  79         }
  80
  81     }
  82
  83     private void updateSecurityGroup(
  84             AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> changes,
  85             Object[] subscribers) {
  86         for (Entry<InstanceIdentifier<?>, DataObject> updateSecurityGroup : changes
  87                 .getUpdatedData().entrySet()) {
  88             if (updateSecurityGroup.getValue() instanceof SecurityGroup) {
  89                 NeutronSecurityGroup securityGroup = fromMd((SecurityGroup) updateSecurityGroup
  90                         .getValue());
  91                 for (Object entry : subscribers) {
  92                     INeutronSecurityGroupAware subscriber = (INeutronSecurityGroupAware) entry;
  93                     subscriber.neutronSecurityGroupUpdated(securityGroup);
  94                 }
  95             }
  96         }
  97     }
  98
  99     private void deleteSecurityGroup(
 100             AsyncDataChangeEvent<InstanceIdentifier<?>, DataObject> changes,
 101             Object[] subscribers) {
 102         for (InstanceIdentifier<?> deletedSecurityGroup : changes
 103                 .getRemovedPaths()) {
 104             if (deletedSecurityGroup.getTargetType()
 105                     .equals(SecurityGroup.class)) {
 106                 NeutronSecurityGroup securityGroup = fromMd((SecurityGroup) changes
 107                         .getOriginalData().get(deletedSecurityGroup));
 108                 for (Object entry : subscribers) {
 109                     INeutronSecurityGroupAware subscriber = (INeutronSecurityGroupAware) entry;
 110                     subscriber.neutronSecurityGroupDeleted(securityGroup);
 111                 }
 112             }
 113         }
 114     }
 115
 116     private NeutronSecurityGroup fromMd(SecurityGroup group) {
 117         NeutronSecurityGroup answer = new NeutronSecurityGroup();
 118         if (group.getName() != null) {
 119             answer.setSecurityGroupName(group.getName());
 120         }
 121         if (group.getTenantId() != null) {
 122             answer.setSecurityGroupTenantID(group.getTenantId().getValue()
 123                     .replace("-", ""));
 124         }
 125         if (group.getUuid() != null) {
 126             answer.setID(group.getUuid().getValue());
 127         }
 128         return answer;
 129     }
 130
 131     @Override
 132     public void close() throws Exception {
 133         registration.close();
 134     }
 135 }