v3po/v3po2vpp/src/test/java/io/fd/honeycomb/translate/v3po/interfacesstate/GreCustomizerTest.java

   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.translate.v3po.interfacesstate;
  18
  19 import static io.fd.honeycomb.translate.v3po.test.ContextTestUtils.getMapping;
  20 import static io.fd.honeycomb.translate.v3po.test.ContextTestUtils.getMappingIid;
  21 import static org.junit.Assert.assertEquals;
  22 import static org.junit.Assert.assertNotNull;
  23 import static org.junit.Assert.assertNull;
  24 import static org.mockito.Matchers.any;
  25 import static org.mockito.Mockito.doReturn;
  26 import static org.mockito.Mockito.verify;
  27 import static org.mockito.Mockito.verifyZeroInteractions;
  28
  29 import com.google.common.collect.Lists;
  30 import io.fd.honeycomb.translate.spi.read.ReaderCustomizer;
  31 import io.fd.honeycomb.translate.v3po.test.ReaderCustomizerTest;
  32 import io.fd.honeycomb.translate.v3po.util.NamingContext;
  33 import java.net.InetAddress;
  34 import java.net.UnknownHostException;
  35 import java.util.HashMap;
  36 import java.util.Map;
  37 import java.util.concurrent.CompletableFuture;
  38 import org.junit.Test;
  39 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.InterfacesState;
  40 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.Interface;
  41 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.state.InterfaceKey;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.VppInterfaceStateAugmentation;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces.state._interface.Gre;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.v3po.rev150105.interfaces.state._interface.GreBuilder;
  45 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  46 import org.openvpp.jvpp.VppInvocationException;
  47 import org.openvpp.jvpp.dto.SwInterfaceDetails;
  48 import org.openvpp.jvpp.dto.GreTunnelDetails;
  49 import org.openvpp.jvpp.dto.GreTunnelDetailsReplyDump;
  50 import org.openvpp.jvpp.dto.GreTunnelDump;
  51
  52 public class GreCustomizerTest extends ReaderCustomizerTest<Gre, GreBuilder> {
  53
  54     private NamingContext interfacesContext;
  55     static final InstanceIdentifier<Gre> IID =
  56         InstanceIdentifier.create(InterfacesState.class).child(Interface.class, new InterfaceKey("ifc1"))
  57             .augmentation(VppInterfaceStateAugmentation.class).child(Gre.class);
  58
  59     public GreCustomizerTest() {
  60         super(Gre.class);
  61     }
  62
  63     @Override
  64     public void setUpBefore() {
  65         interfacesContext = new NamingContext("gre-tunnel", "test-instance");
  66         doReturn(getMapping("ifc1", 0)).when(mappingContext).read(getMappingIid("ifc1", "test-instance"));
  67
  68         final SwInterfaceDetails v = new SwInterfaceDetails();
  69         v.interfaceName = "gre-tunnel4".getBytes();
  70         final Map<Integer, SwInterfaceDetails> map = new HashMap<>();
  71         map.put(0, v);
  72         cache.put(InterfaceCustomizer.DUMPED_IFCS_CONTEXT_KEY, map);
  73     }
  74
  75     @Override
  76     protected void setUpAfter() throws UnknownHostException, VppInvocationException {
  77         final CompletableFuture<GreTunnelDetailsReplyDump> greTunnelDetailsReplyDumpCompletionStage =
  78             new CompletableFuture<>();
  79
  80         final GreTunnelDetailsReplyDump value = new GreTunnelDetailsReplyDump();
  81         final GreTunnelDetails greTunnelDetails = new GreTunnelDetails();
  82         greTunnelDetails.isIpv6 = 0;
  83         greTunnelDetails.dstAddress = InetAddress.getByName("1.2.3.4").getAddress();
  84         greTunnelDetails.srcAddress = InetAddress.getByName("1.2.3.5").getAddress();
  85         greTunnelDetails.outerFibId = 55;
  86         greTunnelDetails.swIfIndex = 0;
  87
  88         value.greTunnelDetails = Lists.newArrayList(greTunnelDetails);
  89         greTunnelDetailsReplyDumpCompletionStage.complete(value);
  90
  91         doReturn(greTunnelDetailsReplyDumpCompletionStage).when(api).greTunnelDump(any(GreTunnelDump.class));
  92     }
  93
  94     @Test
  95     public void testReadCurrentAttributes() throws Exception {
  96         final GreBuilder builder = getCustomizer().getBuilder(IID);
  97         getCustomizer().readCurrentAttributes(IID, builder, ctx);
  98
  99         assertEquals(55, builder.getOuterFibId().intValue());
 100
 101         assertNull(builder.getSrc().getIpv6Address());
 102         assertNotNull(builder.getSrc().getIpv4Address());
 103         assertEquals("1.2.3.5", builder.getSrc().getIpv4Address().getValue());
 104
 105         assertNull(builder.getDst().getIpv6Address());
 106         assertNotNull(builder.getDst().getIpv4Address());
 107         assertEquals("1.2.3.4", builder.getDst().getIpv4Address().getValue());
 108
 109         verify(api).greTunnelDump(any(GreTunnelDump.class));
 110     }
 111
 112     @Test(expected = NullPointerException.class)
 113     public void testReadCurrentAttributesVppNameNotCached() throws Exception {
 114         InterfaceCustomizer.getCachedInterfaceDump(cache).remove(0);
 115
 116         final GreBuilder builder = getCustomizer().getBuilder(IID);
 117         getCustomizer().readCurrentAttributes(IID, builder, ctx);
 118     }
 119
 120     @Test
 121     public void testReadCurrentAttributesWrongType() throws Exception {
 122         final SwInterfaceDetails v = new SwInterfaceDetails();
 123         v.interfaceName = "tap-2".getBytes();
 124         InterfaceCustomizer.getCachedInterfaceDump(cache).put(0, v);
 125
 126         final GreBuilder builder = getCustomizer().getBuilder(IID);
 127         getCustomizer().readCurrentAttributes(IID, builder, ctx);
 128
 129         // Should be ignored
 130         verifyZeroInteractions(api);
 131     }
 132
 133     @Override
 134     protected ReaderCustomizer<Gre, GreBuilder> initCustomizer() {
 135         return new GreCustomizer(api, interfacesContext);
 136     }
 137 }