gerrit.fd Code Review - hc2vpp.git/blob

   1 /*
   2  * Copyright (c) 2016 Cisco and/or its affiliates.
   3  *
   4  * Licensed under the Apache License, Version 2.0 (the "License");
   5  * you may not use this file except in compliance with the License.
   6  * You may obtain a copy of the License at:
   7  *
   8  *     http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software
  11  * distributed under the License is distributed on an "AS IS" BASIS,
  12  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  13  * See the License for the specific language governing permissions and
  14  * limitations under the License.
  15  */
  16
  17 package io.fd.honeycomb.v3po.translate.v3po.interfacesstate;
  18
  19 import static io.fd.honeycomb.v3po.translate.v3po.test.ContextTestUtils.getMapping;
  20 import static io.fd.honeycomb.v3po.translate.v3po.test.ContextTestUtils.getMappingIid;
  21 import static org.mockito.Matchers.any;
  22 import static org.mockito.Mockito.doReturn;
  23 import static org.mockito.Mockito.mock;
  24 import static org.mockito.Mockito.verify;
  25 import static org.mockito.Mockito.when;
  26
  27 import com.google.common.base.Optional;
  28 import com.google.common.collect.Lists;
  29 import io.fd.honeycomb.v3po.translate.spi.read.RootReaderCustomizer;
  30 import io.fd.honeycomb.v3po.translate.v3po.test.ChildReaderCustomizerTest;
  31 import io.fd.honeycomb.v3po.translate.v3po.util.NamingContext;
  32 import java.util.Collections;
  33 import java.util.HashMap;
  34 import java.util.List;
  35 import java.util.Map;
  36 import java.util.concurrent.CompletableFuture;
  37 import java.util.concurrent.ExecutionException;
  38 import org.junit.Test;
  39 import org.opendaylight.yang.gen.v1.urn.honeycomb.params.xml.ns.yang.naming.context.rev160513.contexts.naming.context.Mappings;
  40 import org.opendaylight.yang.gen.v1.urn.honeycomb.params.xml.ns.yang.naming.context.rev160513.contexts.naming.context.MappingsBuilder;
  41 import org.opendaylight.yang.gen.v1.urn.honeycomb.params.xml.ns.yang.naming.context.rev160513.contexts.naming.context.mappings.Mapping;
  42 import org.opendaylight.yang.gen.v1.urn.honeycomb.params.xml.ns.yang.naming.context.rev160513.contexts.naming.context.mappings.MappingKey;
  43 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.InterfacesState;
  44 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface;
  45 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.InterfaceKey;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.VppInterfaceStateAugmentation;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.VppInterfaceStateAugmentationBuilder;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces.state._interface.L2;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces.state._interface.L2Builder;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.l2.base.attributes.Interconnection;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.l2.base.attributes.interconnection.BridgeBasedBuilder;
  52 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  53 import org.opendaylight.yangtools.yang.binding.KeyedInstanceIdentifier;
  54 import org.openvpp.jvpp.dto.BridgeDomainDetails;
  55 import org.openvpp.jvpp.dto.BridgeDomainDetailsReplyDump;
  56 import org.openvpp.jvpp.dto.BridgeDomainDump;
  57 import org.openvpp.jvpp.dto.BridgeDomainSwIfDetails;
  58 import org.openvpp.jvpp.dto.SwInterfaceDetails;
  59
  60 public class L2CustomizerTest extends ChildReaderCustomizerTest<L2, L2Builder> {
  61
  62     private NamingContext interfaceContext;
  63     private NamingContext bridgeDomainContext;
  64
  65     public L2CustomizerTest() {
  66         super(L2.class);
  67     }
  68
  69     @Override
  70     public void setUpBefore() {
  71         interfaceContext = new NamingContext("generatedIfaceName", "ifc-test-instance");
  72         bridgeDomainContext = new NamingContext("generatedBDName", "bd-test-instance");
  73     }
  74
  75     @Override
  76     protected RootReaderCustomizer<L2, L2Builder> initCustomizer() {
  77         return new L2Customizer(api, interfaceContext, bridgeDomainContext);
  78     }
  79
  80     @Test
  81     public void testMerge() {
  82         final VppInterfaceStateAugmentationBuilder builder = mock(VppInterfaceStateAugmentationBuilder.class);
  83         final L2 value = mock(L2.class);
  84         getCustomizer().merge(builder, value);
  85         verify(builder).setL2(value);
  86     }
  87
  88     private InstanceIdentifier<L2> getL2Id(final String name) {
  89         return InstanceIdentifier.create(InterfacesState.class).child(Interface.class, new InterfaceKey(name))
  90                 .augmentation(
  91                         VppInterfaceStateAugmentation.class).child(L2.class);
  92     }
  93
  94     private void whenBridgeDomainSwIfDumpThenReturn(final List<BridgeDomainSwIfDetails> bdSwIfList,
  95                                                     final List<BridgeDomainDetails> bridgeDomainDetailses)
  96             throws ExecutionException, InterruptedException {
  97         final BridgeDomainDetailsReplyDump reply = new BridgeDomainDetailsReplyDump();
  98         reply.bridgeDomainSwIfDetails = bdSwIfList;
  99         reply.bridgeDomainDetails = bridgeDomainDetailses;
 100
 101         final CompletableFuture<BridgeDomainDetailsReplyDump> replyFuture = new CompletableFuture<>();
 102         replyFuture.complete(reply);
 103         when(api.bridgeDomainSwIfDump(any(BridgeDomainDump.class))).thenReturn(replyFuture);
 104     }
 105
 106
 107     private BridgeDomainSwIfDetails generateBdSwIfDetails(final int ifId, final int bdId) {
 108         final BridgeDomainSwIfDetails bdSwIfDetails = new BridgeDomainSwIfDetails();
 109         bdSwIfDetails.swIfIndex = ifId;
 110         bdSwIfDetails.shg = 1;
 111         bdSwIfDetails.bdId = bdId;
 112         return bdSwIfDetails;
 113     }
 114
 115     private Interconnection generateInterconnection(final int ifId, final String bdName, final Boolean bvi) {
 116         final BridgeBasedBuilder bbBuilder = new BridgeBasedBuilder();
 117         bbBuilder.setBridgeDomain(bdName);
 118         bbBuilder.setSplitHorizonGroup((short) 1);
 119         // Empty type
 120         if(bvi != null) {
 121             bbBuilder.setBridgedVirtualInterface(bvi);
 122         }
 123         return bbBuilder.build();
 124     }
 125
 126     @Test
 127     public void testRead() throws Exception {
 128         final Map<Integer, SwInterfaceDetails> cachedInterfaceDump = new HashMap<>();
 129         final int ifId = 1;
 130         final int bdId = 1;
 131         final String bdName = "bd001";
 132         final String ifName = "eth0.sub0";
 133         final KeyedInstanceIdentifier<Mapping, MappingKey> ifcIid = getMappingIid(ifName, "ifc-test-instance");
 134         doReturn(getMapping(ifName, ifId)).when(mappingContext).read(ifcIid);
 135         final KeyedInstanceIdentifier<Mapping, MappingKey> bdIid = getMappingIid(bdName, "bd-test-instance");
 136         doReturn(getMapping(bdName, bdId)).when(mappingContext).read(bdIid);
 137
 138         List<Mapping> allMappings = Lists.newArrayList(getMapping(ifName, ifId).get());
 139         Mappings allMappingsBaObject = new MappingsBuilder().setMapping(allMappings).build();
 140         doReturn(Optional.of(allMappingsBaObject)).when(mappingContext).read(ifcIid.firstIdentifierOf(Mappings.class));
 141
 142         allMappings = Lists.newArrayList(getMapping(bdName, bdId).get());
 143         allMappingsBaObject = new MappingsBuilder().setMapping(allMappings).build();
 144         doReturn(Optional.of(allMappingsBaObject)).when(mappingContext).read(bdIid.firstIdentifierOf(Mappings.class));
 145
 146         final SwInterfaceDetails ifaceDetails = new SwInterfaceDetails();
 147         ifaceDetails.subId = ifId;
 148         cachedInterfaceDump.put(ifId, ifaceDetails);
 149         cache.put(InterfaceCustomizer.DUMPED_IFCS_CONTEXT_KEY, cachedInterfaceDump);
 150
 151         // BVI
 152         whenBridgeDomainSwIfDumpThenReturn(Collections.singletonList(generateBdSwIfDetails(ifId, bdId)),
 153             Collections.singletonList(generateBdDetails(ifId, bdId)));
 154
 155         L2Builder builder = mock(L2Builder.class);
 156         getCustomizer().readCurrentAttributes(getL2Id(ifName), builder, ctx);
 157
 158         verify(builder).setInterconnection(generateInterconnection(ifId, bdName, true));
 159
 160         // Not BVI
 161         whenBridgeDomainSwIfDumpThenReturn(Collections.singletonList(generateBdSwIfDetails(ifId, bdId)),
 162             Collections.singletonList(generateBdDetails(99 /* Different ifc is marked as BVI in bd details */, bdId)));
 163
 164         builder = mock(L2Builder.class);
 165         getCustomizer().readCurrentAttributes(getL2Id(ifName), builder, ctx);
 166
 167         verify(builder).setInterconnection(generateInterconnection(ifId, bdName, null));
 168     }
 169
 170     private BridgeDomainDetails generateBdDetails(final int ifId, final int bdId) {
 171         final BridgeDomainDetails bridgeDomainDetails = new BridgeDomainDetails();
 172         bridgeDomainDetails.bviSwIfIndex = ifId;
 173         bridgeDomainDetails.bdId = bdId;
 174         return bridgeDomainDetails;
 175     }
 176 }