2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2018-2019 Huawei Intellectual Property. All rights reserved.
6 * Modifications Copyright (C) 2019 Nordix Foundation.
7 * Modifications Copyright (C) 2019-2020 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;
27 import java.util.Collections;
28 import java.util.List;
29 import java.util.UUID;
30 import org.onap.policy.controlloop.ControlLoopOperation;
31 import org.onap.policy.controlloop.VirtualControlLoopEvent;
32 import org.onap.policy.controlloop.actorserviceprovider.impl.HttpActor;
33 import org.onap.policy.controlloop.actorserviceprovider.impl.HttpOperator;
34 import org.onap.policy.controlloop.actorserviceprovider.parameters.HttpActorParams;
35 import org.onap.policy.controlloop.policy.Policy;
36 import org.onap.policy.sdnc.SdncHealNetworkInfo;
37 import org.onap.policy.sdnc.SdncHealRequest;
38 import org.onap.policy.sdnc.SdncHealRequestHeaderInfo;
39 import org.onap.policy.sdnc.SdncHealRequestInfo;
40 import org.onap.policy.sdnc.SdncHealServiceInfo;
41 import org.onap.policy.sdnc.SdncHealVfModuleInfo;
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;
46 import org.onap.policy.sdnc.SdncRequest;
47 import org.slf4j.Logger;
48 import org.slf4j.LoggerFactory;
50 public class SdncActor extends HttpActor<HttpActorParams> {
51 private static final Logger logger = LoggerFactory.getLogger(SdncActor.class);
53 public static final String NAME = "SDNC";
55 // TODO old code: remove lines down to **HERE**
57 // Strings for Sdnc Actor
58 private static final String SDNC_ACTOR = "SDNC";
60 // Strings for targets
61 private static final String TARGET_VM = "VM";
63 // Strings for recipes
64 private static final String RECIPE_REROUTE = "Reroute";
66 // Strings for recipes
67 private static final String RECIPE_BW_ON_DEMAND = "BandwidthOnDemand";
69 private static final ImmutableList<String> recipes = ImmutableList.of(RECIPE_REROUTE);
70 private static final ImmutableMap<String, List<String>> targets = new ImmutableMap.Builder<String, List<String>>()
71 .put(RECIPE_REROUTE, ImmutableList.of(TARGET_VM)).build();
76 * Constructs the object.
79 super(NAME, HttpActorParams.class);
81 addOperator(new HttpOperator(NAME, RerouteOperation.NAME, RerouteOperation::new));
82 addOperator(new HttpOperator(NAME, BandwidthOnDemandOperation.NAME, BandwidthOnDemandOperation::new));
86 // TODO old code: remove lines down to **HERE**
89 public String actor() {
94 public List<String> recipes() {
95 return ImmutableList.copyOf(recipes);
99 public List<String> recipeTargets(String recipe) {
100 return ImmutableList.copyOf(targets.getOrDefault(recipe, Collections.emptyList()));
104 public List<String> recipePayloads(String recipe) {
105 return Collections.emptyList();
109 * Construct a request.
111 * @param onset the onset event
112 * @param operation the control loop operation
113 * @param policy the policy
114 * @return the constructed request
116 public SdncRequest constructRequest(VirtualControlLoopEvent onset, ControlLoopOperation operation, Policy policy) {
117 switch (policy.getRecipe()) {
119 return constructReOptimizeRequest(onset);
120 case RECIPE_BW_ON_DEMAND:
121 logger.info("Construct request for receipe {}", RECIPE_BW_ON_DEMAND);
122 return constructBwOnDemandRequest(onset);
124 logger.info("Unsupported recipe {}", policy.getRecipe());
129 private SdncRequest constructBwOnDemandRequest(VirtualControlLoopEvent onset) {
130 // Construct an Sdnc request
131 String serviceInstance = onset.getAai().get("service-instance.service-instance-id");
132 if (serviceInstance == null || serviceInstance.isEmpty()) {
133 // This indicates that AAI Enrichment needs to be done by event producer.
136 SdncHealVfModuleParameter bandwidth = new SdncHealVfModuleParameter();
137 bandwidth.setName("bandwidth");
138 bandwidth.setValue(onset.getAai().get("bandwidth"));
140 SdncHealVfModuleParameter timeStamp = new SdncHealVfModuleParameter();
141 timeStamp.setName("bandwidth-change-time");
142 timeStamp.setValue(onset.getAai().get("bandwidth-change-time"));
144 SdncHealVfModuleParametersInfo vfParametersInfo = new SdncHealVfModuleParametersInfo();
145 vfParametersInfo.addParameters(bandwidth);
146 vfParametersInfo.addParameters(timeStamp);
148 SdncHealVfModuleRequestInput vfRequestInfo = new SdncHealVfModuleRequestInput();
149 vfRequestInfo.setVfModuleParametersInfo(vfParametersInfo);
151 SdncHealServiceInfo serviceInfo = new SdncHealServiceInfo();
152 serviceInfo.setServiceInstanceId(serviceInstance);
154 SdncHealRequestInfo requestInfo = new SdncHealRequestInfo();
155 requestInfo.setRequestAction("SdwanBandwidthChange");
157 SdncHealRequestHeaderInfo headerInfo = new SdncHealRequestHeaderInfo();
158 headerInfo.setSvcAction("update");
159 headerInfo.setSvcRequestId(UUID.randomUUID().toString());
161 SdncRequest request = new SdncRequest();
162 request.setNsInstanceId(serviceInstance);
163 request.setRequestId(onset.getRequestId());
164 request.setUrl("/GENERIC-RESOURCE-API:vf-module-topology-operation");
166 SdncHealVnfInfo vnfInfo = new SdncHealVnfInfo();
167 vnfInfo.setVnfId(onset.getAai().get("vnfId"));
169 SdncHealVfModuleInfo vfModuleInfo = new SdncHealVfModuleInfo();
170 vfModuleInfo.setVfModuleId("");
172 SdncHealRequest healRequest = new SdncHealRequest();
173 healRequest.setVnfInfo(vnfInfo);
174 healRequest.setVfModuleInfo(vfModuleInfo);
175 healRequest.setRequestHeaderInfo(headerInfo);
176 healRequest.setVfModuleRequestInput(vfRequestInfo);
177 healRequest.setRequestInfo(requestInfo);
178 healRequest.setServiceInfo(serviceInfo);
179 request.setHealRequest(healRequest);
183 private SdncRequest constructReOptimizeRequest(VirtualControlLoopEvent onset) {
184 // Construct an Sdnc request
185 String serviceInstance = onset.getAai().get("service-instance.service-instance-id");
186 if (serviceInstance == null || serviceInstance.isEmpty()) {
187 // This indicates that AAI Enrichment needs to be done by event producer.
190 SdncHealServiceInfo serviceInfo = new SdncHealServiceInfo();
191 serviceInfo.setServiceInstanceId(serviceInstance);
193 String networkId = onset.getAai().get("network-information.network-id");
194 if (networkId == null || networkId.isEmpty()) {
195 // This indicates that AAI Enrichment needs to be done by event producer.
198 SdncHealNetworkInfo networkInfo = new SdncHealNetworkInfo();
199 networkInfo.setNetworkId(networkId);
201 SdncHealRequestInfo requestInfo = new SdncHealRequestInfo();
202 requestInfo.setRequestAction("ReoptimizeSOTNInstance");
204 SdncHealRequestHeaderInfo headerInfo = new SdncHealRequestHeaderInfo();
205 headerInfo.setSvcAction("reoptimize");
206 headerInfo.setSvcRequestId(UUID.randomUUID().toString());
208 SdncRequest request = new SdncRequest();
209 request.setNsInstanceId(serviceInstance);
210 request.setRequestId(onset.getRequestId());
211 request.setUrl("/GENERIC-RESOURCE-API:network-topology-operation");
213 SdncHealRequest healRequest = new SdncHealRequest();
214 healRequest.setRequestHeaderInfo(headerInfo);
215 healRequest.setNetworkInfo(networkInfo);
216 healRequest.setRequestInfo(requestInfo);
217 healRequest.setServiceInfo(serviceInfo);
218 request.setHealRequest(healRequest);