transcriber/src/main/java/org/opendaylight/neutron/transcriber/NeutronSecurityRuleInterface.java

   1 /*
   2  * Copyright (c) 2014, 2015 Red Hat, 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.neutron.transcriber;
  10
  11 import java.util.ArrayList;
  12 import java.util.HashSet;
  13 import java.util.List;
  14 import java.util.Map.Entry;
  15 import java.util.Set;
  16
  17 import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
  18 import org.opendaylight.neutron.spi.INeutronSecurityRuleCRUD;
  19 import org.opendaylight.neutron.spi.NeutronSecurityRule;
  20 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.IpPrefix;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.constants.rev150712.DirectionBase;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.constants.rev150712.DirectionEgress;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.constants.rev150712.DirectionIngress;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.constants.rev150712.EthertypeBase;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.constants.rev150712.EthertypeV4;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.constants.rev150712.EthertypeV6;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.constants.rev150712.ProtocolBase;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.constants.rev150712.ProtocolHttp;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.constants.rev150712.ProtocolHttps;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.constants.rev150712.ProtocolIcmp;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.constants.rev150712.ProtocolIcmpV6;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.constants.rev150712.ProtocolTcp;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.constants.rev150712.ProtocolUdp;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.secgroups.rev150712.security.rules.attributes.SecurityRules;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.secgroups.rev150712.security.rules.attributes.security.rules.SecurityRule;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.secgroups.rev150712.security.rules.attributes.security.rules.SecurityRuleBuilder;
  38 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  39 import org.osgi.framework.BundleContext;
  40 import org.osgi.framework.ServiceRegistration;
  41 import org.slf4j.Logger;
  42 import org.slf4j.LoggerFactory;
  43
  44 import com.google.common.collect.ImmutableBiMap;
  45
  46
  47 public class NeutronSecurityRuleInterface extends AbstractNeutronInterface<SecurityRule, SecurityRules, NeutronSecurityRule> implements INeutronSecurityRuleCRUD {
  48     private static final Logger LOGGER = LoggerFactory.getLogger(NeutronSecurityRuleInterface.class);
  49
  50     private static final ImmutableBiMap<Class<? extends DirectionBase>,String> DIRECTION_MAP
  51             = new ImmutableBiMap.Builder<Class<? extends DirectionBase>,String>()
  52             .put(DirectionEgress.class,"egress")
  53             .put(DirectionIngress.class,"ingress")
  54             .build();
  55     private static final ImmutableBiMap<Class<? extends ProtocolBase>,String> PROTOCOL_MAP
  56             = new ImmutableBiMap.Builder<Class<? extends ProtocolBase>,String>()
  57             .put(ProtocolIcmp.class,"icmp")
  58             .put(ProtocolTcp.class,"tcp")
  59             .put(ProtocolUdp.class,"udp")
  60             .put(ProtocolIcmpV6.class,"icmpv6")
  61             .build();
  62     private static final ImmutableBiMap<Class<? extends EthertypeBase>,String> ETHERTYPE_MAP
  63             = new ImmutableBiMap.Builder<Class<? extends EthertypeBase>,String>()
  64             .put(EthertypeV4.class,"IPv4")
  65             .put(EthertypeV6.class,"IPv6")
  66             .build();
  67
  68     NeutronSecurityRuleInterface(ProviderContext providerContext) {
  69         super(providerContext);
  70     }
  71
  72     @Override
  73     public boolean neutronSecurityRuleExists(String uuid) {
  74         return exists(uuid);
  75     }
  76
  77     @Override
  78     public NeutronSecurityRule getNeutronSecurityRule(String uuid) {
  79         return get(uuid);
  80     }
  81
  82     @Override
  83     protected List<SecurityRule> getDataObjectList(SecurityRules rules) {
  84         return rules.getSecurityRule();
  85     }
  86
  87     @Override
  88     public List<NeutronSecurityRule> getAllNeutronSecurityRules() {
  89         return getAll();
  90     }
  91
  92     @Override
  93     public boolean addNeutronSecurityRule(NeutronSecurityRule input) {
  94         return add(input);
  95     }
  96
  97     @Override
  98     public boolean removeNeutronSecurityRule(String uuid) {
  99         return remove(uuid);
 100     }
 101
 102     @Override
 103     public boolean updateNeutronSecurityRule(String uuid, NeutronSecurityRule delta) {
 104         return update(uuid, delta);
 105     }
 106
 107     @Override
 108     public boolean neutronSecurityRuleInUse(String securityRuleUUID) {
 109         return !exists(securityRuleUUID);
 110     }
 111
 112     protected NeutronSecurityRule fromMd(SecurityRule rule) {
 113         NeutronSecurityRule answer = new NeutronSecurityRule();
 114         if (rule.getTenantId() != null) {
 115             answer.setTenantID(rule.getTenantId());
 116         }
 117         if (rule.getDirection() != null) {
 118             answer.setSecurityRuleDirection(DIRECTION_MAP.get(rule.getDirection()));
 119         }
 120         if (rule.getSecurityGroupId() != null) {
 121             answer.setSecurityRuleGroupID(rule.getSecurityGroupId().getValue());
 122         }
 123         if (rule.getRemoteGroupId() != null) {
 124             answer.setSecurityRemoteGroupID(rule.getRemoteGroupId().getValue());
 125         }
 126         if (rule.getRemoteIpPrefix() != null) {
 127             answer.setSecurityRuleRemoteIpPrefix(new String(rule.getRemoteIpPrefix().getValue()));
 128         }
 129         if (rule.getProtocol() != null) {
 130             answer.setSecurityRuleProtocol(PROTOCOL_MAP.get(rule.getProtocol()));
 131         }
 132         if (rule.getEthertype() != null) {
 133             answer.setSecurityRuleEthertype(ETHERTYPE_MAP.get(rule.getEthertype()));
 134         }
 135         if (rule.getPortRangeMin() != null) {
 136             answer.setSecurityRulePortMin(Integer.valueOf(rule.getPortRangeMin()));
 137         }
 138         if (rule.getPortRangeMax() != null) {
 139             answer.setSecurityRulePortMax(Integer.valueOf(rule.getPortRangeMax()));
 140         }
 141         if (rule.getId() != null) {
 142             answer.setID(rule.getId().getValue());
 143         }
 144         return answer;
 145     }
 146
 147     @Override
 148     protected SecurityRule toMd(NeutronSecurityRule securityRule) {
 149         SecurityRuleBuilder securityRuleBuilder = new SecurityRuleBuilder();
 150
 151         if (securityRule.getTenantID() != null) {
 152             securityRuleBuilder.setTenantId(toUuid(securityRule.getTenantID()));
 153         }
 154         if (securityRule.getSecurityRuleDirection() != null) {
 155             ImmutableBiMap<String, Class<? extends DirectionBase>> mapper =
 156                     DIRECTION_MAP.inverse();
 157             securityRuleBuilder.setDirection((Class<? extends DirectionBase>) mapper.get(securityRule.getSecurityRuleDirection()));
 158         }
 159         if (securityRule.getSecurityRuleGroupID() != null) {
 160             securityRuleBuilder.setSecurityGroupId(toUuid(securityRule.getSecurityRuleGroupID()));
 161         }
 162         if (securityRule.getSecurityRemoteGroupID() != null) {
 163             securityRuleBuilder.setRemoteGroupId(toUuid(securityRule.getSecurityRemoteGroupID()));
 164         }
 165         if (securityRule.getSecurityRuleRemoteIpPrefix() != null) {
 166             IpPrefix ipPrefix = new IpPrefix(securityRule.getSecurityRuleRemoteIpPrefix().toCharArray());
 167             securityRuleBuilder.setRemoteIpPrefix(ipPrefix);
 168         }
 169         if (securityRule.getSecurityRuleProtocol() != null) {
 170             ImmutableBiMap<String, Class<? extends ProtocolBase>> mapper =
 171                     PROTOCOL_MAP.inverse();
 172             securityRuleBuilder.setProtocol((Class<? extends ProtocolBase>) mapper.get(securityRule.getSecurityRuleProtocol()));
 173         }
 174         if (securityRule.getSecurityRuleEthertype() != null) {
 175             ImmutableBiMap<String, Class<? extends EthertypeBase>> mapper =
 176                     ETHERTYPE_MAP.inverse();
 177             securityRuleBuilder.setEthertype((Class<? extends EthertypeBase>) mapper.get(securityRule.getSecurityRuleEthertype()));
 178         }
 179         if (securityRule.getSecurityRulePortMin() != null) {
 180             securityRuleBuilder.setPortRangeMin(Integer.valueOf(securityRule.getSecurityRulePortMin()));
 181         }
 182         if (securityRule.getSecurityRulePortMax() != null) {
 183             securityRuleBuilder.setPortRangeMax(Integer.valueOf(securityRule.getSecurityRulePortMax()));
 184         }
 185         if (securityRule.getID() != null) {
 186             securityRuleBuilder.setId(toUuid(securityRule.getID()));
 187         } else {
 188             LOGGER.warn("Attempting to write neutron securityRule without UUID");
 189         }
 190         return securityRuleBuilder.build();
 191     }
 192
 193     @Override
 194     protected InstanceIdentifier<SecurityRule> createInstanceIdentifier(SecurityRule securityRule) {
 195         return InstanceIdentifier.create(Neutron.class)
 196             .child(SecurityRules.class).child(SecurityRule.class,
 197                                               securityRule.getKey());
 198     }
 199
 200     @Override
 201     protected InstanceIdentifier<SecurityRules> createInstanceIdentifier() {
 202         return InstanceIdentifier.create(Neutron.class)
 203             .child(SecurityRules.class);
 204     }
 205
 206     @Override
 207     protected SecurityRule toMd(String uuid) {
 208         SecurityRuleBuilder securityRuleBuilder = new SecurityRuleBuilder();
 209         securityRuleBuilder.setId(toUuid(uuid));
 210         return securityRuleBuilder.build();
 211     }
 212
 213     public static void registerNewInterface(BundleContext context,
 214                                             ProviderContext providerContext,
 215                                             List<ServiceRegistration<?>> registrations) {
 216         NeutronSecurityRuleInterface neutronSecurityRuleInterface = new NeutronSecurityRuleInterface(providerContext);
 217         ServiceRegistration<INeutronSecurityRuleCRUD> neutronSecurityRuleInterfaceRegistration = context.registerService(INeutronSecurityRuleCRUD.class, neutronSecurityRuleInterface, null);
 218         if(neutronSecurityRuleInterfaceRegistration != null) {
 219             registrations.add(neutronSecurityRuleInterfaceRegistration);
 220         }
 221     }
 222 }