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

   1 /*
   2  * Copyright (c) 2013, 2015 IBM Corporation 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.List;
  13 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
  14 import org.opendaylight.neutron.spi.INeutronRouterCRUD;
  15 import org.opendaylight.neutron.spi.NeutronRoute;
  16 import org.opendaylight.neutron.spi.Neutron_IPs;
  17 import org.opendaylight.neutron.spi.NeutronRouter;
  18 import org.opendaylight.neutron.spi.NeutronRouter_NetworkReference;
  19 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
  20 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpPrefix;
  21 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.l3.rev150712.l3.attributes.Routes;
  22 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.l3.rev150712.l3.attributes.RoutesBuilder;
  23 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.l3.rev150712.routers.attributes.Routers;
  24 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.l3.rev150712.routers.attributes.routers.Router;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.l3.rev150712.routers.attributes.routers.RouterBuilder;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.l3.rev150712.routers.attributes.routers.router.ExternalGatewayInfo;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.l3.rev150712.routers.attributes.routers.router.ExternalGatewayInfoBuilder;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.l3.rev150712.routers.attributes.routers.router.external_gateway_info.ExternalFixedIpsBuilder;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.l3.rev150712.routers.attributes.routers.router.external_gateway_info.ExternalFixedIps;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.neutron.rev150712.Neutron;
  31 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  32 import org.slf4j.Logger;
  33 import org.slf4j.LoggerFactory;
  34
  35 public class NeutronRouterInterface extends AbstractNeutronInterface<Router, Routers, NeutronRouter> implements INeutronRouterCRUD {
  36     private static final Logger LOGGER = LoggerFactory.getLogger(NeutronRouterInterface.class);
  37     // methods needed for creating caches
  38
  39
  40     NeutronRouterInterface(DataBroker db) {
  41         super(db);
  42     }
  43
  44
  45     // IfNBRouterCRUD Interface methods
  46     @Override
  47     protected List<Router> getDataObjectList(Routers routers) {
  48         return routers.getRouter();
  49     }
  50
  51     @Override
  52     protected Router toMd(NeutronRouter router) {
  53
  54         final RouterBuilder routerBuilder = new RouterBuilder();
  55
  56         if (router.getID() != null) {
  57             routerBuilder.setUuid(toUuid(router.getID()));
  58         }
  59         if (router.getName() != null) {
  60             routerBuilder.setName(router.getName());
  61         }
  62         if (router.getTenantID() != null && !router.getTenantID().isEmpty()) {
  63             routerBuilder.setTenantId(toUuid(router.getTenantID()));
  64         }
  65         if (router.getStatus() != null) {
  66             routerBuilder.setStatus(router.getStatus());
  67         }
  68         if (router.getGatewayPortId() != null && !router.getGatewayPortId().isEmpty()) {
  69             routerBuilder.setGatewayPortId(toUuid(router.getGatewayPortId()));
  70         }
  71         routerBuilder.setAdminStateUp(router.getAdminStateUp());
  72         routerBuilder.setDistributed(router.getDistributed());
  73         if (router.getRoutes() != null) {
  74             final List<Routes> routes = new ArrayList<Routes>();
  75             for (final NeutronRoute route : router.getRoutes()) {
  76                 final RoutesBuilder routeBuilder = new RoutesBuilder();
  77                 routeBuilder.setDestination(new IpPrefix(route.getDestination().toCharArray()));
  78                 routeBuilder.setNexthop(new IpAddress(route.getNextHop().toCharArray()));
  79                 routes.add(routeBuilder.build());
  80             }
  81             routerBuilder.setRoutes(routes);
  82         }
  83         if (router.getExternalGatewayInfo() != null) {
  84             ExternalGatewayInfo externalGatewayInfo = null;
  85             final List<NeutronRouter_NetworkReference> neutronRouter_NetworkReferences = new ArrayList<NeutronRouter_NetworkReference>();
  86             neutronRouter_NetworkReferences.add(router.getExternalGatewayInfo());
  87             for (final NeutronRouter_NetworkReference externalGatewayInfos : neutronRouter_NetworkReferences) {
  88                 final ExternalGatewayInfoBuilder builder = new ExternalGatewayInfoBuilder();
  89                 builder.setEnableSnat(externalGatewayInfos.getEnableSNAT());
  90                 builder.setExternalNetworkId(toUuid(externalGatewayInfos.getNetworkID()));
  91                 if (externalGatewayInfos.getExternalFixedIPs() != null) {
  92                     final List<ExternalFixedIps> externalFixedIps = new ArrayList<ExternalFixedIps>();
  93                     for (final Neutron_IPs eIP : externalGatewayInfos.getExternalFixedIPs()) {
  94                         final ExternalFixedIpsBuilder eFixedIpBuilder = new ExternalFixedIpsBuilder();
  95                         eFixedIpBuilder.setIpAddress(new IpAddress(eIP.getIpAddress().toCharArray()));
  96                         eFixedIpBuilder.setSubnetId(toUuid(eIP.getSubnetUUID()));
  97                         externalFixedIps.add(eFixedIpBuilder.build());
  98                     }
  99                     builder.setExternalFixedIps(externalFixedIps);
 100                 }
 101                 externalGatewayInfo = builder.build();
 102             }
 103             routerBuilder.setExternalGatewayInfo(externalGatewayInfo);
 104         }
 105         if (router.getID() != null) {
 106             routerBuilder.setUuid(toUuid(router.getID()));
 107         } else {
 108             LOGGER.warn("Attempting to write neutron router without UUID");
 109         }
 110         return routerBuilder.build();
 111     }
 112
 113     @Override
 114     protected InstanceIdentifier<Router> createInstanceIdentifier(Router router) {
 115         return InstanceIdentifier.create(Neutron.class)
 116                  .child(Routers.class)
 117                  .child(Router.class, router.getKey());
 118     }
 119
 120     @Override
 121     protected InstanceIdentifier<Routers> createInstanceIdentifier() {
 122         return InstanceIdentifier.create(Neutron.class).child(Routers.class);
 123     }
 124
 125     @Override
 126     protected Router toMd(String uuid) {
 127         final RouterBuilder routerBuilder = new RouterBuilder();
 128         routerBuilder.setUuid(toUuid(uuid));
 129         return routerBuilder.build();
 130     }
 131
 132     public NeutronRouter fromMd(Router router) {
 133         final NeutronRouter result = new NeutronRouter();
 134         result.setID(router.getUuid().getValue());
 135         result.setName(router.getName());
 136         result.setTenantID(router.getTenantId());
 137         result.setAdminStateUp(router.isAdminStateUp());
 138         result.setStatus(router.getStatus());
 139         result.setDistributed(router.isDistributed());
 140         if (router.getGatewayPortId() != null) {
 141             result.setGatewayPortId(String.valueOf(router.getGatewayPortId().getValue()));
 142         }
 143         if (router.getRoutes() != null) {
 144             final List<NeutronRoute> routes = new ArrayList<NeutronRoute>();
 145             for (final Routes route : router.getRoutes()) {
 146                 final NeutronRoute routerRoute = new NeutronRoute();
 147                 routerRoute.setDestination(String.valueOf(route.getDestination().getValue()));
 148                 routerRoute.setNextHop(String.valueOf(route.getNexthop().getValue()));
 149                 routes.add(routerRoute);
 150             }
 151             result.setRoutes(routes);
 152         }
 153
 154         if (router.getExternalGatewayInfo() != null) {
 155             final NeutronRouter_NetworkReference extGwInfo = new NeutronRouter_NetworkReference();
 156             extGwInfo.setNetworkID(String.valueOf(router.getExternalGatewayInfo().getExternalNetworkId().getValue()));
 157             extGwInfo.setEnableSNAT(router.getExternalGatewayInfo().isEnableSnat());
 158             if (router.getExternalGatewayInfo().getExternalFixedIps() != null) {
 159                 final List<Neutron_IPs> fixedIPs = new ArrayList<Neutron_IPs>();
 160                 for (final ExternalFixedIps mdFixedIP : router.getExternalGatewayInfo().getExternalFixedIps()) {
 161                      final Neutron_IPs fixedIP = new Neutron_IPs();
 162                      fixedIP.setSubnetUUID(String.valueOf(mdFixedIP.getSubnetId().getValue()));
 163                      fixedIP.setIpAddress(String.valueOf(mdFixedIP.getIpAddress().getValue()));
 164                      fixedIPs.add(fixedIP);
 165                 }
 166                 extGwInfo.setExternalFixedIPs(fixedIPs);
 167             }
 168             result.setExternalGatewayInfo(extGwInfo);
 169         }
 170
 171         return result;
 172     }
 173 }