2 * ============LICENSE_START=======================================================
3 * SdncActorServiceProvider
4 * ================================================================================
5 * Copyright (C) 2018-2019 Huawei Intellectual Property. All rights reserved.
6 * Modifications Copyright (C) 2019 Nordix Foundation.
7 * Modifications Copyright (C) 2019 AT&T Intellectual Property.
8 * ================================================================================
9 * Licensed under the Apache License, Version 2.0 (the "License");
10 * you may not use this file except in compliance with the License.
11 * You may obtain a copy of the License at
13 * http://www.apache.org/licenses/LICENSE-2.0
15 * Unless required by applicable law or agreed to in writing, software
16 * distributed under the License is distributed on an "AS IS" BASIS,
17 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
18 * See the License for the specific language governing permissions and
19 * limitations under the License.
20 * ============LICENSE_END=========================================================
23 package org.onap.policy.controlloop.actor.sdnc;
25 import com.google.common.collect.ImmutableList;
26 import com.google.common.collect.ImmutableMap;
28 import java.util.Collections;
29 import java.util.List;
30 import java.util.UUID;
32 import org.onap.policy.aai.AaiGetVnfResponse;
33 import org.onap.policy.controlloop.ControlLoopOperation;
34 import org.onap.policy.controlloop.VirtualControlLoopEvent;
35 import org.onap.policy.controlloop.actorserviceprovider.spi.Actor;
36 import org.onap.policy.controlloop.policy.Policy;
37 import org.onap.policy.sdnc.SdncHealNetworkInfo;
38 import org.onap.policy.sdnc.SdncHealRequest;
39 import org.onap.policy.sdnc.SdncHealRequestHeaderInfo;
40 import org.onap.policy.sdnc.SdncHealRequestInfo;
41 import org.onap.policy.sdnc.SdncHealServiceInfo;
42 import org.onap.policy.sdnc.SdncHealVfModuleParameter;
43 import org.onap.policy.sdnc.SdncHealVfModuleParametersInfo;
44 import org.onap.policy.sdnc.SdncHealVfModuleRequestInput;
45 import org.onap.policy.sdnc.SdncHealVnfInfo;
47 import org.onap.policy.sdnc.SdncRequest;
49 import org.slf4j.Logger;
50 import org.slf4j.LoggerFactory;
53 public class SdncActorServiceProvider implements Actor {
54 private static final Logger logger = LoggerFactory.getLogger(SdncActorServiceProvider.class);
56 // Strings for Sdnc Actor
57 private static final String SDNC_ACTOR = "SDNC";
59 // Strings for targets
60 private static final String TARGET_VM = "VM";
62 // Strings for recipes
63 private static final String RECIPE_REROUTE = "Reroute";
65 // Strings for recipes
66 private static final String RECIPE_BW_ON_DEMAND = "BandwidthOnDemand";
68 private static final ImmutableList<String> recipes = ImmutableList.of(RECIPE_REROUTE);
69 private static final ImmutableMap<String, List<String>> targets =
70 new ImmutableMap.Builder<String, List<String>>().put(RECIPE_REROUTE, ImmutableList.of(TARGET_VM)).build();
73 public String actor() {
78 public List<String> recipes() {
79 return ImmutableList.copyOf(recipes);
83 public List<String> recipeTargets(String recipe) {
84 return ImmutableList.copyOf(targets.getOrDefault(recipe, Collections.emptyList()));
88 public List<String> recipePayloads(String recipe) {
89 return Collections.emptyList();
93 * Construct a request.
95 * @param onset the onset event
96 * @param operation the control loop operation
97 * @param policy the policy
98 * @return the constructed request
100 public SdncRequest constructRequest(VirtualControlLoopEvent onset, ControlLoopOperation operation,
102 switch (policy.getRecipe()) {
104 return constructReOptimizeRequest(onset);
105 case RECIPE_BW_ON_DEMAND:
106 logger.info("Construct request for receipe {}" , RECIPE_BW_ON_DEMAND);
107 return constructBwOnDemandRequest(onset);
109 logger.info("Unsupported recipe {} " + policy.getRecipe());
114 private SdncRequest constructBwOnDemandRequest(VirtualControlLoopEvent onset) {
115 // Construct an Sdnc request
116 String serviceInstance = onset.getAai().get("service-instance.service-instance-id");
117 if (serviceInstance == null || serviceInstance.isEmpty()) {
118 // This indicates that AAI Enrichment needs to be done by event producer.
121 SdncHealVfModuleParameter bandwidth = new SdncHealVfModuleParameter();
122 bandwidth.setName("bandwidth");
123 bandwidth.setValue(onset.getAai().get("bandwidth"));
125 SdncHealVfModuleParameter timeStamp = new SdncHealVfModuleParameter();
126 timeStamp.setName("bandwidth-change-time");
127 timeStamp.setValue(onset.getAai().get("bandwidth-change-time"));
129 SdncHealVfModuleParametersInfo vfParametersInfo = new SdncHealVfModuleParametersInfo();
130 vfParametersInfo.addParameters(bandwidth);
131 vfParametersInfo.addParameters(timeStamp);
133 SdncHealVfModuleRequestInput vfRequestInfo = new SdncHealVfModuleRequestInput();
134 vfRequestInfo.setVfModuleParametersInfo(vfParametersInfo);
136 SdncHealServiceInfo serviceInfo = new SdncHealServiceInfo();
137 serviceInfo.setServiceInstanceId(serviceInstance);
139 SdncHealRequestInfo requestInfo = new SdncHealRequestInfo();
140 requestInfo.setRequestAction("SdwanBWPolicyChange");
142 SdncHealRequestHeaderInfo headerInfo = new SdncHealRequestHeaderInfo();
143 headerInfo.setSvcAction("update");
144 headerInfo.setSvcRequestId(UUID.randomUUID().toString());
146 SdncRequest request = new SdncRequest();
147 request.setNsInstanceId(serviceInstance);
148 request.setRequestId(onset.getRequestId());
149 request.setUrl("/GENERIC-RESOURCE-API:vnf-topology-operation");
151 SdncHealVnfInfo vnfInfo = new SdncHealVnfInfo();
152 vnfInfo.setVnfId(onset.getAai().get("vnfId"));
154 SdncHealRequest healRequest = new SdncHealRequest();
155 healRequest.setVnfInfo(vnfInfo);
156 healRequest.setRequestHeaderInfo(headerInfo);
157 healRequest.setVfModuleRequestInput(vfRequestInfo);
158 healRequest.setRequestInfo(requestInfo);
159 healRequest.setServiceInfo(serviceInfo);
160 request.setHealRequest(healRequest);
164 private SdncRequest constructReOptimizeRequest(VirtualControlLoopEvent onset) {
165 // Construct an Sdnc request
166 String serviceInstance = onset.getAai().get("service-instance.service-instance-id");
167 if (serviceInstance == null || serviceInstance.isEmpty()) {
168 // This indicates that AAI Enrichment needs to be done by event producer.
171 SdncHealServiceInfo serviceInfo = new SdncHealServiceInfo();
172 serviceInfo.setServiceInstanceId(serviceInstance);
174 String networkId = onset.getAai().get("network-information.network-id");
175 if (networkId == null || networkId.isEmpty()) {
176 // This indicates that AAI Enrichment needs to be done by event producer.
179 SdncHealNetworkInfo networkInfo = new SdncHealNetworkInfo();
180 networkInfo.setNetworkId(networkId);
182 SdncHealRequestInfo requestInfo = new SdncHealRequestInfo();
183 requestInfo.setRequestAction("ReoptimizeSOTNInstance");
185 SdncHealRequestHeaderInfo headerInfo = new SdncHealRequestHeaderInfo();
186 headerInfo.setSvcAction("reoptimize");
187 headerInfo.setSvcRequestId(UUID.randomUUID().toString());
189 SdncRequest request = new SdncRequest();
190 request.setNsInstanceId(serviceInstance);
191 request.setRequestId(onset.getRequestId());
192 request.setUrl("/GENERIC-RESOURCE-API:network-topology-operation");
194 SdncHealRequest healRequest = new SdncHealRequest();
195 healRequest.setRequestHeaderInfo(headerInfo);
196 healRequest.setNetworkInfo(networkInfo);
197 healRequest.setRequestInfo(requestInfo);
198 healRequest.setServiceInfo(serviceInfo);
199 request.setHealRequest(healRequest);