import static io.fd.hc2vpp.acl.read.AbstractVppAclCustomizer.getAclCfgId;
import static io.fd.honeycomb.translate.util.read.cache.EntityDumpExecutor.NO_PARAMS;
+import com.google.common.annotations.VisibleForTesting;
import com.google.common.base.Optional;
import io.fd.hc2vpp.acl.util.AclContextManager;
import io.fd.hc2vpp.acl.util.FutureJVppAclCustomizer;
implements InitializingReaderCustomizer<VppMacipAcl, VppMacipAclBuilder>, JvppReplyConsumer, ByteDataTranslator {
private static final Logger LOG = LoggerFactory.getLogger(VppMacIpAclCustomizer.class);
+ @VisibleForTesting
+ protected static final int ACL_NOT_ASSIGNED = -1;
private final DumpCacheManager<MacipAclDetailsReplyDump, Integer> macIpAclDumpManager;
private final DumpCacheManager<MacipAclInterfaceGetReply, Void> interfaceMacIpAclDumpManager;
if (interfacesMacIpDumpReply.isPresent() && interfaceIndex < interfacesMacIpDumpReply.get().count) {
final int aclIndex = interfacesMacIpDumpReply.get().acls[interfaceIndex];
-
- final Optional<MacipAclDetailsReplyDump> macIpDumpReply =
- macIpAclDumpManager.getDump(id, modificationCache, aclIndex);
-
- if (macIpDumpReply.isPresent() && !macIpDumpReply.get().macipAclDetails.isEmpty()) {
- builder.setName(macIpAclContext.getAclName(aclIndex, mappingContext));
- builder.setType(
- org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vpp.acl.rev161214.VppMacipAcl.class);
- } else {
- // this is invalid state(Interface in VPP will act as "deny-all" for security reasons), but generally
- // it should not happen
- throw new ReadFailedException(id,
- new IllegalStateException(String.format("ACE with index %s not found in VPP", aclIndex)));
+ if (aclIndex != ACL_NOT_ASSIGNED) {
+ final Optional<MacipAclDetailsReplyDump> macIpDumpReply =
+ macIpAclDumpManager.getDump(id, modificationCache, aclIndex);
+
+ if (macIpDumpReply.isPresent() && !macIpDumpReply.get().macipAclDetails.isEmpty()) {
+ builder.setName(macIpAclContext.getAclName(aclIndex, mappingContext));
+ builder.setType(
+ org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vpp.acl.rev161214.VppMacipAcl.class);
+ return;
+ } else {
+ // this is invalid state(Interface in VPP will act as "deny-all" for security reasons), but generally
+ // it should not happen
+ throw new ReadFailedException(id,
+ new IllegalStateException(String.format("ACE with index %s not found in VPP", aclIndex)));
+ }
}
- } else {
- // this is valid state, so just logging
- LOG.debug("No Mac-ip ACL specified for Interface name={},index={}", interfaceName, interfaceIndex);
}
+ // this is valid state, so just logging
+ LOG.debug("No Mac-ip ACL specified for Interface name={},index={}", interfaceName, interfaceIndex);
}
@Override
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vpp.acl.rev161214.acl.ip.protocol.header.fields.ip.protocol.IcmpBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vpp.acl.rev161214.acl.ip.protocol.header.fields.ip.protocol.IcmpV6;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vpp.acl.rev161214.acl.ip.protocol.header.fields.ip.protocol.IcmpV6Builder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vpp.acl.rev161214.acl.ip.protocol.header.fields.ip.protocol.Other;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vpp.acl.rev161214.acl.ip.protocol.header.fields.ip.protocol.OtherBuilder;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vpp.acl.rev161214.acl.ip.protocol.header.fields.ip.protocol.Tcp;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vpp.acl.rev161214.acl.ip.protocol.header.fields.ip.protocol.TcpBuilder;
return new IcmpV6Builder().setIcmpV6Nodes(nodes.build()).build();
}
- private static IpProtocol parse(final AclRule rule) {
+ private static Other parse(final AclRule rule) {
final OtherNodesBuilder nodes = new OtherNodesBuilder();
nodes.setProtocol((short) Short.toUnsignedInt(rule.proto));
return new OtherBuilder().setOtherNodes(nodes.build()).build();
package io.fd.hc2vpp.acl.read;
+import static org.junit.Assert.assertEquals;
+import static org.junit.Assert.assertTrue;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.when;
+
import io.fd.hc2vpp.acl.util.AclContextManager;
import io.fd.hc2vpp.common.test.read.InitializingListReaderCustomizerTest;
+import io.fd.honeycomb.translate.read.ReadFailedException;
+import io.fd.vpp.jvpp.acl.dto.AclDetails;
+import io.fd.vpp.jvpp.acl.dto.AclDetailsReplyDump;
+import io.fd.vpp.jvpp.acl.dto.MacipAclDetails;
+import io.fd.vpp.jvpp.acl.dto.MacipAclDetailsReplyDump;
import io.fd.vpp.jvpp.acl.future.FutureJVppAclFacade;
+import io.fd.vpp.jvpp.acl.types.AclRule;
+import io.fd.vpp.jvpp.acl.types.MacipAclRule;
+import java.util.ArrayList;
+import java.util.List;
+import org.junit.Test;
import org.mockito.Mock;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.access.control.list.rev160708.AccessLists;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.access.control.list.rev160708.AccessListsBuilder;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.access.control.list.rev160708.access.lists.Acl;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.access.control.list.rev160708.access.lists.AclBuilder;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.access.control.list.rev160708.access.lists.AclKey;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.access.control.list.rev160708.access.lists.acl.access.list.entries.Ace;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.access.control.list.rev160708.access.lists.acl.access.list.entries.ace.actions.packet.handling.Deny;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vpp.acl.rev161214.VppAcl;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vpp.acl.rev161214.VppMacipAcl;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vpp.acl.rev161214.access.lists.acl.access.list.entries.ace.matches.ace.type.VppAce;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vpp.acl.rev161214.access.lists.acl.access.list.entries.ace.matches.ace.type.vpp.ace.VppAceNodes;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vpp.acl.rev161214.acl.ip.protocol.header.fields.ip.protocol.Other;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+import org.opendaylight.yangtools.yang.binding.KeyedInstanceIdentifier;
public class AclCustomizerTest extends InitializingListReaderCustomizerTest<Acl, AclKey, AclBuilder> {
+ private static final String ACL_NAME = "vpp-acl";
+ private static final String ACE_NAME = "vpp-ace";
+ private static final int ACL_INDEX = 123;
+ private static final String MACIP_ACL_NAME = "vpp-macip-acl";
+ private static final String MACIP_ACE_NAME = "vpp-macip-ace";
+ private static final int MACIP_ACL_INDEX = 456;
+ private static final short PROTOCOL = 2;
@Mock
private FutureJVppAclFacade aclApi;
@Mock
private AclContextManager standardAclContext;
@Mock
private AclContextManager macipAclContext;
+ private KeyedInstanceIdentifier<Acl, AclKey> ACL_IID =
+ InstanceIdentifier.create(AccessLists.class).child(Acl.class, new AclKey(
+ ACL_NAME, VppAcl.class));
+ private KeyedInstanceIdentifier<Acl, AclKey> MACIP_ACL_IID =
+ InstanceIdentifier.create(AccessLists.class).child(Acl.class, new AclKey(MACIP_ACL_NAME, VppMacipAcl.class));
public AclCustomizerTest() {
super(Acl.class, AccessListsBuilder.class);
protected AclCustomizer initCustomizer() {
return new AclCustomizer(aclApi, standardAclContext, macipAclContext);
}
+
+ @Override
+ protected void setUp() throws Exception {
+ final AclDetailsReplyDump aclDump = new AclDetailsReplyDump();
+ aclDump.aclDetails = new ArrayList<>();
+ final AclDetails acl1 = new AclDetails();
+ acl1.r = new AclRule[1];
+ acl1.r[0] = new AclRule();
+ acl1.r[0].proto = PROTOCOL;
+ acl1.aclIndex = ACL_INDEX;
+ aclDump.aclDetails.add(acl1);
+ when(aclApi.aclDump(any())).thenReturn(future(aclDump));
+
+ final MacipAclDetailsReplyDump macipAclDump = new MacipAclDetailsReplyDump();
+ macipAclDump.macipAclDetails = new ArrayList<>();
+ final MacipAclDetails macipAcl1 = new MacipAclDetails();
+ macipAcl1.r = new MacipAclRule[]{new MacipAclRule()};
+ macipAcl1.aclIndex = MACIP_ACL_INDEX;
+ macipAclDump.macipAclDetails.add(macipAcl1);
+ when(aclApi.macipAclDump(any())).thenReturn(future(macipAclDump));
+
+ when(standardAclContext.getAclName(ACL_INDEX, mappingContext)).thenReturn(ACL_NAME);
+ when(standardAclContext.getAclIndex(ACL_NAME, mappingContext)).thenReturn(ACL_INDEX);
+ when(standardAclContext.getAceName(ACL_NAME, 0, mappingContext)).thenReturn(ACE_NAME);
+
+ when(macipAclContext.getAclName(MACIP_ACL_INDEX, mappingContext)).thenReturn(MACIP_ACL_NAME);
+ when(macipAclContext.getAclIndex(MACIP_ACL_NAME, mappingContext)).thenReturn(MACIP_ACL_INDEX);
+ when(macipAclContext.getAceName(MACIP_ACL_NAME, 0, mappingContext)).thenReturn(MACIP_ACE_NAME);
+ }
+
+ @Test
+ public void testGetAllIds() throws ReadFailedException {
+ final List<AclKey> allIds = getCustomizer().getAllIds(InstanceIdentifier.create(AccessLists.class).child(Acl.class), ctx);
+ assertEquals(2, allIds.size());
+ assertEquals(ACL_IID.getKey(), allIds.get(0));
+ assertEquals(MACIP_ACL_IID.getKey(), allIds.get(1));
+ }
+
+ @Test
+ public void testReadStandardAcl() throws ReadFailedException {
+ final AclBuilder builder = new AclBuilder();
+ getCustomizer().readCurrentAttributes(ACL_IID, builder, ctx);
+ assertEquals(ACL_IID.getKey(), builder.getKey());
+ final List<Ace> aces = builder.getAccessListEntries().getAce();
+ assertEquals(1, aces.size());
+ final Ace ace = aces.get(0);
+ assertEquals(ACE_NAME, ace.getKey().getRuleName());
+ assertTrue(ace.getActions().getPacketHandling() instanceof Deny);
+ final VppAceNodes nodes = ((VppAce) (ace.getMatches().getAceType())).getVppAceNodes();
+ assertEquals(PROTOCOL, ((Other) nodes.getIpProtocol()).getOtherNodes().getProtocol().shortValue());
+
+ }
+
+ @Test
+ public void testReadMacipAcl() throws ReadFailedException {
+ final AclBuilder builder = new AclBuilder();
+ getCustomizer().readCurrentAttributes(MACIP_ACL_IID, builder, ctx);
+ assertEquals(MACIP_ACL_IID.getKey(), builder.getKey());
+ final List<Ace> aces = builder.getAccessListEntries().getAce();
+ assertEquals(1, aces.size());
+ final Ace ace = aces.get(0);
+ assertEquals(MACIP_ACE_NAME, ace.getKey().getRuleName());
+ assertTrue(ace.getActions().getPacketHandling() instanceof Deny);
+ }
}
\ No newline at end of file
package io.fd.hc2vpp.acl.read;
+import static io.fd.hc2vpp.acl.read.VppMacIpAclCustomizer.ACL_NOT_ASSIGNED;
import static io.fd.hc2vpp.acl.read.AbstractVppAclCustomizerTest.getAclId;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
final MacipAclInterfaceGetReply assignedAcls = new MacipAclInterfaceGetReply();
assignedAcls.count = 2;
- assignedAcls.acls = new int[] {-1, ACL_ID};
+ assignedAcls.acls = new int[] {ACL_NOT_ASSIGNED, ACL_ID};
when(aclApi.macipAclInterfaceGet(any())).thenReturn(future(assignedAcls));
final MacipAclDump request = new MacipAclDump();
verify(builder).setType(ACL_TYPE);
}
+ @Test
+ public void testReadNotAssigned() throws ReadFailedException {
+ final VppMacipAclBuilder builder = mock(VppMacipAclBuilder.class);
+
+ final MacipAclInterfaceGetReply assignedAcls = new MacipAclInterfaceGetReply();
+ // pretending we have 3 interfaces, IF_NAME does not have MacipAcl assigned
+ assignedAcls.count = 3;
+ assignedAcls.acls = new int[] {ACL_NOT_ASSIGNED, ACL_NOT_ASSIGNED, ACL_ID};
+ when(aclApi.macipAclInterfaceGet(any())).thenReturn(future(assignedAcls));
+
+ final MacipAclDump request = new MacipAclDump();
+ request.aclIndex = ACL_ID;
+ final MacipAclDetailsReplyDump reply = new MacipAclDetailsReplyDump();
+ final MacipAclDetails details = new MacipAclDetails();
+ details.aclIndex = ACL_ID;
+ reply.macipAclDetails.add(details);
+ when(aclApi.macipAclDump(request)).thenReturn(future(reply));
+
+ getCustomizer().readCurrentAttributes(getIid(IF_NAME), builder, ctx);
+ verifyZeroInteractions(builder);
+ }
+
@Test
public void testReadNoAcls() throws ReadFailedException {
final VppMacipAclBuilder builder = mock(VppMacipAclBuilder.class);
import org.junit.runner.RunWith;
import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.access.control.list.rev160708.AccessLists;
import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vpp.acl.rev161214.access.lists.acl.access.list.entries.ace.matches.ace.type.VppAce;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vpp.acl.rev161214.acl.ip.protocol.header.fields.ip.protocol.Icmp;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vpp.acl.rev161214.acl.ip.protocol.header.fields.ip.protocol.IcmpV6;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vpp.acl.rev161214.acl.ip.protocol.header.fields.ip.protocol.Other;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vpp.acl.rev161214.acl.ip.protocol.header.fields.ip.protocol.Tcp;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.vpp.acl.rev161214.acl.ip.protocol.header.fields.ip.protocol.Udp;
@RunWith(HoneycombTestRunner.class)
-public class ProtoPreBindRuleProducerTest implements ProtoPreBindRuleProducer, AclTestSchemaContext {
+public class ProtocolParsingTest implements ProtoPreBindRuleProducer, IpProtocolReader, AclTestSchemaContext {
private static final byte IGNORE_PROTOCOL = 0;
//TODO - remove after resolving how to address identity from different model in textual yang instance identifier
final AclRule icmpRule = createPreBindRule(extractAce(acls));
assertEquals(1, icmpRule.proto);
- assertEquals(5, icmpRule.srcportOrIcmptypeFirst);
- assertEquals(8, icmpRule.srcportOrIcmptypeLast);
- assertEquals(1, icmpRule.dstportOrIcmpcodeFirst);
- assertEquals(3, icmpRule.dstportOrIcmpcodeLast);
assertEquals(0, icmpRule.tcpFlagsMask);
assertEquals(0, icmpRule.tcpFlagsValue);
- }
+ final Icmp protocol = (Icmp)parseProtocol(icmpRule);
+ assertEquals(5, protocol.getIcmpNodes().getIcmpTypeRange().getFirst().shortValue());
+ assertEquals(8, protocol.getIcmpNodes().getIcmpTypeRange().getLast().shortValue());
+ assertEquals(1, protocol.getIcmpNodes().getIcmpCodeRange().getFirst().shortValue());
+ assertEquals(3, protocol.getIcmpNodes().getIcmpCodeRange().getLast().shortValue());
+ }
@Test
public void testIcmpv6Rule(@InjectTestData(resourcePath = "/rules/icmp-v6-rule.json") AccessLists acls) {
assertEquals(3, icmpv6Rule.dstportOrIcmpcodeLast);
assertEquals(0, icmpv6Rule.tcpFlagsMask);
assertEquals(0, icmpv6Rule.tcpFlagsValue);
+
+ final IcmpV6 protocol = (IcmpV6)parseProtocol(icmpv6Rule);
+ assertEquals(5, protocol.getIcmpV6Nodes().getIcmpTypeRange().getFirst().shortValue());
+ assertEquals(8, protocol.getIcmpV6Nodes().getIcmpTypeRange().getLast().shortValue());
+ assertEquals(1, protocol.getIcmpV6Nodes().getIcmpCodeRange().getFirst().shortValue());
+ assertEquals(3, protocol.getIcmpV6Nodes().getIcmpCodeRange().getLast().shortValue());
}
@Test
public void testTcpRule(@InjectTestData(resourcePath = "/rules/tcp-rule.json") AccessLists acls) {
final AclRule tcpRule = createPreBindRule(extractAce(acls));
assertEquals(6, tcpRule.proto);
- assertEquals(1, tcpRule.srcportOrIcmptypeFirst);
- assertEquals(5487, tcpRule.srcportOrIcmptypeLast);
- assertEquals(87, tcpRule.dstportOrIcmpcodeFirst);
- assertEquals(6745, tcpRule.dstportOrIcmpcodeLast);
assertEquals(1, tcpRule.tcpFlagsMask);
assertEquals(7, tcpRule.tcpFlagsValue);
+
+ final Tcp protocol = (Tcp)parseProtocol(tcpRule);
+ assertEquals(1, protocol.getTcpNodes().getSourcePortRange().getLowerPort().getValue().intValue());
+ assertEquals(5487, protocol.getTcpNodes().getSourcePortRange().getUpperPort().getValue().intValue());
+ assertEquals(87, protocol.getTcpNodes().getDestinationPortRange().getLowerPort().getValue().intValue());
+ assertEquals(6745, protocol.getTcpNodes().getDestinationPortRange().getUpperPort().getValue().intValue());
}
@Test
assertEquals((short)65000, tcpRule.dstportOrIcmpcodeLast);
assertEquals(0, tcpRule.tcpFlagsMask);
assertEquals(0, tcpRule.tcpFlagsValue);
+
+ final Tcp protocol = (Tcp)parseProtocol(tcpRule);
+ assertEquals(123, protocol.getTcpNodes().getSourcePortRange().getLowerPort().getValue().intValue());
+ assertEquals(123, protocol.getTcpNodes().getSourcePortRange().getUpperPort().getValue().intValue());
+ assertEquals(65000, protocol.getTcpNodes().getDestinationPortRange().getLowerPort().getValue().intValue());
+ assertEquals(65000, protocol.getTcpNodes().getDestinationPortRange().getUpperPort().getValue().intValue());
}
@Test
public void testUdpRule(@InjectTestData(resourcePath = "/rules/udp-rule.json") AccessLists acls) {
final AclRule udpRule = createPreBindRule(extractAce(acls));
assertEquals(17, udpRule.proto);
- assertEquals(1, udpRule.srcportOrIcmptypeFirst);
- assertEquals(5487, udpRule.srcportOrIcmptypeLast);
- assertEquals(87, udpRule.dstportOrIcmpcodeFirst);
- assertEquals(6745, udpRule.dstportOrIcmpcodeLast);
assertEquals(0, udpRule.tcpFlagsMask);
assertEquals(0, udpRule.tcpFlagsValue);
+
+ final Udp protocol = (Udp)parseProtocol(udpRule);
+ assertEquals(1, protocol.getUdpNodes().getSourcePortRange().getLowerPort().getValue().intValue());
+ assertEquals(5487, protocol.getUdpNodes().getSourcePortRange().getUpperPort().getValue().intValue());
+ assertEquals(87, protocol.getUdpNodes().getDestinationPortRange().getLowerPort().getValue().intValue());
+ assertEquals(6745, protocol.getUdpNodes().getDestinationPortRange().getUpperPort().getValue().intValue());
}
@Test
public void testOtherRule(@InjectTestData(resourcePath = "/rules/other-rule.json") AccessLists acls) {
- final AclRule icmpRule = createPreBindRule(extractAce(acls));
- assertEquals(64, icmpRule.proto);
- assertEquals(0, icmpRule.srcportOrIcmptypeFirst);
- assertEquals((short) 65535, icmpRule.srcportOrIcmptypeLast);
- assertEquals(0, icmpRule.dstportOrIcmpcodeFirst);
- assertEquals((short) 65535, icmpRule.dstportOrIcmpcodeLast);
- assertEquals(0, icmpRule.tcpFlagsMask);
- assertEquals(0, icmpRule.tcpFlagsValue);
+ final AclRule rule = createPreBindRule(extractAce(acls));
+ final int protocolNumber = 64;
+ assertEquals(protocolNumber, rule.proto);
+ assertEquals(0, rule.srcportOrIcmptypeFirst);
+ assertEquals((short) 65535, rule.srcportOrIcmptypeLast);
+ assertEquals(0, rule.dstportOrIcmpcodeFirst);
+ assertEquals((short) 65535, rule.dstportOrIcmpcodeLast);
+ assertEquals(0, rule.tcpFlagsMask);
+ assertEquals(0, rule.tcpFlagsValue);
+
+ final Other protocol = (Other)parseProtocol(rule);
+ assertEquals(protocolNumber, protocol.getOtherNodes().getProtocol().shortValue());
}
@Test
/*
- * Copyright (c) 2016 Cisco and/or its affiliates.
+ * Copyright (c) 2017 Cisco and/or its affiliates.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
package io.fd.hc2vpp.acl.write;
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
import io.fd.hc2vpp.acl.AclTestSchemaContext;
+import io.fd.hc2vpp.acl.util.AclContextManager;
import io.fd.hc2vpp.common.test.write.WriterCustomizerTest;
+import io.fd.hc2vpp.common.translate.util.NamingContext;
+import io.fd.vpp.jvpp.acl.dto.AclInterfaceSetAclList;
+import io.fd.vpp.jvpp.acl.dto.AclInterfaceSetAclListReply;
import io.fd.vpp.jvpp.acl.future.FutureJVppAclFacade;
import org.junit.Test;
import org.mockito.Mock;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.Interfaces;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.InterfaceKey;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang._interface.acl.rev161214.VppAclInterfaceAugmentation;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang._interface.acl.rev161214._interface.acl.attributes.Acl;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang._interface.acl.rev161214._interface.acl.attributes.AclBuilder;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
public class InterfaceAclCustomizerTest extends WriterCustomizerTest implements AclTestSchemaContext {
+ private static final String IFC_CTX_NAME = "ifc-test-instance";
+ private static final String IFACE_NAME = "eth0";
+ private static final int IFACE_ID = 123;
+
@Mock
private FutureJVppAclFacade aclApi;
+ @Mock
+ private AclContextManager standardAclContext;
+
+ private InterfaceAclCustomizer customizer;
+ private NamingContext interfaceContext;
+ private InstanceIdentifier<Acl> ACL_ID = InstanceIdentifier.create(Interfaces.class)
+ .child(Interface.class, new InterfaceKey(IFACE_NAME)).augmentation(VppAclInterfaceAugmentation.class).child(Acl.class);
@Override
protected void setUpTest() throws Exception {
-
+ defineMapping(mappingContext, IFACE_NAME, IFACE_ID, IFC_CTX_NAME);
+ interfaceContext = new NamingContext("generatedIfaceName", IFC_CTX_NAME);
+ customizer = new InterfaceAclCustomizer(aclApi, interfaceContext, standardAclContext);
+ when(aclApi.aclInterfaceSetAclList(any())).thenReturn(future(new AclInterfaceSetAclListReply()));
}
@Test
- public void writeCurrentAttributes() throws Exception {
-
+ public void testWrite() throws Exception {
+ final Acl acl = new AclBuilder().build();
+ customizer.writeCurrentAttributes(ACL_ID, acl, writeContext);
+ final AclInterfaceSetAclList list = new AclInterfaceSetAclList();
+ list.swIfIndex = IFACE_ID;
+ list.acls = new int[]{};
+ verify(aclApi).aclInterfaceSetAclList(list);
}
@Test
- public void updateCurrentAttributes() throws Exception {
-
+ public void testUpdate() throws Exception {
+ final Acl acl = new AclBuilder().build();
+ customizer.updateCurrentAttributes(ACL_ID, acl, acl, writeContext);
+ final AclInterfaceSetAclList list = new AclInterfaceSetAclList();
+ list.swIfIndex = IFACE_ID;
+ list.acls = new int[]{};
+ verify(aclApi).aclInterfaceSetAclList(list);
}
@Test
- public void deleteCurrentAttributes() throws Exception {
-
+ public void testDelete() throws Exception {
+ final Acl acl = new AclBuilder().build();
+ customizer.deleteCurrentAttributes(ACL_ID, acl, writeContext);
+ final AclInterfaceSetAclList list = new AclInterfaceSetAclList();
+ list.swIfIndex = IFACE_ID;
+ list.acls = new int[]{};
+ verify(aclApi).aclInterfaceSetAclList(list);
}
}
\ No newline at end of file
--- /dev/null
+/*
+ * Copyright (c) 2017 Cisco and/or its affiliates.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at:
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package io.fd.hc2vpp.acl.write;
+
+import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+import io.fd.hc2vpp.acl.AclTestSchemaContext;
+import io.fd.hc2vpp.acl.util.AclContextManager;
+import io.fd.hc2vpp.common.test.write.WriterCustomizerTest;
+import io.fd.hc2vpp.common.translate.util.NamingContext;
+import io.fd.honeycomb.translate.write.WriteFailedException;
+import io.fd.vpp.jvpp.acl.dto.MacipAclInterfaceAddDel;
+import io.fd.vpp.jvpp.acl.dto.MacipAclInterfaceAddDelReply;
+import io.fd.vpp.jvpp.acl.future.FutureJVppAclFacade;
+import org.junit.Test;
+import org.mockito.Mock;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.Interfaces;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.Interface;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.interfaces.rev140508.interfaces.InterfaceKey;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang._interface.acl.rev161214.VppAclInterfaceAugmentation;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang._interface.acl.rev161214._interface.acl.attributes.Acl;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang._interface.acl.rev161214._interface.acl.attributes.acl.Ingress;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang._interface.acl.rev161214.vpp.macip.acls.base.attributes.VppMacipAcl;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang._interface.acl.rev161214.vpp.macip.acls.base.attributes.VppMacipAclBuilder;
+import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
+
+public class InterfaceAclMacipCustomizerTest extends WriterCustomizerTest implements AclTestSchemaContext {
+
+ private static final String IFC_CTX_NAME = "ifc-test-instance";
+ private static final String IFACE_NAME = "eth0";
+ private static final int IFACE_ID = 123;
+ private static final String ACL_NAME = "macip_acl";
+ private static final int ACL_ID = 111;
+
+ @Mock
+ private FutureJVppAclFacade aclApi;
+ @Mock
+ private AclContextManager macipAclContext;
+
+ private InterfaceAclMacIpCustomizer customizer;
+ private NamingContext interfaceContext;
+ private InstanceIdentifier<VppMacipAcl> ACL_IID = InstanceIdentifier.create(Interfaces.class)
+ .child(Interface.class, new InterfaceKey(IFACE_NAME)).augmentation(VppAclInterfaceAugmentation.class)
+ .child(Acl.class).child(Ingress.class).child(VppMacipAcl.class);
+ private VppMacipAcl acl;
+
+ @Override
+ protected void setUpTest() throws Exception {
+ defineMapping(mappingContext, IFACE_NAME, IFACE_ID, IFC_CTX_NAME);
+ interfaceContext = new NamingContext("generatedIfaceName", IFC_CTX_NAME);
+ customizer = new InterfaceAclMacIpCustomizer(aclApi, macipAclContext, interfaceContext);
+ acl = new VppMacipAclBuilder().setName(ACL_NAME).build();
+ when(macipAclContext.getAclIndex(ACL_NAME, mappingContext)).thenReturn(ACL_ID);
+ when(aclApi.macipAclInterfaceAddDel(any())).thenReturn(future(new MacipAclInterfaceAddDelReply()));
+ }
+
+ @Test
+ public void testWrite() throws Exception {
+ customizer.writeCurrentAttributes(ACL_IID, acl, writeContext);
+ final MacipAclInterfaceAddDel request = new MacipAclInterfaceAddDel();
+ request.swIfIndex = IFACE_ID;
+ request.isAdd = 1;
+ request.aclIndex = ACL_ID;
+ verify(aclApi).macipAclInterfaceAddDel(request);
+ }
+
+ @Test(expected = WriteFailedException.UpdateFailedException.class)
+ public void testUpdate() throws Exception {
+ customizer.updateCurrentAttributes(ACL_IID, acl, acl, writeContext);
+ }
+
+ @Test
+ public void testDelete() throws Exception {
+ customizer.deleteCurrentAttributes(ACL_IID, acl, writeContext);
+ final MacipAclInterfaceAddDel request = new MacipAclInterfaceAddDel();
+ request.swIfIndex = IFACE_ID;
+ request.isAdd = 0;
+ request.aclIndex = ACL_ID;
+ verify(aclApi).macipAclInterfaceAddDel(request);
+ }
+
+}
\ No newline at end of file
Code Review / hc2vpp.git / commitdiff