2 * Copyright (c) 2016 Cisco Systems, Inc. and others. All rights reserved.
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
9 package org.opendaylight.protocol.bmp.mock;
11 import java.net.InetAddress;
12 import java.util.Collections;
13 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.AsNumber;
14 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
15 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address;
16 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Prefix;
17 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.PortNumber;
18 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.OpenBuilder;
19 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.OpenMessage;
20 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.ProtocolVersion;
21 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.path.attributes.AttributesBuilder;
22 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.path.attributes.attributes.AsPath;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.path.attributes.attributes.AsPathBuilder;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.path.attributes.attributes.Origin;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.path.attributes.attributes.OriginBuilder;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.message.rev180329.update.message.NlriBuilder;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev180329.BgpOrigin;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev180329.next.hop.c.next.hop.Ipv4NextHopCaseBuilder;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bgp.types.rev180329.next.hop.c.next.hop.ipv4.next.hop._case.Ipv4NextHopBuilder;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev180329.AdjRibInType;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev180329.InitiationMessage;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev180329.InitiationMessageBuilder;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev180329.PeerType;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev180329.PeerUpNotification;
35 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev180329.PeerUpNotificationBuilder;
36 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev180329.RouteMonitoringMessage;
37 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev180329.RouteMonitoringMessageBuilder;
38 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev180329.description.tlv.DescriptionTlvBuilder;
39 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev180329.initiation.TlvsBuilder;
40 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev180329.name.tlv.NameTlvBuilder;
41 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev180329.peer.header.PeerHeader;
42 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev180329.peer.header.PeerHeaderBuilder;
43 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev180329.peer.up.ReceivedOpenBuilder;
44 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev180329.peer.up.SentOpenBuilder;
45 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev180329.route.monitoring.message.Update;
46 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.bmp.message.rev180329.route.monitoring.message.UpdateBuilder;
48 final class BmpMockUtil {
50 private static final String DESCRIPTION = "OpenDaylight";
51 private static final String NAME = "BMP mock";
52 private static final int HOLD_TIMER = 180;
53 private static final AsNumber ASN = new AsNumber(65431L);
54 private static final Ipv4Address NEXT_HOP = new Ipv4Address("1.2.3.4");
55 private static final PortNumber PEER_PORT = new PortNumber(179);
56 private static final ProtocolVersion PROTOCOL_VERSION = new ProtocolVersion((short) 4);
57 private static final Origin ORIGIN = new OriginBuilder().setValue(BgpOrigin.Igp).build();
58 private static final AsPath AS_PATH = new AsPathBuilder().setSegments(Collections.emptyList()).build();
60 private BmpMockUtil() {
61 throw new UnsupportedOperationException();
64 static InitiationMessage createInitiation() {
65 final InitiationMessageBuilder msgBuilder = new InitiationMessageBuilder();
68 .setDescriptionTlv(new DescriptionTlvBuilder().setDescription(DESCRIPTION).build())
69 .setNameTlv(new NameTlvBuilder().setName(NAME).build())
71 return msgBuilder.build();
74 static PeerUpNotification createPeerUp(final Ipv4Address peerIp, final InetAddress localAddress) {
75 final PeerUpNotificationBuilder msgBuilder = new PeerUpNotificationBuilder();
76 msgBuilder.setLocalAddress(new IpAddress(new Ipv4Address(localAddress.getHostAddress())));
77 msgBuilder.setLocalPort(PEER_PORT);
78 msgBuilder.setRemotePort(PEER_PORT);
79 msgBuilder.setReceivedOpen(new ReceivedOpenBuilder(createOpen(peerIp)).build());
80 msgBuilder.setSentOpen(new SentOpenBuilder(createOpen(new Ipv4Address(localAddress.getHostAddress()))).build());
81 msgBuilder.setPeerHeader(createPeerHeader(peerIp, AdjRibInType.PrePolicy));
82 return msgBuilder.build();
85 private static OpenMessage createOpen(final Ipv4Address address) {
86 final OpenBuilder msgBuilder = new OpenBuilder();
87 msgBuilder.setBgpIdentifier(address);
88 msgBuilder.setHoldTimer(HOLD_TIMER);
89 msgBuilder.setMyAsNumber(ASN.getValue().intValue());
90 msgBuilder.setVersion(PROTOCOL_VERSION);
91 return msgBuilder.build();
94 private static PeerHeader createPeerHeader(final Ipv4Address bgpId, final AdjRibInType ribType) {
95 return new PeerHeaderBuilder()
96 .setAddress(new IpAddress(bgpId))
97 .setAdjRibInType(ribType)
98 .setAs(new AsNumber(ASN))
101 .setType(PeerType.Global)
105 static RouteMonitoringMessage createRouteMonitoring(final Ipv4Address bgpId, final AdjRibInType ribType,
106 final Ipv4Prefix prefix) {
107 final RouteMonitoringMessageBuilder routeMonitMsgBuilder = new RouteMonitoringMessageBuilder()
108 .setPeerHeader(createPeerHeader(bgpId, ribType))
109 .setUpdate(createUpdate(prefix));
110 return routeMonitMsgBuilder.build();
113 private static Update createUpdate(final Ipv4Prefix prefix) {
114 final UpdateBuilder updateBuilder = new UpdateBuilder()
115 .setAttributes(new AttributesBuilder().setOrigin(ORIGIN).setAsPath(AS_PATH).setCNextHop(
116 new Ipv4NextHopCaseBuilder().setIpv4NextHop(new Ipv4NextHopBuilder().setGlobal(NEXT_HOP).build())
118 .setNlri(Collections.singletonList(new NlriBuilder().setPrefix(prefix).build()));
119 return updateBuilder.build();