extension/openflowplugin-extension-onf/src/test/java/org/opendaylight/openflowplugin/extension/onf/converter/BundleAddMessageConverterTest.java

   1 /*
   2  * Copyright (c) 2017 Pantheon Technologies s.r.o. 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.openflowplugin.extension.onf.converter;
  10
  11 import static org.opendaylight.openflowplugin.openflow.md.util.InventoryDataServiceUtil.extractDatapathId;
  12
  13 import java.util.ArrayList;
  14 import java.util.Collections;
  15 import java.util.List;
  16 import org.junit.Assert;
  17 import org.junit.Before;
  18 import org.junit.Test;
  19 import org.mockito.Mockito;
  20 import org.opendaylight.openflowplugin.api.OFConstants;
  21 import org.opendaylight.openflowplugin.extension.api.ExtensionConvertorData;
  22 import org.opendaylight.openflowplugin.extension.api.exception.ConversionException;
  23 import org.opendaylight.openflowplugin.extension.onf.BundleTestUtils;
  24 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.yang.types.rev130715.MacAddress;
  25 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortConfig;
  26 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortFeatures;
  27 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.PortNumberUni;
  28 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.port.mod.PortBuilder;
  29 import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.types.port.rev130925.port.mod.port.PortKey;
  30 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.GroupId;
  31 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId;
  32 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRef;
  33 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.Nodes;
  34 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
  35 import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeKey;
  36 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.common.types.rev130731.ExperimenterId;
  37 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.bundle.service.rev170124.bundle.inner.message.grouping.BundleInnerMessage;
  38 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.bundle.service.rev170124.bundle.inner.message.grouping.bundle.inner.message.BundleAddFlowCaseBuilder;
  39 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.bundle.service.rev170124.bundle.inner.message.grouping.bundle.inner.message.BundleAddGroupCaseBuilder;
  40 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.bundle.service.rev170124.bundle.inner.message.grouping.bundle.inner.message.BundleRemoveFlowCaseBuilder;
  41 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.bundle.service.rev170124.bundle.inner.message.grouping.bundle.inner.message.BundleRemoveGroupCaseBuilder;
  42 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.bundle.service.rev170124.bundle.inner.message.grouping.bundle.inner.message.BundleUpdateFlowCaseBuilder;
  43 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.bundle.service.rev170124.bundle.inner.message.grouping.bundle.inner.message.BundleUpdateGroupCaseBuilder;
  44 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.bundle.service.rev170124.bundle.inner.message.grouping.bundle.inner.message.BundleUpdatePortCaseBuilder;
  45 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.bundle.service.rev170124.bundle.inner.message.grouping.bundle.inner.message.bundle.add.flow._case.AddFlowCaseDataBuilder;
  46 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.bundle.service.rev170124.bundle.inner.message.grouping.bundle.inner.message.bundle.add.group._case.AddGroupCaseDataBuilder;
  47 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.bundle.service.rev170124.bundle.inner.message.grouping.bundle.inner.message.bundle.remove.flow._case.RemoveFlowCaseDataBuilder;
  48 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.bundle.service.rev170124.bundle.inner.message.grouping.bundle.inner.message.bundle.remove.group._case.RemoveGroupCaseDataBuilder;
  49 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.bundle.service.rev170124.bundle.inner.message.grouping.bundle.inner.message.bundle.update.flow._case.UpdateFlowCaseDataBuilder;
  50 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.bundle.service.rev170124.bundle.inner.message.grouping.bundle.inner.message.bundle.update.group._case.UpdateGroupCaseDataBuilder;
  51 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.bundle.service.rev170124.bundle.inner.message.grouping.bundle.inner.message.bundle.update.port._case.UpdatePortCaseDataBuilder;
  52 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.bundle.service.rev170124.send.experimenter.input.experimenter.message.of.choice.BundleAddMessageSal;
  53 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.bundle.service.rev170124.send.experimenter.input.experimenter.message.of.choice.BundleAddMessageSalBuilder;
  54 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.bundle.service.rev170124.send.experimenter.input.experimenter.message.of.choice.bundle.add.message.sal.SalAddMessageDataBuilder;
  55 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.rev170124.BundleFlags;
  56 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.rev170124.BundleId;
  57 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.rev170124.bundle.add.message.grouping.bundle.inner.message.BundleFlowModCase;
  58 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.rev170124.bundle.add.message.grouping.bundle.inner.message.BundleGroupModCase;
  59 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.rev170124.bundle.add.message.grouping.bundle.inner.message.BundlePortModCase;
  60 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.rev170124.bundle.common.grouping.BundleProperty;
  61 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.rev170124.bundle.property.grouping.bundle.property.entry.BundlePropertyExperimenter;
  62 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.rev170124.bundle.property.grouping.bundle.property.entry.bundle.property.experimenter.BundlePropertyExperimenterData;
  63 import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.extension.onf.rev170124.experimenter.input.experimenter.data.of.choice.BundleAddMessageOnf;
  64 import org.opendaylight.yangtools.yang.binding.DataObject;
  65 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
  66 import org.opendaylight.yangtools.yang.common.Uint32;
  67
  68 /**
  69  * Test for {@link org.opendaylight.openflowplugin.extension.onf.converter.BundleAddMessageConverter}.
  70  */
  71 public class BundleAddMessageConverterTest {
  72
  73     private final BundleAddMessageConverter converter = new BundleAddMessageConverter();
  74     private static final NodeRef NODE_REF = new NodeRef(InstanceIdentifier.create(Nodes.class)
  75             .child(Node.class, new NodeKey(new NodeId("openflow:1"))));
  76     private static final GroupId GROUP_ID = new GroupId(1L);
  77
  78     @Before
  79     public void setUp() {
  80     }
  81
  82     @Test
  83     public void testGetExperimenterId() {
  84         Assert.assertEquals("Wrong ExperimenterId.", new ExperimenterId(0x4F4E4600L), converter.getExperimenterId());
  85     }
  86
  87     @Test
  88     public void testGetType() {
  89         Assert.assertEquals("Wrong type.", 2301, converter.getType());
  90     }
  91
  92     @Test
  93     public void testConvertWithoutProperty() throws Exception {
  94         testConvert(false);
  95     }
  96
  97     @Test
  98     public void testConvertWithProperty() throws Exception {
  99         testConvert(true);
 100     }
 101
 102     @Test
 103     public void testConvertAddFlowCase() throws Exception {
 104         testConvert(new BundleAddFlowCaseBuilder().setAddFlowCaseData(new AddFlowCaseDataBuilder().build()).build(),
 105                 BundleFlowModCase.class);
 106     }
 107
 108     @Test
 109     public void testConvertUpdateFlowCase() throws Exception {
 110         testConvert(new BundleUpdateFlowCaseBuilder().setUpdateFlowCaseData(new UpdateFlowCaseDataBuilder().build())
 111                 .build(), BundleFlowModCase.class);
 112     }
 113
 114     @Test
 115     public void testConvertRemoveFlowCase() throws Exception {
 116         testConvert(new BundleRemoveFlowCaseBuilder().setRemoveFlowCaseData(new RemoveFlowCaseDataBuilder().build())
 117                 .build(), BundleFlowModCase.class);
 118     }
 119
 120     @Test
 121     public void testConvertAddGroupCase() throws Exception {
 122         testConvert(
 123                 new BundleAddGroupCaseBuilder()
 124                         .setAddGroupCaseData(new AddGroupCaseDataBuilder().setGroupId(GROUP_ID).build()).build(),
 125                 BundleGroupModCase.class);
 126     }
 127
 128     @Test
 129     public void testConvertUpdateGroupCase() throws Exception {
 130         testConvert(
 131                 new BundleUpdateGroupCaseBuilder()
 132                         .setUpdateGroupCaseData(new UpdateGroupCaseDataBuilder().setGroupId(GROUP_ID).build()).build(),
 133                 BundleGroupModCase.class);
 134     }
 135
 136     @Test
 137     public void testConvertRemoveGroupCase() throws Exception {
 138         testConvert(
 139                 new BundleRemoveGroupCaseBuilder()
 140                         .setRemoveGroupCaseData(new RemoveGroupCaseDataBuilder().setGroupId(GROUP_ID).build()).build(),
 141                 BundleGroupModCase.class);
 142     }
 143
 144     @Test
 145     public void testConvertUpdatePortCase() throws Exception {
 146         testConvert(new BundleUpdatePortCaseBuilder()
 147                 .setUpdatePortCaseData(new UpdatePortCaseDataBuilder()
 148                 .setPort(new PortBuilder()
 149                             .setPort(Collections.singletonList(new org.opendaylight.yang.gen.v1.urn.opendaylight.flow
 150                                         .types.port.rev130925.port.mod.port.PortBuilder()
 151                                     .setConfiguration(Mockito.mock(PortConfig.class))
 152                                     .setAdvertisedFeatures(Mockito.mock(PortFeatures.class))
 153                                     .setPortNumber(new PortNumberUni(Uint32.ZERO))
 154                                     .setHardwareAddress(Mockito.mock(MacAddress.class))
 155                                     .withKey(new PortKey(Uint32.ZERO))
 156                                     .build()))
 157                             .build()).build())
 158                 .build(), BundlePortModCase.class);
 159     }
 160
 161     private void testConvert(final BundleInnerMessage message, final Class<? extends DataObject> clazz)
 162             throws ConversionException {
 163         testConvert(message, clazz, false);
 164     }
 165
 166     private void testConvert(final boolean withProperty) throws ConversionException {
 167         final BundleInnerMessage message = new BundleAddFlowCaseBuilder()
 168                 .setAddFlowCaseData(new AddFlowCaseDataBuilder().build()).build();
 169         testConvert(message, BundleFlowModCase.class, withProperty);
 170     }
 171
 172     private void testConvert(final BundleInnerMessage message, Class<? extends DataObject> clazz,
 173             final boolean withProperty) throws ConversionException {
 174         final BundleAddMessageSal original = createMessage(withProperty, message);
 175         final ExtensionConvertorData data = new ExtensionConvertorData(OFConstants.OFP_VERSION_1_3);
 176         data.setDatapathId(extractDatapathId(NODE_REF));
 177         final BundleAddMessageOnf converted = converter.convert(original, data);
 178         Assert.assertEquals("Wrong BundleId", new BundleId(original.getSalAddMessageData().getBundleId().getValue()),
 179                 converted.getOnfAddMessageGroupingData().getBundleId());
 180         Assert.assertEquals("Wrong flags",
 181                 new BundleFlags(original.getSalAddMessageData().getFlags().isAtomic(),
 182                         original.getSalAddMessageData().getFlags().isOrdered()),
 183                 converted.getOnfAddMessageGroupingData().getFlags());
 184         Assert.assertEquals("Wrong inner message conversion", clazz,
 185                 converted.getOnfAddMessageGroupingData().getBundleInnerMessage().implementedInterface());
 186         if (withProperty) {
 187             final BundlePropertyExperimenter originalProperty = (BundlePropertyExperimenter) original
 188                     .getSalAddMessageData().getBundleProperty().get(0).getBundlePropertyEntry();
 189             final BundlePropertyExperimenter convertedProperty = (BundlePropertyExperimenter) converted
 190                     .getOnfAddMessageGroupingData().getBundleProperty().get(0).getBundlePropertyEntry();
 191             Assert.assertEquals("Wrong property ExperimenterId", new ExperimenterId(originalProperty.getExperimenter()),
 192                     convertedProperty.getExperimenter());
 193             Assert.assertEquals("Wrong property experimenter type", originalProperty.getExpType(),
 194                     convertedProperty.getExpType());
 195             Assert.assertEquals("Wrong property data", originalProperty.getBundlePropertyExperimenterData(),
 196                     convertedProperty.getBundlePropertyExperimenterData());
 197         } else {
 198             Assert.assertTrue("Properties not empty",
 199                     converted.getOnfAddMessageGroupingData().nonnullBundleProperty().isEmpty());
 200         }
 201     }
 202
 203     private static BundleAddMessageSal createMessage(final boolean withProperty,
 204             final BundleInnerMessage innerMessage) {
 205         final SalAddMessageDataBuilder dataBuilder = new SalAddMessageDataBuilder();
 206         dataBuilder.setBundleId(new BundleId(1L));
 207         dataBuilder.setFlags(new BundleFlags(true, false));
 208         List<BundleProperty> properties = new ArrayList<>();
 209         if (withProperty) {
 210             properties.add(
 211                     BundleTestUtils.createExperimenterProperty(Mockito.mock(BundlePropertyExperimenterData.class)));
 212         }
 213         dataBuilder.setBundleProperty(properties);
 214         dataBuilder.setBundleInnerMessage(innerMessage);
 215
 216         return new BundleAddMessageSalBuilder().setSalAddMessageData(dataBuilder.build()).build();
 217     }
 218
 219 }