@Test
public void testPreprendClientAttribute() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("client-attribute-append-test")).findFirst().get();
+ .filter(st -> st.getName().equals("client-attribute-append-test")).findFirst().orElseThrow();
final Attributes att = new AttributesBuilder()
.setCNextHop(new Ipv4NextHopCaseBuilder().setIpv4NextHop(new Ipv4NextHopBuilder()
.setGlobal(IPV4).build()).build())
@Test
public void testMultipleAppend() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("multiple-append-test")).findFirst().get();
+ .filter(st -> st.getName().equals("multiple-append-test")).findFirst().orElseThrow();
final RouteAttributeContainer attributeContainer
= routeAttributeContainerFalse(new AttributesBuilder().build());
RouteAttributeContainer result = statementRegistry.applyExportStatement(
@Test
public void testNextHopSelf() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("next-hop-self-append-test")).findFirst().get();
+ .filter(st -> st.getName().equals("next-hop-self-append-test")).findFirst().orElseThrow();
final RouteAttributeContainer attributeContainer
= routeAttributeContainerFalse(new AttributesBuilder().build());
RouteAttributeContainer result = statementRegistry.applyExportStatement(
import static org.mockito.Mockito.doReturn;
import static org.opendaylight.protocol.bgp.openconfig.routing.policy.spi.registry.RouteAttributeContainer.routeAttributeContainerFalse;
-import java.util.Arrays;
-import java.util.Collections;
import java.util.List;
import org.junit.Before;
import org.junit.Test;
@Test
public void testASPathLengthEq() {
final AsPathBuilder asPath = new AsPathBuilder();
- asPath.setSegments(Collections.singletonList(new SegmentsBuilder()
- .setAsSequence(Arrays.asList(
+ asPath.setSegments(List.of(new SegmentsBuilder()
+ .setAsSequence(List.of(
AsNumber.getDefaultInstance("1"),
AsNumber.getDefaultInstance("2"),
AsNumber.getDefaultInstance("3")))
.build()));
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("as-path-eq-length-test")).findFirst().get();
+ .filter(st -> st.getName().equals("as-path-eq-length-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(new AttributesBuilder()
.setAsPath(asPath.build())
.build());
statement);
assertNotNull(result.getAttributes());
- asPath.setSegments(Collections.singletonList(new SegmentsBuilder()
- .setAsSequence(Arrays.asList(
+ asPath.setSegments(List.of(new SegmentsBuilder()
+ .setAsSequence(List.of(
AsNumber.getDefaultInstance("1"),
AsNumber.getDefaultInstance("3")))
.build()));
@Test
public void testASPathLengthGe() {
final AsPathBuilder asPath = new AsPathBuilder();
- asPath.setSegments(Collections.singletonList(new SegmentsBuilder()
- .setAsSequence(Arrays.asList(
+ asPath.setSegments(List.of(new SegmentsBuilder()
+ .setAsSequence(List.of(
AsNumber.getDefaultInstance("1"),
AsNumber.getDefaultInstance("2"),
AsNumber.getDefaultInstance("3")))
.build()));
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("as-path-ge-length-test")).findFirst().get();
+ .filter(st -> st.getName().equals("as-path-ge-length-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(new AttributesBuilder()
.setAsPath(asPath.build())
.build());
statement);
assertNull(result.getAttributes());
- asPath.setSegments(Collections.singletonList(new SegmentsBuilder()
- .setAsSequence(Collections.singletonList(
- AsNumber.getDefaultInstance("3")))
+ asPath.setSegments(List.of(new SegmentsBuilder()
+ .setAsSequence(List.of(AsNumber.getDefaultInstance("3")))
.build()));
attributeContainer = routeAttributeContainerFalse(new AttributesBuilder().setAsPath(asPath.build()).build());
@Test
public void testASPathLengthLe() {
final AsPathBuilder asPath = new AsPathBuilder();
- asPath.setSegments(Collections.singletonList(new SegmentsBuilder()
- .setAsSequence(Arrays.asList(
+ asPath.setSegments(List.of(new SegmentsBuilder()
+ .setAsSequence(List.of(
AsNumber.getDefaultInstance("1"),
AsNumber.getDefaultInstance("2"),
AsNumber.getDefaultInstance("3")))
.build()));
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("as-path-le-length-test")).findFirst().get();
+ .filter(st -> st.getName().equals("as-path-le-length-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(new AttributesBuilder()
.setAsPath(asPath.build())
.build());
statement);
assertNotNull(result.getAttributes());
- asPath.setSegments(Collections.singletonList(new SegmentsBuilder()
- .setAsSequence(Collections.singletonList(AsNumber.getDefaultInstance("3"))).build()));
+ asPath.setSegments(List.of(new SegmentsBuilder()
+ .setAsSequence(List.of(AsNumber.getDefaultInstance("3"))).build()));
attributeContainer = routeAttributeContainerFalse(new AttributesBuilder().setAsPath(asPath.build()).build());
result = statementRegistry.applyExportStatement(
@Test
public void testMedEq() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("med-eq-test")).findFirst().get();
+ .filter(st -> st.getName().equals("med-eq-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(new AttributesBuilder()
.setMultiExitDisc(new MultiExitDiscBuilder().setMed(Uint32.valueOf(200)).build())
.build());
@Test
public void testOriginEq() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("origin-eq-test")).findFirst().get();
+ .filter(st -> st.getName().equals("origin-eq-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(new AttributesBuilder()
.setOrigin(new OriginBuilder().setValue(BgpOrigin.Egp).build())
.build());
@Test
public void testNextHopIn() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("nexthop-in-test")).findFirst().get();
+ .filter(st -> st.getName().equals("nexthop-in-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(new AttributesBuilder()
.setCNextHop(new Ipv6NextHopCaseBuilder().setIpv6NextHop(new Ipv6NextHopBuilder()
.setGlobal(new Ipv6AddressNoZone("2001:db8::1")).build()).build())
@Test
public void testLocalPref() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("local-pref-eq-test")).findFirst().get();
+ .filter(st -> st.getName().equals("local-pref-eq-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(new AttributesBuilder()
.setLocalPref(new LocalPrefBuilder().setPref(Uint32.valueOf(350)).build())
.build());
@Test
public void testAfiSafiIn() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("afi-safi-in-test")).findFirst().get();
+ .filter(st -> st.getName().equals("afi-safi-in-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(new AttributesBuilder()
.setLocalPref(new LocalPrefBuilder().setPref(Uint32.valueOf(350)).build())
.build());
doReturn(toPeerRole).when(exportParameters).getToPeerRole();
doReturn(AS).when(exportParameters).getToPeerLocalAs();
return defaultExportStatements.stream()
- .filter(st -> st.getName().equals(statementName)).findFirst().get();
+ .filter(st -> st.getName().equals(statementName))
+ .findFirst()
+ .orElseThrow();
}
private void assertApplyExportStatement(
public void testFromEbgp() {
final Statement statement = getStatement("from-external");
- final RouteAttributeContainer attributeContainer
- = routeAttributeContainerFalse(ImportAttributeTestUtil.createInput());
+ final RouteAttributeContainer attributeContainer =
+ routeAttributeContainerFalse(ImportAttributeTestUtil.createInput());
assertApplyImportStatement(statement, PeerRole.Ebgp, attributeContainer,
ImportAttributeTestUtil.createOutput());
final Statement statement = getStatement("from-non-external");
final Attributes expected = ImportAttributeTestUtil.createInput();
- final RouteAttributeContainer attributeContainer
- = routeAttributeContainerFalse(expected);
+ final RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(expected);
assertApplyImportStatement(statement, PeerRole.Ibgp, attributeContainer, expected);
assertApplyImportStatement(statement, PeerRole.RrClient, attributeContainer, expected);
private Statement getStatement(final String statementName) {
return defaultImportStatements.stream()
- .filter(st -> st.getName().equals(statementName)).findFirst().get();
+ .filter(st -> st.getName().equals(statementName))
+ .findFirst()
+ .orElseThrow();
}
private void assertApplyImportStatement(
@Test
public void testExtComAny() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("match-afi-safi-not-in-test")).findFirst().get();
+ .filter(st -> st.getName().equals("match-afi-safi-not-in-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(
new AttributesBuilder().build());
RouteAttributeContainer result = statementRegistry.applyExportStatement(
baseAttributes = new PolicyRIBBaseParametersImpl(LOCAL_AS, IPV4, CLUSTER);
}
-
@Test
public void testMatchAsPathAny() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("reject-match-as-path-any-set")).findFirst().get();
+ .filter(st -> st.getName().equals("reject-match-as-path-any-set")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(
new AttributesBuilder().build());
RouteAttributeContainer result = statementRegistry.applyExportStatement(
@Test
public void testMatchAsPathAll() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("reject-match-as-path-all-set")).findFirst().get();
+ .filter(st -> st.getName().equals("reject-match-as-path-all-set")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(new AttributesBuilder()
.setAsPath(new AsPathBuilder().setSegments(List.of(
new SegmentsBuilder().setAsSequence(List.of(
@Test
public void testMatchAsPathInverse() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("reject-match-as-path-inverse-set")).findFirst().get();
+ .filter(st -> st.getName().equals("reject-match-as-path-inverse-set")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(
new AttributesBuilder()
.setAsPath(new AsPathBuilder().setSegments(List.of(
@Test
public void testMatchFromBgpNeighborAny() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("reject-from-neighbor-test")).findFirst().get();
+ .filter(st -> st.getName().equals("reject-from-neighbor-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(
new AttributesBuilder().build());
@Test
public void testMatchFromBgpNeighborInvert() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("reject-from-neighbor-invert-test")).findFirst().get();
+ .filter(st -> st.getName().equals("reject-from-neighbor-invert-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(
new AttributesBuilder().build());
@Test
public void testMatchToBgpNeighborAny() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("reject-to-neighbor-test")).findFirst().get();
+ .filter(st -> st.getName().equals("reject-to-neighbor-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(
new AttributesBuilder().build());
@Test
public void testMatchToBgpNeighborInvert() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("reject-to-neighbor-invert-test")).findFirst().get();
+ .filter(st -> st.getName().equals("reject-to-neighbor-invert-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(
new AttributesBuilder().build());
@Test
public void testComAny() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("community-any-test")).findFirst().get();
+ .filter(st -> st.getName().equals("community-any-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(
new AttributesBuilder().build());
RouteAttributeContainer result = statementRegistry.applyExportStatement(
@Test
public void testComInvert() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("community-invert-test")).findFirst().get();
+ .filter(st -> st.getName().equals("community-invert-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(
new AttributesBuilder().build());
RouteAttributeContainer result = statementRegistry.applyExportStatement(
@Test
public void testComAll() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("community-all-test")).findFirst().get();
+ .filter(st -> st.getName().equals("community-all-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(
new AttributesBuilder().build());
RouteAttributeContainer result = statementRegistry.applyExportStatement(
* terms of the Eclipse Public License v1.0 which accompanies this distribution,
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
-
package org.opendaylight.protocol.bgp.openconfig.routing.policy.statement;
import static org.junit.Assert.assertNotNull;
import static org.opendaylight.protocol.bgp.openconfig.routing.policy.spi.registry.RouteAttributeContainer.routeAttributeContainerFalse;
import static org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.EncapsulationTunnelType.Vxlan;
-import java.util.Arrays;
-import java.util.Collections;
import java.util.List;
import org.junit.Before;
import org.junit.Test;
@Test
public void testExtComAny() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("ext-community-any-test")).findFirst().get();
- RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(
- new AttributesBuilder().build());
+ .filter(st -> st.getName().equals("ext-community-any-test")).findFirst().orElseThrow();
+ RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(new AttributesBuilder().build());
RouteAttributeContainer result = statementRegistry.applyExportStatement(
baseAttributes, IPV4UNICAST.VALUE, exportParameters, attributeContainer, statement);
assertNotNull(result.getAttributes());
attributeContainer = routeAttributeContainerFalse(new AttributesBuilder()
- .setExtendedCommunities(Collections.singletonList(new ExtendedCommunitiesBuilder()
- .setExtendedCommunity(new As4RouteOriginExtendedCommunityCaseBuilder()
- .setAs4RouteOriginExtendedCommunity(new As4RouteOriginExtendedCommunityBuilder()
- .setAs4SpecificCommon(new As4SpecificCommonBuilder()
- .setAsNumber(AsNumber.getDefaultInstance("65000"))
- .setLocalAdministrator(Uint16.valueOf(123))
- .build()).build()).build()).build())).build());
+ .setExtendedCommunities(List.of(new ExtendedCommunitiesBuilder()
+ .setExtendedCommunity(new As4RouteOriginExtendedCommunityCaseBuilder()
+ .setAs4RouteOriginExtendedCommunity(new As4RouteOriginExtendedCommunityBuilder()
+ .setAs4SpecificCommon(new As4SpecificCommonBuilder()
+ .setAsNumber(AsNumber.getDefaultInstance("65000"))
+ .setLocalAdministrator(Uint16.valueOf(123))
+ .build())
+ .build())
+ .build())
+ .build()))
+ .build());
result = statementRegistry.applyExportStatement(
baseAttributes, IPV4UNICAST.VALUE, exportParameters, attributeContainer, statement);
@Test
public void testExtComAll() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("ext-community-all-test")).findFirst().get();
+ .filter(st -> st.getName().equals("ext-community-all-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(
new AttributesBuilder().build());
RouteAttributeContainer result = statementRegistry.applyExportStatement(
assertNotNull(result.getAttributes());
- attributeContainer = routeAttributeContainerFalse(new AttributesBuilder().setExtendedCommunities(Arrays.asList(
+ attributeContainer = routeAttributeContainerFalse(new AttributesBuilder().setExtendedCommunities(List.of(
new ExtendedCommunitiesBuilder().setExtendedCommunity(new As4RouteOriginExtendedCommunityCaseBuilder()
.setAs4RouteOriginExtendedCommunity(
new As4RouteOriginExtendedCommunityBuilder()
@Test
public void testExtComInvert() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("ext-community-invert-test")).findFirst().get();
+ .filter(st -> st.getName().equals("ext-community-invert-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(
new AttributesBuilder().build());
RouteAttributeContainer result = statementRegistry.applyExportStatement(
assertNull(result.getAttributes());
attributeContainer = routeAttributeContainerFalse(new AttributesBuilder()
- .setExtendedCommunities(Collections.singletonList(new ExtendedCommunitiesBuilder()
+ .setExtendedCommunities(List.of(new ExtendedCommunitiesBuilder()
.setExtendedCommunity(new As4RouteOriginExtendedCommunityCaseBuilder()
.setAs4RouteOriginExtendedCommunity(new As4RouteOriginExtendedCommunityBuilder()
.setAs4SpecificCommon(new As4SpecificCommonBuilder()
* terms of the Eclipse Public License v1.0 which accompanies this distribution,
* and is available at http://www.eclipse.org/legal/epl-v10.html
*/
-
package org.opendaylight.protocol.bgp.openconfig.routing.policy.statement;
import static org.junit.Assert.assertEquals;
import static org.mockito.Mockito.doReturn;
import static org.opendaylight.protocol.bgp.openconfig.routing.policy.spi.registry.RouteAttributeContainer.routeAttributeContainerFalse;
-import java.util.Arrays;
-import java.util.Collections;
import java.util.List;
import org.junit.Before;
import org.junit.Test;
import org.opendaylight.yangtools.yang.common.Uint16;
public class SetCommunityTest extends AbstractStatementRegistryConsumerTest {
- private final Attributes multipleCom = new AttributesBuilder().setCommunities(Arrays.asList(
+ private final Attributes multipleCom = new AttributesBuilder().setCommunities(List.of(
new CommunitiesBuilder().setAsNumber(AsNumber.getDefaultInstance("65")).setSemantics(Uint16.valueOf(10))
.build(),
new CommunitiesBuilder().setAsNumber(AsNumber.getDefaultInstance("66")).setSemantics(Uint16.valueOf(11))
.build()
)).build();
- private final Attributes emptyCom = new AttributesBuilder().setCommunities(Collections.emptyList()).build();
+ private final Attributes emptyCom = new AttributesBuilder().setCommunities(List.of()).build();
@Mock
private BGPRouteEntryExportParameters exportParameters;
private List<Statement> basicStatements;
@Test
public void testInlineAdd() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("set-community-inline-add-test")).findFirst().get();
+ .filter(st -> st.getName().equals("set-community-inline-add-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(
new AttributesBuilder().build());
RouteAttributeContainer result = statementRegistry.applyExportStatement(
@Test
public void testInlineReplace() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("set-community-inline-replace-test")).findFirst().get();
+ .filter(st -> st.getName().equals("set-community-inline-replace-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(
new AttributesBuilder().build());
RouteAttributeContainer result = statementRegistry.applyExportStatement(
@Test
public void testInlineRemove() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("set-community-inline-remove-test")).findFirst().get();
+ .filter(st -> st.getName().equals("set-community-inline-remove-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(multipleCom);
RouteAttributeContainer result = statementRegistry.applyExportStatement(
@Test
public void testReferenceAdd() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("set-community-reference-add-test")).findFirst().get();
+ .filter(st -> st.getName().equals("set-community-reference-add-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(
new AttributesBuilder().build());
RouteAttributeContainer result = statementRegistry.applyExportStatement(
@Test
public void testReferenceReplace() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("set-community-reference-replace-test")).findFirst().get();
+ .filter(st -> st.getName().equals("set-community-reference-replace-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(
new AttributesBuilder().build());
RouteAttributeContainer result = statementRegistry.applyExportStatement(
@Test
public void testReferenceRemove() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("set-community-reference-remove-test")).findFirst().get();
+ .filter(st -> st.getName().equals("set-community-reference-remove-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(multipleCom);
RouteAttributeContainer result = statementRegistry.applyExportStatement(
import static org.opendaylight.protocol.bgp.openconfig.routing.policy.spi.registry.RouteAttributeContainer.routeAttributeContainerFalse;
import static org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev200120.EncapsulationTunnelType.Vxlan;
-import java.util.Arrays;
-import java.util.Collections;
import java.util.List;
import org.junit.Before;
import org.junit.Test;
import org.opendaylight.yangtools.yang.common.Uint32;
public class SetExtCommunityTest extends AbstractStatementRegistryConsumerTest {
- private final Attributes multipleExtCom = new AttributesBuilder().setExtendedCommunities(Arrays.asList(
+ private final Attributes multipleExtCom = new AttributesBuilder().setExtendedCommunities(List.of(
new ExtendedCommunitiesBuilder().setExtendedCommunity(new EncapsulationCaseBuilder()
.setEncapsulationExtendedCommunity(new EncapsulationExtendedCommunityBuilder()
.setTunnelType(Vxlan).build()).build()).build(),
.setLocalAdministrator(Uint16.valueOf(123))
.setAsNumber(new AsNumber(Uint32.valueOf(65000))).build())
.build()).build()).build())).build();
- private final Attributes emptyExtCom = new AttributesBuilder()
- .setExtendedCommunities(Collections.emptyList()).build();
+ private final Attributes emptyExtCom = new AttributesBuilder().setExtendedCommunities(List.of()).build();
@Mock
private BGPRouteEntryExportParameters exportParameters;
private List<Statement> basicStatements;
@Test
public void testInlineAdd() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("set-ext-community-inline-add-test")).findFirst().get();
+ .filter(st -> st.getName().equals("set-ext-community-inline-add-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(
new AttributesBuilder().build());
RouteAttributeContainer result = statementRegistry.applyExportStatement(
@Test
public void testInlineReplace() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("set-ext-community-inline-replace-test")).findFirst().get();
+ .filter(st -> st.getName().equals("set-ext-community-inline-replace-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(
new AttributesBuilder().build());
RouteAttributeContainer result = statementRegistry.applyExportStatement(
@Test
public void testInlineRemove() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("set-ext-community-inline-remove-test")).findFirst().get();
+ .filter(st -> st.getName().equals("set-ext-community-inline-remove-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(multipleExtCom);
RouteAttributeContainer result = statementRegistry.applyExportStatement(
@Test
public void testReferenceAdd() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("set-ext-community-reference-add-test")).findFirst().get();
+ .filter(st -> st.getName().equals("set-ext-community-reference-add-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(
new AttributesBuilder().build());
RouteAttributeContainer result = statementRegistry.applyExportStatement(
@Test
public void testReferenceReplace() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("set-ext-community-reference-replace-test")).findFirst().get();
+ .filter(st -> st.getName().equals("set-ext-community-reference-replace-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(
new AttributesBuilder().build());
RouteAttributeContainer result = statementRegistry.applyExportStatement(
@Test
public void testReferenceRemove() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("set-ext-community-reference-remove-test")).findFirst().get();
+ .filter(st -> st.getName().equals("set-ext-community-reference-remove-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(multipleExtCom);
RouteAttributeContainer result = statementRegistry.applyExportStatement(
@Test
public void testExtComAny() {
Statement statement = basicStatements.stream()
- .filter(st -> st.getName().equals("vpn-non-member-test")).findFirst().get();
+ .filter(st -> st.getName().equals("vpn-non-member-test")).findFirst().orElseThrow();
RouteAttributeContainer attributeContainer = routeAttributeContainerFalse(
new AttributesBuilder()
.setExtendedCommunities(List.of(new ExtendedCommunitiesBuilder()
import static org.junit.Assert.assertArrayEquals;
import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertFalse;
import static org.mockito.Mockito.doReturn;
import com.google.common.primitives.UnsignedBytes;
@RunWith(MockitoJUnitRunner.StrictStubs.class)
public class UtilsTest {
-
- @Mock private AddressFamilyRegistry afiReg;
- @Mock private SubsequentAddressFamilyRegistry safiReg;
+ @Mock
+ private AddressFamilyRegistry afiReg;
+ @Mock
+ private SubsequentAddressFamilyRegistry safiReg;
@Before
public void setUp() {
public void testMultiprotocolCapabilitiesUtil() throws BGPParsingException {
final byte[] bytes = new byte[] {0, 1, 0, 1};
final ByteBuf bytesBuf = Unpooled.copiedBuffer(bytes);
- final BgpTableType parsedAfiSafi = MultiprotocolCapabilitiesUtil.parseMPAfiSafi(bytesBuf, afiReg,
- safiReg).get();
+ final BgpTableType parsedAfiSafi = MultiprotocolCapabilitiesUtil.parseMPAfiSafi(bytesBuf, afiReg, safiReg)
+ .orElseThrow();
assertEquals(Ipv4AddressFamily.VALUE, parsedAfiSafi.getAfi());
assertEquals(UnicastSubsequentAddressFamily.VALUE, parsedAfiSafi.getSafi());
public void testUnsupportedAfi() {
final byte[] bytes = new byte[] {0, 2, 0, 1};
final ByteBuf bytesBuf = Unpooled.copiedBuffer(bytes);
- final Optional<BgpTableType> parsedAfiSafi = MultiprotocolCapabilitiesUtil.parseMPAfiSafi(bytesBuf, afiReg,
- safiReg);
- assertFalse(parsedAfiSafi.isPresent());
+ assertEquals(Optional.empty(), MultiprotocolCapabilitiesUtil.parseMPAfiSafi(bytesBuf, afiReg, safiReg));
}
@Test
public void testUnsupportedSafi() {
final byte[] bytes = new byte[] {0, 1, 0, 3};
final ByteBuf bytesBuf = Unpooled.copiedBuffer(bytes);
- final Optional<BgpTableType> parsedAfiSafi = MultiprotocolCapabilitiesUtil.parseMPAfiSafi(bytesBuf, afiReg,
- safiReg);
- assertFalse(parsedAfiSafi.isPresent());
+ assertEquals(Optional.empty(), MultiprotocolCapabilitiesUtil.parseMPAfiSafi(bytesBuf, afiReg, safiReg));
}
@Test(expected = ParameterLengthOverflowException.class)
private AbstractRIBSupport<C, S, R> abstractRIBSupport;
protected final void setUpTestCustomizer(final AbstractRIBSupport<C, S, R> ribSupport) throws Exception {
- this.abstractRIBSupport = ribSupport;
+ abstractRIBSupport = ribSupport;
}
@Before
AbstractRIBSupportTest.this.insertedRoutes.add(adapter.currentSerializer()
.fromNormalizedNode((YangInstanceIdentifier) args[1], (NormalizedNode) args[2]));
return args[1];
- }).when(this.tx).put(any(LogicalDatastoreType.class), any(YangInstanceIdentifier.class),
+ }).when(tx).put(any(LogicalDatastoreType.class), any(YangInstanceIdentifier.class),
any(NormalizedNode.class));
doAnswer(invocation -> {
AbstractRIBSupportTest.this.deletedRoutes.add((InstanceIdentifier)
adapter.currentSerializer().fromYangInstanceIdentifier((YangInstanceIdentifier) args[1]));
return args[1];
- }).when(this.tx).delete(any(LogicalDatastoreType.class), any(YangInstanceIdentifier.class));
- this.deletedRoutes = new ArrayList<>();
- this.insertedRoutes = new ArrayList<>();
+ }).when(tx).delete(any(LogicalDatastoreType.class), any(YangInstanceIdentifier.class));
+ deletedRoutes = new ArrayList<>();
+ insertedRoutes = new ArrayList<>();
}
@Override
protected final AbstractDataBrokerTestCustomizer createDataBrokerTestCustomizer() {
final AbstractDataBrokerTestCustomizer customizer = super.createDataBrokerTestCustomizer();
- this.adapter = customizer.getAdapterContext();
+ adapter = customizer.getAdapterContext();
return customizer;
}
final Tables tables = new TablesBuilder().withKey(getTablesKey())
.setAttributes(new org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.rib.rev180329
.rib.tables.AttributesBuilder().build()).build();
- return (MapEntryNode) this.adapter.currentSerializer().toNormalizedNode(tablesIId(), tables).getValue();
+ return (MapEntryNode) adapter.currentSerializer().toNormalizedNode(tablesIId(), tables).getValue();
}
protected final ChoiceNode createRoutes(final Routes routes) {
final Tables tables = new TablesBuilder().withKey(getTablesKey()).setRoutes(routes).build();
- return (ChoiceNode) verifyNotNull(((MapEntryNode) this.adapter.currentSerializer()
+ return (ChoiceNode) verifyNotNull(((MapEntryNode) adapter.currentSerializer()
.toNormalizedNode(tablesIId(), tables).getValue())
.childByArg(new NodeIdentifier(BindingReflections.findQName(Routes.class))));
}
protected final Collection<MapEntryNode> createRoutes(final S routes) {
Preconditions.checkArgument(routes.implementedInterface()
- .equals(this.abstractRIBSupport.routesContainerClass()));
+ .equals(abstractRIBSupport.routesContainerClass()));
final InstanceIdentifier<S> routesIId = routesIId();
- final Map.Entry<YangInstanceIdentifier, NormalizedNode> normalizedNode = this.adapter.currentSerializer()
+ final Map.Entry<YangInstanceIdentifier, NormalizedNode> normalizedNode = adapter.currentSerializer()
.toNormalizedNode(routesIId, routes);
final ContainerNode container = (ContainerNode) normalizedNode.getValue();
final NodeIdentifier routeNid = new NodeIdentifier(getRouteListQname());
- return ((MapNode) verifyNotNull(container.childByArg(routeNid))).body();
+ return ((MapNode) container.getChildByArg(routeNid)).body();
}
private TablesKey getTablesKey() {
- return new TablesKey(this.abstractRIBSupport.getAfi(), this.abstractRIBSupport.getSafi());
+ return new TablesKey(abstractRIBSupport.getAfi(), abstractRIBSupport.getSafi());
}
private InstanceIdentifier<Tables> tablesIId() {
private InstanceIdentifier<S> routesIId() {
final InstanceIdentifier<Tables> tables = tablesIId();
- return tables.child(this.abstractRIBSupport.routesCaseClass(), this.abstractRIBSupport.routesContainerClass());
+ return tables.child(abstractRIBSupport.routesCaseClass(), abstractRIBSupport.routesContainerClass());
}
protected final YangInstanceIdentifier getTablePath() {
final InstanceIdentifier<Tables> tables = tablesIId();
- return this.adapter.currentSerializer().toYangInstanceIdentifier(tables);
+ return adapter.currentSerializer().toYangInstanceIdentifier(tables);
}
protected final YangInstanceIdentifier getRoutePath() {
final InstanceIdentifier<S> routesIId = routesIId();
- return this.adapter.currentSerializer().toYangInstanceIdentifier(routesIId).node(getRouteListQname());
+ return adapter.currentSerializer().toYangInstanceIdentifier(routesIId).node(getRouteListQname());
}
private QName getRouteListQname() {
- return BindingReflections.findQName(this.abstractRIBSupport.routesListClass())
- .bindTo(BindingReflections.getQNameModule(this.abstractRIBSupport.routesCaseClass()));
+ return BindingReflections.findQName(abstractRIBSupport.routesListClass())
+ .bindTo(BindingReflections.getQNameModule(abstractRIBSupport.routesCaseClass()));
}
protected final NodeIdentifierWithPredicates createRouteNIWP(final S routes) {
final List<Message> messages;
checkReceivedMessages(pceSessionListener, expectedTotalMessages);
if (startAtNumberLsp.isPresent()) {
- messages = pceSessionListener.messages().subList(startAtNumberLsp.get(),
- startAtNumberLsp.get() + expectedNumberOfLsp);
+ final int offset = startAtNumberLsp.orElseThrow();
+ messages = pceSessionListener.messages().subList(offset, offset + expectedNumberOfLsp);
} else {
messages = pceSessionListener.messages();
}
Code Review / bgpcep.git / commitdiff