1 package org.opendaylight.groupbasedpolicy.renderer.ios_xe_provider.impl.manager;
3 import static org.junit.Assert.assertTrue;
4 import static org.mockito.Matchers.eq;
5 import static org.mockito.Mockito.mock;
6 import static org.mockito.Mockito.when;
7 import static org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.policy.rev140421.HasDirection.Direction.Out;
8 import static org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.EndpointPolicyParticipation.PROVIDER;
9 import static org.powermock.api.support.membermodification.MemberMatcher.method;
10 import static org.powermock.api.support.membermodification.MemberModifier.stub;
12 import com.google.common.util.concurrent.Futures;
13 import com.google.common.util.concurrent.ListenableFuture;
14 import java.util.Collections;
15 import java.util.List;
16 import org.junit.Before;
17 import org.junit.Test;
18 import org.junit.runner.RunWith;
19 import org.opendaylight.controller.md.sal.binding.api.DataBroker;
20 import org.opendaylight.controller.md.sal.binding.api.WriteTransaction;
21 import org.opendaylight.groupbasedpolicy.renderer.ios_xe_provider.impl.util.PolicyManagerUtil;
22 import org.opendaylight.groupbasedpolicy.renderer.ios_xe_provider.impl.util.RendererPolicyUtil;
23 import org.opendaylight.groupbasedpolicy.renderer.ios_xe_provider.impl.util.ServiceChainingUtil;
24 import org.opendaylight.groupbasedpolicy.util.IetfModelCodec;
25 import org.opendaylight.sfc.provider.api.SfcProviderServiceForwarderAPI;
26 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.common.rev151017.RspName;
27 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.common.rev151017.SfName;
28 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.common.rev151017.SffName;
29 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.common.rev151017.SfpName;
30 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.rsp.rev140701.rendered.service.paths.RenderedServicePath;
31 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.rsp.rev140701.rendered.service.paths.RenderedServicePathBuilder;
32 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.rsp.rev140701.rendered.service.paths.RenderedServicePathKey;
33 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.rsp.rev140701.rendered.service.paths.rendered.service.path.RenderedServicePathHopBuilder;
34 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sff.rev140701.service.function.forwarders.ServiceFunctionForwarder;
35 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sff.rev140701.service.function.forwarders.ServiceFunctionForwarderBuilder;
36 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sff.rev140701.service.function.forwarders.ServiceFunctionForwarderKey;
37 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sfp.rev140701.service.function.paths.ServiceFunctionPath;
38 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sfp.rev140701.service.function.paths.ServiceFunctionPathBuilder;
39 import org.opendaylight.yang.gen.v1.urn.cisco.params.xml.ns.yang.sfc.sfp.rev140701.service.function.paths.ServiceFunctionPathKey;
40 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.IpAddress;
41 import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.inet.types.rev100924.Ipv4Address;
42 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.base_endpoint.rev160427.has.absolute.location.AbsoluteLocation;
43 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.base_endpoint.rev160427.has.absolute.location.AbsoluteLocationBuilder;
44 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.base_endpoint.rev160427.has.absolute.location.absolute.location.location.type.ExternalLocationCaseBuilder;
45 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.ActionDefinitionId;
46 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.ContextId;
47 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.ContractId;
48 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.SubjectName;
49 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.common.rev140421.TenantId;
50 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.forwarding.l2_l3.rev160427.IpPrefixType;
51 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.forwarding.l2_l3.rev160427.L2BridgeDomain;
52 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.policy.rev140421.HasDirection;
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.has.rule.group.with.renderer.endpoint.participation.RuleGroupWithRendererEndpointParticipationKey;
57 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.Configuration;
58 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.ConfigurationBuilder;
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.RendererForwarding;
62 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.RuleGroupsBuilder;
63 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.endpoints.AddressEndpointWithLocation;
64 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.endpoints.AddressEndpointWithLocationBuilder;
65 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.endpoints.AddressEndpointWithLocationKey;
66 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.renderer.endpoints.RendererEndpoint;
67 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.renderer.endpoints.RendererEndpointBuilder;
68 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.renderer.endpoints.RendererEndpointKey;
69 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.renderer.endpoints.renderer.endpoint.PeerEndpointBuilder;
70 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.renderer.endpoints.renderer.endpoint.PeerEndpointKey;
71 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.rule.groups.RuleGroup;
72 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.rule.groups.RuleGroupBuilder;
73 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.renderer.rev151103.renderers.renderer.renderer.policy.configuration.rule.groups.RuleGroupKey;
74 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.resolved.policy.rev150828.has.actions.ActionBuilder;
75 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.resolved.policy.rev150828.has.classifiers.ClassifierBuilder;
76 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.resolved.policy.rev150828.has.resolved.rules.ResolvedRule;
77 import org.opendaylight.yang.gen.v1.urn.opendaylight.groupbasedpolicy.resolved.policy.rev150828.has.resolved.rules.ResolvedRuleBuilder;
78 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.config.groupbasedpolicy.sxp.mapper.model.rev160302.AddressEndpointWithLocationAug;
79 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.controller.config.groupbasedpolicy.sxp.mapper.model.rev160302.AddressEndpointWithLocationAugBuilder;
80 import org.opendaylight.yang.gen.v1.urn.opendaylight.sxp.database.rev160308.Sgt;
81 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NetworkTopology;
82 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.NodeId;
83 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.TopologyId;
84 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.Topology;
85 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.TopologyKey;
86 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node;
87 import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeKey;
88 import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
89 import org.powermock.core.classloader.annotations.PrepareForTest;
90 import org.powermock.modules.junit4.PowerMockRunner;
92 @RunWith(PowerMockRunner.class)
93 @PrepareForTest({RendererPolicyUtil.class, PolicyManagerUtil.class, SfcProviderServiceForwarderAPI.class})
94 public class PolicyManagerImplTest {
96 private final String address = "address";
97 private final String connector = "connector";
98 private final SfpName servicePath = new SfpName("service-path");
99 private final RspName renderedPath = new RspName("rendered-path");
100 private final SffName forwarderName = new SffName("service-forwarder");
101 private final ContextId contextId_1 = new ContextId("context-id-1");
102 private final ContextId contextId_2 = new ContextId("context-id-2");
103 private final ContextId contextId_3 = new ContextId("context-id-3");
104 private final ContextId contextId_4 = new ContextId("context-id-4");
105 private final ContractId contractId = new ContractId("contract-id");
106 private final String ipAddress = "192.168.50.1";
107 private final NodeId nodeId = new NodeId("node-id");
108 private final SubjectName subjectName = new SubjectName("subject-name");
109 private final TenantId tenantId = new TenantId("tenant-id");
110 private final TopologyId topologyId = new TopologyId("topology-id");
111 private final ActionDefinitionId chainActionDefinitionId = new ActionDefinitionId("Action-Chain");
112 private final ActionDefinitionId otherActionDefinitionId = new ActionDefinitionId("Action-Other");
113 private final SfName functionName = new SfName("service-function");
114 private PolicyManagerImpl policyManager;
115 private DataBroker mountpoint;
116 private NodeManager nodeManager;
117 private WriteTransaction writeTransaction;
121 mountpoint = mock(DataBroker.class);
122 writeTransaction = mock(WriteTransaction.class);
123 nodeManager = mock(NodeManager.class);
124 policyManager = new PolicyManagerImpl(mountpoint, nodeManager);
125 when(mountpoint.newWriteOnlyTransaction()).thenReturn(writeTransaction);
126 when(writeTransaction.submit()).thenReturn(Futures.immediateCheckedFuture((Void) null));
130 public void testSyncPolicy_emptyConfiguration() throws Exception {
131 Configuration policyConfiguration = createTestConfiguration(null, null, null, null);
132 ListenableFuture result = policyManager.syncPolicy(policyConfiguration, null, 0);
133 assertTrue((boolean) result.get());
137 public void testSyncPolicy_noEndpointsInConfiguration() throws Exception {
138 RendererEndpoint rendererEndpoint = createRendererEndpoint(contextId_1, contextId_2, null);
139 Configuration policyConfiguration = createTestConfiguration(null, Collections.singletonList(rendererEndpoint),
141 ListenableFuture result = policyManager.syncPolicy(policyConfiguration, null, 0);
142 assertTrue((boolean) result.get());
146 public void testSyncPolicy_noMountPoint() throws Exception {
147 AddressEndpointWithLocation endpointWithLocation = createAddressEndpointWithLocation(contextId_1, null, false);
148 RendererEndpoint rendererEndpoint = createRendererEndpoint(contextId_2, contextId_3, null);
149 Configuration policyConfiguration = createTestConfiguration(Collections.singletonList(endpointWithLocation),
150 Collections.singletonList(rendererEndpoint), null, null);
152 AbsoluteLocation location = createAbsoluteLocationExternal(connector, createMountpointIid());
153 AddressEndpointWithLocation lookupEndpoint = createAddressEndpointWithLocation(contextId_4, location, false);
154 stub(method(RendererPolicyUtil.class, "lookupEndpoint")).toReturn(lookupEndpoint);
155 when(nodeManager.getNodeMountPoint(eq(createMountpointIid()))).thenReturn(null);
157 ListenableFuture result = policyManager.syncPolicy(policyConfiguration, null, 0);
158 assertTrue((boolean) result.get());
162 public void testSyncPolicy_nullSgtTags() throws Exception {
163 AddressEndpointWithLocation endpointWithLocation = createAddressEndpointWithLocation(contextId_1, null, false);
164 RendererEndpoint rendererEndpoint = createRendererEndpoint(contextId_2, contextId_3, null);
165 Configuration policyConfiguration = createTestConfiguration(Collections.singletonList(endpointWithLocation),
166 Collections.singletonList(rendererEndpoint), null, null);
168 AbsoluteLocation location = createAbsoluteLocationExternal(connector, createMountpointIid());
169 AddressEndpointWithLocation lookupEndpoint = createAddressEndpointWithLocation(contextId_4, location, false);
170 stub(method(RendererPolicyUtil.class, "lookupEndpoint")).toReturn(lookupEndpoint);
171 when(nodeManager.getNodeMountPoint(eq(createMountpointIid()))).thenReturn(mountpoint);
172 when(nodeManager.getNodeIdByMountpointIid(eq(createMountpointIid()))).thenReturn(nodeId);
173 when(nodeManager.getNodeManagementIpByMountPointIid(eq(createMountpointIid()))).thenReturn(ipAddress);
175 ListenableFuture result = policyManager.syncPolicy(policyConfiguration, null, 0);
176 assertTrue((boolean) result.get());
180 public void testSyncPolicy_emptyRuleGroup() throws Exception {
181 AddressEndpointWithLocation endpointWithLocation = createAddressEndpointWithLocation(contextId_1, null, false);
182 RuleGroupWithRendererEndpointParticipation ruleGroupWithParticipation =
183 createRuleGroupWithRendererEpParticipation(PROVIDER);
184 RendererEndpoint rendererEndpoint = createRendererEndpoint(contextId_2, contextId_3,
185 ruleGroupWithParticipation);
186 RuleGroup ruleGroup = createRuleGroup(null);
187 Configuration policyConfiguration = createTestConfiguration(Collections.singletonList(endpointWithLocation),
188 Collections.singletonList(rendererEndpoint), null, ruleGroup);
190 AbsoluteLocation location = createAbsoluteLocationExternal(connector, createMountpointIid());
191 AddressEndpointWithLocation lookupEndpoint = createAddressEndpointWithLocation(contextId_4, location, true);
192 stub(method(RendererPolicyUtil.class, "lookupEndpoint")).toReturn(lookupEndpoint);
193 when(nodeManager.getNodeMountPoint(eq(createMountpointIid()))).thenReturn(mountpoint);
194 when(nodeManager.getNodeIdByMountpointIid(eq(createMountpointIid()))).thenReturn(nodeId);
195 when(nodeManager.getNodeManagementIpByMountPointIid(eq(createMountpointIid()))).thenReturn(ipAddress);
197 ListenableFuture result = policyManager.syncPolicy(policyConfiguration, null, 0);
198 assertTrue((boolean) result.get());
202 public void testSyncPolicy_noActionDefinition() throws Exception {
203 AddressEndpointWithLocation endpointWithLocation = createAddressEndpointWithLocation(contextId_1, null, false);
204 RuleGroupWithRendererEndpointParticipation ruleGroupWithParticipation =
205 createRuleGroupWithRendererEpParticipation(PROVIDER);
206 RendererEndpoint rendererEndpoint = createRendererEndpoint(contextId_2, contextId_3,
207 ruleGroupWithParticipation);
209 RuleGroup ruleGroup = createRuleGroup(createRule(Out, null));
210 Configuration policyConfiguration = createTestConfiguration(Collections.singletonList(endpointWithLocation),
211 Collections.singletonList(rendererEndpoint), null, ruleGroup);
213 AbsoluteLocation location = createAbsoluteLocationExternal(connector, createMountpointIid());
214 AddressEndpointWithLocation lookupEndpoint = createAddressEndpointWithLocation(contextId_4, location, true);
215 stub(method(RendererPolicyUtil.class, "lookupEndpoint")).toReturn(lookupEndpoint);
216 when(nodeManager.getNodeMountPoint(eq(createMountpointIid()))).thenReturn(mountpoint);
217 when(nodeManager.getNodeIdByMountpointIid(eq(createMountpointIid()))).thenReturn(nodeId);
218 when(nodeManager.getNodeManagementIpByMountPointIid(eq(createMountpointIid()))).thenReturn(ipAddress);
220 ListenableFuture result = policyManager.syncPolicy(policyConfiguration, null, 0);
221 assertTrue((boolean) result.get());
225 public void testSyncPolicy_otherAction() throws Exception {
226 AddressEndpointWithLocation endpointWithLocation = createAddressEndpointWithLocation(contextId_1, null, false);
227 RuleGroupWithRendererEndpointParticipation ruleGroupWithParticipation =
228 createRuleGroupWithRendererEpParticipation(PROVIDER);
229 RendererEndpoint rendererEndpoint = createRendererEndpoint(contextId_2, contextId_3,
230 ruleGroupWithParticipation);
232 RuleGroup ruleGroup = createRuleGroup(createRule(Out, otherActionDefinitionId));
233 Configuration policyConfiguration = createTestConfiguration(Collections.singletonList(endpointWithLocation),
234 Collections.singletonList(rendererEndpoint), null, ruleGroup);
236 AbsoluteLocation location = createAbsoluteLocationExternal(connector, createMountpointIid());
237 AddressEndpointWithLocation lookupEndpoint = createAddressEndpointWithLocation(contextId_4, location, true);
238 stub(method(RendererPolicyUtil.class, "lookupEndpoint")).toReturn(lookupEndpoint);
239 when(nodeManager.getNodeMountPoint(eq(createMountpointIid()))).thenReturn(mountpoint);
240 when(nodeManager.getNodeIdByMountpointIid(eq(createMountpointIid()))).thenReturn(nodeId);
241 when(nodeManager.getNodeManagementIpByMountPointIid(eq(createMountpointIid()))).thenReturn(ipAddress);
243 ListenableFuture result = policyManager.syncPolicy(policyConfiguration, null, 0);
244 assertTrue((boolean) result.get());
248 public void testSyncPolicy_asymmetricChain() throws Exception {
249 AddressEndpointWithLocation endpointWithLocation = createAddressEndpointWithLocation(contextId_1, null, false);
250 RuleGroupWithRendererEndpointParticipation ruleGroupWithParticipation =
251 createRuleGroupWithRendererEpParticipation(PROVIDER);
252 RendererEndpoint rendererEndpoint = createRendererEndpoint(contextId_2, contextId_3,
253 ruleGroupWithParticipation);
255 RuleGroup ruleGroup = createRuleGroup(createRule(Out, chainActionDefinitionId));
256 Configuration policyConfiguration = createTestConfiguration(Collections.singletonList(endpointWithLocation),
257 Collections.singletonList(rendererEndpoint), null, ruleGroup);
259 AbsoluteLocation location = createAbsoluteLocationExternal(connector, createMountpointIid());
260 AddressEndpointWithLocation lookupEndpoint = createAddressEndpointWithLocation(contextId_4, location, true);
261 stub(method(RendererPolicyUtil.class, "lookupEndpoint")).toReturn(lookupEndpoint);
262 when(nodeManager.getNodeMountPoint(eq(createMountpointIid()))).thenReturn(mountpoint);
263 when(nodeManager.getNodeIdByMountpointIid(eq(createMountpointIid()))).thenReturn(nodeId);
264 when(nodeManager.getNodeManagementIpByMountPointIid(eq(createMountpointIid()))).thenReturn(ipAddress);
265 ServiceFunctionPath sfp = createServiceFunctionPath();
266 stub(method(ServiceChainingUtil.class, "getServicePath")).toReturn(sfp);
267 RenderedServicePath rsp = createRenderedServicePath();
268 stub(method(ServiceChainingUtil.class, "createRenderedPath")).toReturn(rsp);
269 ServiceFunctionForwarder serviceFunctionForwarder = createServiceForwarder();
270 stub(method(SfcProviderServiceForwarderAPI.class, "readServiceFunctionForwarder"))
271 .toReturn(serviceFunctionForwarder);
273 ListenableFuture result = policyManager.syncPolicy(policyConfiguration, null, 0);
274 assertTrue((boolean) result.get());
277 private ServiceFunctionForwarder createServiceForwarder() {
278 ServiceFunctionForwarderBuilder serviceFunctionForwarderBuilder = new ServiceFunctionForwarderBuilder();
279 serviceFunctionForwarderBuilder.setName(new SffName(forwarderName))
280 .setKey(new ServiceFunctionForwarderKey(new SffName(forwarderName)))
281 .setIpMgmtAddress(IetfModelCodec.ipAddress2013(new IpAddress(new Ipv4Address(ipAddress))));
282 return serviceFunctionForwarderBuilder.build();
287 private InstanceIdentifier createMountpointIid() {
288 return InstanceIdentifier.builder(NetworkTopology.class)
289 .child(Topology.class, new TopologyKey(topologyId))
290 .child(Node.class, new NodeKey(nodeId)).build();
293 private ResolvedRule createRule(HasDirection.Direction direction, ActionDefinitionId actionDefinitionId) {
294 ResolvedRuleBuilder resolvedRuleBuilder = new ResolvedRuleBuilder();
295 ClassifierBuilder classifierBuilder = new ClassifierBuilder();
296 classifierBuilder.setDirection(direction);
297 ActionBuilder actionBuilder = new ActionBuilder();
298 actionBuilder.setActionDefinitionId(actionDefinitionId);
299 resolvedRuleBuilder.setClassifier(Collections.singletonList(classifierBuilder.build()))
300 .setAction(Collections.singletonList(actionBuilder.build()));
301 return resolvedRuleBuilder.build();
304 private RuleGroupWithRendererEndpointParticipation createRuleGroupWithRendererEpParticipation(final EndpointPolicyParticipation participation) {
305 RuleGroupWithRendererEndpointParticipationBuilder ruleGroupBuilder = new RuleGroupWithRendererEndpointParticipationBuilder();
306 ruleGroupBuilder.setKey(new RuleGroupWithRendererEndpointParticipationKey(contractId, participation, subjectName,
308 return ruleGroupBuilder.build();
311 private AbsoluteLocation createAbsoluteLocationExternal(String connector, InstanceIdentifier mountpoint) {
312 ExternalLocationCaseBuilder externalLocationCaseBuilder = new ExternalLocationCaseBuilder();
313 externalLocationCaseBuilder.setExternalNodeConnector(connector)
314 .setExternalNodeMountPoint(mountpoint);
315 AbsoluteLocationBuilder absoluteLocationBuilder = new AbsoluteLocationBuilder();
316 absoluteLocationBuilder.setLocationType(externalLocationCaseBuilder.build());
317 return absoluteLocationBuilder.build();
320 private ServiceFunctionPath createServiceFunctionPath() {
321 ServiceFunctionPathBuilder serviceFunctionPathBuilder = new ServiceFunctionPathBuilder();
322 serviceFunctionPathBuilder.setKey(new ServiceFunctionPathKey(servicePath))
323 .setSymmetric(false);
324 return serviceFunctionPathBuilder.build();
327 private RenderedServicePath createRenderedServicePath() {
328 RenderedServicePathHopBuilder renderedServicePathHopBuilder = new RenderedServicePathHopBuilder();
329 renderedServicePathHopBuilder.setServiceFunctionForwarder(forwarderName);
330 renderedServicePathHopBuilder.setServiceFunctionName(functionName);
331 renderedServicePathHopBuilder.build();
333 RenderedServicePathBuilder renderedServicePathBuilder = new RenderedServicePathBuilder();
334 renderedServicePathBuilder.setKey(new RenderedServicePathKey(renderedPath))
335 .setRenderedServicePathHop(Collections.singletonList(renderedServicePathHopBuilder.build()));
336 return renderedServicePathBuilder.build();
340 private AddressEndpointWithLocation createAddressEndpointWithLocation(final ContextId contextId,
341 final AbsoluteLocation location,
342 boolean augmentation) {
343 AddressEndpointWithLocationAugBuilder augmentationBuilder = new AddressEndpointWithLocationAugBuilder();
344 augmentationBuilder.setSgt(new Sgt(1));
345 AddressEndpointWithLocationBuilder addressEndpointBuilder = new AddressEndpointWithLocationBuilder();
346 addressEndpointBuilder.setKey(new AddressEndpointWithLocationKey(address, IpPrefixType.class,
347 contextId, L2BridgeDomain.class))
348 .setAbsoluteLocation(location);
350 addressEndpointBuilder.addAugmentation(AddressEndpointWithLocationAug.class, augmentationBuilder.build());
352 return addressEndpointBuilder.build();
355 private RendererEndpoint createRendererEndpoint(ContextId contextId_1, ContextId contextId_2,
356 RuleGroupWithRendererEndpointParticipation ruleGroup) {
357 PeerEndpointBuilder PeerEndpointBuilder = new PeerEndpointBuilder();
358 PeerEndpointBuilder.setKey(new PeerEndpointKey(address, IpPrefixType.class, contextId_1,
359 L2BridgeDomain.class))
360 .setRuleGroupWithRendererEndpointParticipation(Collections.singletonList(ruleGroup));
361 RendererEndpointBuilder rendererEndpointBuilder = new RendererEndpointBuilder();
362 rendererEndpointBuilder.setKey(new RendererEndpointKey(address, IpPrefixType.class, contextId_2,
363 L2BridgeDomain.class))
364 .setPeerEndpoint(Collections.singletonList(PeerEndpointBuilder.build()));
365 return rendererEndpointBuilder.build();
368 private RuleGroup createRuleGroup(ResolvedRule rule) {
369 RuleGroupBuilder ruleGroupBuilder = new RuleGroupBuilder();
370 ruleGroupBuilder.setKey(new RuleGroupKey(contractId, subjectName, tenantId))
371 .setResolvedRule(Collections.singletonList(rule));
372 return ruleGroupBuilder.build();
375 private Configuration createTestConfiguration(final List<AddressEndpointWithLocation> endpointsWithLocation,
376 final List<RendererEndpoint> rendererEndpoints,
377 final RendererForwarding rendererForwarding,
378 final RuleGroup ruleGroup) {
380 EndpointsBuilder endpointsBuilder = new EndpointsBuilder();
381 endpointsBuilder.setAddressEndpointWithLocation(endpointsWithLocation);
382 // Set renderer endpoints
383 RendererEndpointsBuilder rendererEndpointsBuilder = new RendererEndpointsBuilder();
384 rendererEndpointsBuilder.setRendererEndpoint(rendererEndpoints);
386 RuleGroupsBuilder ruleGroupsBuilder = new RuleGroupsBuilder();
387 ruleGroupsBuilder.setRuleGroup(Collections.singletonList(ruleGroup));
388 // Build configuration
389 ConfigurationBuilder configurationBuilder = new ConfigurationBuilder();
390 configurationBuilder.setEndpoints(endpointsBuilder.build())
391 .setRendererEndpoints(rendererEndpointsBuilder.build())
392 .setRendererForwarding(rendererForwarding)
393 .setRuleGroups(ruleGroupsBuilder.build());
394 return configurationBuilder.build();