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.ContextTestUtils.getMapping;
  20 import static io.fd.honeycomb.v3po.translate.v3po.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.CompletionStage;
  38 import java.util.concurrent.ExecutionException;
  39 import org.junit.Test;
  40 import org.opendaylight.yang.gen.v1.urn.honeycomb.params.xml.ns.yang.naming.context.rev160513.contexts.naming.context.Mappings;
  41 import org.opendaylight.yang.gen.v1.urn.honeycomb.params.xml.ns.yang.naming.context.rev160513.contexts.naming.context.MappingsBuilder;
  42 import org.opendaylight.yang.gen.v1.urn.honeycomb.params.xml.ns.yang.naming.context.rev160513.contexts.naming.context.mappings.Mapping;
  43 import org.opendaylight.yang.gen.v1.urn.honeycomb.params.xml.ns.yang.naming.context.rev160513.contexts.naming.context.mappings.MappingKey;
  44 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.InterfacesState;
  45 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface;
  46 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.InterfaceKey;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.VppInterfaceStateAugmentation;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.VppInterfaceStateAugmentationBuilder;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces.state._interface.L2;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces.state._interface.L2Builder;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces.state._interface.l2.Interconnection;
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces.state._interface.l2.interconnection.BridgeBasedBuilder;
  53 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  54 import org.opendaylight.yangtools.yang.binding.KeyedInstanceIdentifier;
  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             throws ExecutionException, InterruptedException {
  96         final CompletionStage<BridgeDomainDetailsReplyDump> replyCS = mock(CompletionStage.class);
  97         final CompletableFuture<BridgeDomainDetailsReplyDump> replyFuture = mock(CompletableFuture.class);
  98         when(replyCS.toCompletableFuture()).thenReturn(replyFuture);
  99         final BridgeDomainDetailsReplyDump reply = new BridgeDomainDetailsReplyDump();
 100         reply.bridgeDomainSwIfDetails = bdSwIfList;
 101         when(replyFuture.get()).thenReturn(reply);
 102         when(api.bridgeDomainSwIfDump(any(BridgeDomainDump.class))).thenReturn(replyCS);
 103     }
 104
 105
 106     private BridgeDomainSwIfDetails generateBdSwIfDetails(final int ifId, final int bdId) {
 107         final BridgeDomainSwIfDetails bdSwIfDetails = new BridgeDomainSwIfDetails();
 108         bdSwIfDetails.swIfIndex = ifId;
 109         bdSwIfDetails.shg = 1;
 110         bdSwIfDetails.bdId = bdId;
 111         return bdSwIfDetails;
 112     }
 113
 114     private Interconnection generateInterconnection(final int ifId, final String bdName) {
 115         final BridgeBasedBuilder bbBuilder = new BridgeBasedBuilder();
 116         bbBuilder.setBridgeDomain(bdName);
 117         bbBuilder.setSplitHorizonGroup((short) 1);
 118         return bbBuilder.build();
 119     }
 120
 121     @Test
 122     public void testRead() throws Exception {
 123         final Map<Integer, SwInterfaceDetails> cachedInterfaceDump = new HashMap<>();
 124         final int ifId = 1;
 125         final int bdId = 1;
 126         final String bdName = "bd001";
 127         final String ifName = "eth0.sub0";
 128         final KeyedInstanceIdentifier<Mapping, MappingKey> ifcIid = getMappingIid(ifName, "ifc-test-instance");
 129         doReturn(getMapping(ifName, ifId)).when(mappingContext).read(ifcIid);
 130         final KeyedInstanceIdentifier<Mapping, MappingKey> bdIid = getMappingIid(bdName, "bd-test-instance");
 131         doReturn(getMapping(bdName, bdId)).when(mappingContext).read(bdIid);
 132
 133         List<Mapping> allMappings = Lists.newArrayList(getMapping(ifName, ifId).get());
 134         Mappings allMappingsBaObject = new MappingsBuilder().setMapping(allMappings).build();
 135         doReturn(Optional.of(allMappingsBaObject)).when(mappingContext).read(ifcIid.firstIdentifierOf(Mappings.class));
 136
 137         allMappings = Lists.newArrayList(getMapping(bdName, bdId).get());
 138         allMappingsBaObject = new MappingsBuilder().setMapping(allMappings).build();
 139         doReturn(Optional.of(allMappingsBaObject)).when(mappingContext).read(bdIid.firstIdentifierOf(Mappings.class));
 140
 141         final SwInterfaceDetails ifaceDetails = new SwInterfaceDetails();
 142         ifaceDetails.subId = ifId;
 143         cachedInterfaceDump.put(ifId, ifaceDetails);
 144         cache.put(InterfaceCustomizer.DUMPED_IFCS_CONTEXT_KEY, cachedInterfaceDump);
 145
 146         whenBridgeDomainSwIfDumpThenReturn(Collections.singletonList(generateBdSwIfDetails(ifId, bdId)));
 147
 148         final L2Builder builder = mock(L2Builder.class);
 149         getCustomizer().readCurrentAttributes(getL2Id(ifName), builder, ctx);
 150
 151         verify(builder).setInterconnection(generateInterconnection(ifId, bdName));
 152     }
 153 }