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
8 package org.opendaylight.groupbasedpolicy.renderer.vpp;
10 import java.util.Arrays;
11 import java.util.List;
12 import java.util.stream.Collectors;
13 import java.util.stream.Stream;
15 import org.opendaylight.groupbasedpolicy.api.sf.AllowActionDefinition;
16 import org.opendaylight.groupbasedpolicy.api.sf.EtherTypeClassifierDefinition;
17 import org.opendaylight.groupbasedpolicy.renderer.vpp.iface.VppPathMapper;
18 import org.opendaylight.groupbasedpolicy.renderer.vpp.util.KeyFactory;
19 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpAddress;
20 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.IpPrefix;
21 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Address;
22 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev130715.Ipv4Prefix;
23 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.base_endpoint.rev160427.common.endpoint.fields.NetworkContainment;
24 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.base_endpoint.rev160427.common.endpoint.fields.NetworkContainmentBuilder;
25 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.base_endpoint.rev160427.common.endpoint.fields.network.containment.containment.ForwardingContextContainmentBuilder;
26 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.base_endpoint.rev160427.has.absolute.location.AbsoluteLocation;
27 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.base_endpoint.rev160427.has.absolute.location.AbsoluteLocationBuilder;
28 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.base_endpoint.rev160427.has.absolute.location.absolute.location.location.type.ExternalLocationCaseBuilder;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.ActionName;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.ClassifierName;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.ContextId;
32 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.ContractId;
33 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.Name;
34 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.NetworkDomainId;
35 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.ParameterName;
36 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.RuleName;
37 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.SubjectName;
38 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.TenantId;
39 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.forwarding.l2_l3.rev160427.L2BridgeDomain;
40 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.forwarding.l2_l3.rev160427.L2FloodDomain;
41 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.forwarding.l2_l3.rev160427.L3Context;
42 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.forwarding.l2_l3.rev160427.Subnet;
43 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.forwarding.l2_l3.rev160427.SubnetAugmentRenderer;
44 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.forwarding.l2_l3.rev160427.SubnetAugmentRendererBuilder;
45 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.forwarding.l2_l3.rev160427.has.subnet.SubnetBuilder;
46 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.forwarding.rev160427.AddressType;
47 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.forwarding.rev160427.ContextType;
48 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.forwarding.rev160427.forwarding.fields.Parent;
49 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.forwarding.rev160427.forwarding.fields.ParentBuilder;
50 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.policy.rev140421.HasDirection.Direction;
51 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.policy.rev140421.subject.feature.instance.ParameterValue;
52 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.policy.rev140421.subject.feature.instance.ParameterValueBuilder;
53 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.EndpointPolicyParticipation;
54 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.has.rule.group.with.renderer.endpoint.participation.RuleGroupWithRendererEndpointParticipation;
55 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.has.rule.group.with.renderer.endpoint.participation.RuleGroupWithRendererEndpointParticipationBuilder;
56 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.Configuration;
57 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.ConfigurationBuilder;
58 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.Endpoints;
59 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.EndpointsBuilder;
60 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.RendererEndpointsBuilder;
61 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.RendererForwardingBuilder;
62 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.RuleGroups;
63 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.RuleGroupsBuilder;
64 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.endpoints.AddressEndpointWithLocation;
65 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.endpoints.AddressEndpointWithLocationBuilder;
66 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.endpoints.AddressEndpointWithLocationKey;
67 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.renderer.endpoints.RendererEndpoint;
68 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.renderer.endpoints.RendererEndpointBuilder;
69 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.renderer.endpoints.renderer.endpoint.PeerEndpoint;
70 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.renderer.endpoints.renderer.endpoint.PeerEndpointBuilder;
71 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.renderer.forwarding.RendererForwardingByTenant;
72 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.renderer.forwarding.RendererForwardingByTenantBuilder;
73 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.renderer.forwarding.renderer.forwarding.by.tenant.RendererForwardingContext;
74 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.renderer.forwarding.renderer.forwarding.by.tenant.RendererForwardingContextBuilder;
75 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.renderer.forwarding.renderer.forwarding.by.tenant.RendererNetworkDomain;
76 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.renderer.forwarding.renderer.forwarding.by.tenant.RendererNetworkDomainBuilder;
77 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.rule.groups.RuleGroup;
78 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.rule.groups.RuleGroupBuilder;
79 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.resolved.policy.rev150828.has.actions.Action;
80 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.resolved.policy.rev150828.has.actions.ActionBuilder;
81 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.resolved.policy.rev150828.has.classifiers.Classifier;
82 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.resolved.policy.rev150828.has.classifiers.ClassifierBuilder;
83 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.resolved.policy.rev150828.has.resolved.rules.ResolvedRule;
84 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.resolved.policy.rev150828.has.resolved.rules.ResolvedRuleBuilder;
85 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology;
86 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
87 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.TopologyId;
88 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
89 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.TopologyKey;
90 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
91 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeKey;
92 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
94 import com.google.common.base.Strings;
95 import com.google.common.collect.ImmutableList;
97 public class DtoFactory {
99 static IpPrefix subnetPrefix = new IpPrefix(new Ipv4Prefix("10.0.0.0/24"));
100 static IpAddress virtRouterIp = new IpAddress(new Ipv4Address("10.0.0.1"));
102 public static final ContextId CTX_ID = new ContextId("ctx");
103 public static final ContextId L3_CTX = new ContextId("l3ctx");
104 public static final ContextId L2BD_CTX = new ContextId("l2bd");
105 public static final ContextId L2FD_CTX = new ContextId("l2fd");
106 public static final ContractId CONTRACT_ID = new ContractId("contract");
107 public static final TenantId TENANT_ID = new TenantId("tenant");
108 public static final SubjectName SUBJECT_NAME = new SubjectName("subject");
109 public static final RuleName RULE_NAME = new RuleName("rule");
111 public static final Name L2_FD_ID = new Name("l2fd");
112 public static final Name L3_CTX_ID = new Name("l3ctx");
113 public static final Name L2_BD_ID = new Name("l2bd");
114 public static final Name SUBNET_ID = new Name("subnetId");
116 public static final RuleGroupWithRendererEndpointParticipation RULE_GROUP_WITH_CONSUMER =
117 new RuleGroupWithRendererEndpointParticipationBuilder().setContractId(CONTRACT_ID)
118 .setTenantId(TENANT_ID)
119 .setSubjectName(SUBJECT_NAME)
120 .setRendererEndpointParticipation(EndpointPolicyParticipation.CONSUMER)
122 public static final RuleGroupWithRendererEndpointParticipation RULE_GROUP_WITH_PROVIDER =
123 new RuleGroupWithRendererEndpointParticipationBuilder().setContractId(CONTRACT_ID)
124 .setTenantId(TENANT_ID)
125 .setSubjectName(SUBJECT_NAME)
126 .setRendererEndpointParticipation(EndpointPolicyParticipation.PROVIDER)
128 public final static TopologyKey TOPO_KEY = new TopologyKey(new TopologyId("topology-netconf"));
129 public final static InstanceIdentifier<Node> VPP_NODE_1_IID = InstanceIdentifier.builder(NetworkTopology.class)
130 .child(Topology.class, TOPO_KEY)
131 .child(Node.class, new NodeKey(new NodeId("node1")))
133 public final static InstanceIdentifier<Node> VPP_NODE_2_IID = InstanceIdentifier.builder(NetworkTopology.class)
134 .child(Topology.class, TOPO_KEY)
135 .child(Node.class, new NodeKey(new NodeId("node2")))
138 public static Configuration createConfiguration(List<AddressEndpointWithLocation> consumers,
139 List<AddressEndpointWithLocation> providers) {
140 List<AddressEndpointWithLocation> eps =
141 Stream.concat(consumers.stream(), providers.stream()).collect(Collectors.toList());
142 Endpoints endpoints = new EndpointsBuilder().setAddressEndpointWithLocation(eps).build();
143 List<RendererEndpoint> consumersAsRendererEps = consumers.stream().map(cons -> {
144 List<PeerEndpoint> peers = providers.stream()
145 .map(web -> new PeerEndpointBuilder().setKey(KeyFactory.peerEndpointKey(web.getKey()))
146 .setRuleGroupWithRendererEndpointParticipation(Arrays.asList(RULE_GROUP_WITH_CONSUMER))
148 .collect(Collectors.toList());
149 return new RendererEndpointBuilder().setKey(KeyFactory.rendererEndpointKey(cons.getKey()))
150 .setPeerEndpoint(peers)
152 }).collect(Collectors.toList());
153 List<RendererEndpoint> providersAsRendererEps = providers.stream().map(prov -> {
154 List<PeerEndpoint> peers = consumers.stream()
155 .map(client -> new PeerEndpointBuilder().setKey(KeyFactory.peerEndpointKey(client.getKey()))
156 .setRuleGroupWithRendererEndpointParticipation(Arrays.asList(RULE_GROUP_WITH_PROVIDER))
158 .collect(Collectors.toList());
159 return new RendererEndpointBuilder().setKey(KeyFactory.rendererEndpointKey(prov.getKey()))
160 .setPeerEndpoint(peers)
162 }).collect(Collectors.toList());
163 List<RendererEndpoint> rendererEps = Stream
164 .concat(consumersAsRendererEps.stream(), providersAsRendererEps.stream()).collect(Collectors.toList());
165 return new ConfigurationBuilder().setEndpoints(endpoints)
166 .setRendererEndpoints(new RendererEndpointsBuilder().setRendererEndpoint(rendererEps).build())
167 .setRuleGroups(new RuleGroupsBuilder(createRuleGroups()).build())
168 .setRendererForwarding(new RendererForwardingBuilder()
169 .setRendererForwardingByTenant(ImmutableList.<RendererForwardingByTenant>of(createForwarding()))
174 private static RendererForwardingByTenant createForwarding() {
175 RendererForwardingContext l2Fd = createRendererForwardingCtx(L2FD_CTX, L2_FD_ID, L2FloodDomain.class).setParent(
176 createParent(L2BD_CTX, L2BridgeDomain.class))
178 RendererForwardingContext l2Bd = createRendererForwardingCtx(L3_CTX, L3_CTX_ID, L3Context.class).setParent(
179 createParent(L3_CTX, L3Context.class))
181 RendererForwardingContext l3Ctx = createRendererForwardingCtx(L2BD_CTX, L2_BD_ID, L2BridgeDomain.class).build();
182 RendererNetworkDomain subnet = new RendererNetworkDomainBuilder().setNetworkDomainId(new NetworkDomainId(SUBNET_ID.getValue()))
184 .setNetworkDomainType(Subnet.class)
185 .setParent(createParent(L2FD_CTX, L2FloodDomain.class))
187 SubnetAugmentRenderer.class,
188 new SubnetAugmentRendererBuilder().setSubnet(
189 new SubnetBuilder().setIpPrefix(subnetPrefix).setVirtualRouterIp(virtRouterIp).setIsTenant(true).build())
192 return new RendererForwardingByTenantBuilder().setTenantId(TENANT_ID)
193 .setRendererForwardingContext(ImmutableList.<RendererForwardingContext>of(l2Fd, l2Bd, l3Ctx))
194 .setRendererNetworkDomain(ImmutableList.<RendererNetworkDomain>of(subnet))
198 static RendererForwardingContextBuilder createRendererForwardingCtx(ContextId id, Name name,
199 Class<? extends ContextType> type) {
200 return new RendererForwardingContextBuilder().setName(name).setContextId(id).setContextType(type);
203 static Parent createParent(ContextId ctxId, Class<? extends ContextType> type) {
204 return new ParentBuilder().setContextId(ctxId).setContextType(type).build();
207 public static RuleGroups createRuleGroups() {
208 ParameterValue param = new ParameterValueBuilder().setIntValue(EtherTypeClassifierDefinition.IPv4_VALUE)
209 .setName(new ParameterName(EtherTypeClassifierDefinition.ETHERTYPE_PARAM))
211 Classifier classif = new ClassifierBuilder().setClassifierDefinitionId(EtherTypeClassifierDefinition.ID)
212 .setDirection(Direction.In)
213 .setName(new ClassifierName("cl-name"))
214 .setParameterValue(ImmutableList.<ParameterValue>of(param))
216 Action action = new ActionBuilder().setActionDefinitionId(AllowActionDefinition.ID)
217 .setName(new ActionName("Allow"))
219 ResolvedRuleBuilder rrBuilder = new ResolvedRuleBuilder();
220 rrBuilder.setClassifier(ImmutableList.<Classifier>of(classif));
221 rrBuilder.setAction(ImmutableList.<Action>of(action));
222 rrBuilder.setName(RULE_NAME);
223 rrBuilder.setOrder(0);
224 RuleGroup ruleGroup = new RuleGroupBuilder().setTenantId(TENANT_ID)
226 .setSubjectName(SUBJECT_NAME)
227 .setContractId(CONTRACT_ID)
228 .setResolvedRule(ImmutableList.<ResolvedRule>of(rrBuilder.build()))
230 return new RuleGroupsBuilder().setRuleGroup(ImmutableList.<RuleGroup>of(ruleGroup)).build();
233 public static AddressEndpointWithLocation createEndpoint(String ip, String l2FdIdAsNetCont,
234 AbsoluteLocation absoluteLocation) {
235 AddressEndpointWithLocationKey key =
236 new AddressEndpointWithLocationKey(ip, AddressType.class, CTX_ID, L3Context.class);
237 NetworkContainment networkContainment =
238 new NetworkContainmentBuilder().setContainment(new ForwardingContextContainmentBuilder()
239 .setContextType(L2FloodDomain.class).setContextId(new ContextId(l2FdIdAsNetCont)).build()).build();
240 return new AddressEndpointWithLocationBuilder().setKey(key)
241 .setNetworkContainment(networkContainment)
242 .setAbsoluteLocation(absoluteLocation)
246 public static AbsoluteLocation absoluteLocation(InstanceIdentifier<?> mountPoint, String nodeName,
247 String nodeConnectorName) {
248 ExternalLocationCaseBuilder extLocBuilder =
249 new ExternalLocationCaseBuilder().setExternalNodeMountPoint(mountPoint);
250 if (!Strings.isNullOrEmpty(nodeName)) {
251 extLocBuilder.setExternalNode(VppPathMapper.bridgeDomainToRestPath(nodeName));
253 if (!Strings.isNullOrEmpty(nodeConnectorName)) {
254 extLocBuilder.setExternalNodeConnector(VppPathMapper.interfaceToRestPath(nodeConnectorName));
256 return new AbsoluteLocationBuilder().setLocationType(extLocBuilder.build()).build();