2 * ============LICENSE_START=======================================================
3 * SdncActorServiceProvider
4 * ================================================================================
5 * Copyright (C) 2018-2019 Huawei Technologies Co., Ltd. All rights reserved.
6 * ================================================================================
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
11 * http://www.apache.org/licenses/LICENSE-2.0
13 * Unless required by applicable law or agreed to in writing, software
14 * distributed under the License is distributed on an "AS IS" BASIS,
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 * See the License for the specific language governing permissions and
17 * limitations under the License.
18 * ============LICENSE_END=========================================================
21 package org.onap.policy.controlloop.actor.sdnc;
23 import com.google.common.collect.ImmutableList;
24 import com.google.common.collect.ImmutableMap;
26 import java.util.Collections;
27 import java.util.List;
28 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.spi.Actor;
33 import org.onap.policy.controlloop.policy.Policy;
34 import org.onap.policy.sdnc.SdncHealNetworkInfo;
35 import org.onap.policy.sdnc.SdncHealRequest;
36 import org.onap.policy.sdnc.SdncHealRequestHeaderInfo;
37 import org.onap.policy.sdnc.SdncHealRequestInfo;
38 import org.onap.policy.sdnc.SdncHealServiceInfo;
39 import org.onap.policy.sdnc.SdncHealVfModuleParameter;
40 import org.onap.policy.sdnc.SdncHealVfModuleParametersInfo;
41 import org.onap.policy.sdnc.SdncHealVfModuleRequestInput;
42 import org.onap.policy.sdnc.SdncHealVnfInfo;
44 import org.onap.policy.sdnc.SdncRequest;
46 import org.slf4j.Logger;
47 import org.slf4j.LoggerFactory;
50 public class SdncActorServiceProvider implements Actor {
51 private static final Logger logger = LoggerFactory.getLogger(SdncActorServiceProvider.class);
53 // Strings for Sdnc Actor
54 private static final String SDNC_ACTOR = "SDNC";
56 // Strings for targets
57 private static final String TARGET_VM = "VM";
59 // Strings for recipes
60 private static final String RECIPE_REROUTE = "Reroute";
62 // Strings for recipes
63 private static final String RECIPE_BW_ON_DEMAND = "BandwidthOnDemand";
65 private static final ImmutableList<String> recipes = ImmutableList.of(RECIPE_REROUTE);
66 private static final ImmutableMap<String, List<String>> targets =
67 new ImmutableMap.Builder<String, List<String>>().put(RECIPE_REROUTE, ImmutableList.of(TARGET_VM)).build();
70 public String actor() {
75 public List<String> recipes() {
76 return ImmutableList.copyOf(recipes);
80 public List<String> recipeTargets(String recipe) {
81 return ImmutableList.copyOf(targets.getOrDefault(recipe, Collections.emptyList()));
85 public List<String> recipePayloads(String recipe) {
86 return Collections.emptyList();
90 * Construct a request.
92 * @param onset the onset event
93 * @param operation the control loop operation
94 * @param policy the policy
95 * @return the constructed request
97 public SdncRequest constructRequest(VirtualControlLoopEvent onset, ControlLoopOperation operation,
99 switch (policy.getRecipe()) {
101 return constructReOptimizeRequest(onset);
102 case RECIPE_BW_ON_DEMAND:
103 logger.info("Construct request for receipe {}" , RECIPE_BW_ON_DEMAND);
104 return constructBwOnDemandRequest(onset);
106 logger.info("Unsupported recipe {} " + policy.getRecipe());
111 private SdncRequest constructBwOnDemandRequest(VirtualControlLoopEvent onset) {
112 // Construct an Sdnc request
113 String serviceInstance = onset.getAai().get("service-instance.service-instance-id");
114 if (serviceInstance == null || serviceInstance.isEmpty()) {
115 // This indicates that AAI Enrichment needs to be done by event producer.
118 SdncHealVfModuleParameter bandwidth = new SdncHealVfModuleParameter();
119 bandwidth.setName("bandwidth");
120 bandwidth.setValue(onset.getAai().get("bandwidth"));
122 SdncHealVfModuleParameter timeStamp = new SdncHealVfModuleParameter();
123 timeStamp.setName("bandwidth-change-time");
124 timeStamp.setValue(onset.getAai().get("bandwidth-change-time"));
126 SdncHealVfModuleParametersInfo vfParametersInfo = new SdncHealVfModuleParametersInfo();
127 vfParametersInfo.addParameters(bandwidth);
128 vfParametersInfo.addParameters(timeStamp);
130 SdncHealVfModuleRequestInput vfRequestInfo = new SdncHealVfModuleRequestInput();
131 vfRequestInfo.setVfModuleParametersInfo(vfParametersInfo);
133 SdncHealServiceInfo serviceInfo = new SdncHealServiceInfo();
134 serviceInfo.setServiceInstanceId(serviceInstance);
136 SdncHealRequestInfo requestInfo = new SdncHealRequestInfo();
137 requestInfo.setRequestAction("SdwanBandwidthChange");
139 SdncHealRequestHeaderInfo headerInfo = new SdncHealRequestHeaderInfo();
140 headerInfo.setSvcAction("update");
141 headerInfo.setSvcRequestId(UUID.randomUUID().toString());
143 SdncRequest request = new SdncRequest();
144 request.setNsInstanceId(serviceInstance);
145 request.setRequestId(onset.getRequestId());
146 request.setUrl("/GENERIC-RESOURCE-API:vnf-topology-operation");
148 SdncHealVnfInfo vnfInfo = new SdncHealVnfInfo();
149 vnfInfo.setVnfId(onset.getAai().get("vnfId"));
151 SdncHealRequest healRequest = new SdncHealRequest();
152 healRequest.setVnfInfo(vnfInfo);
153 healRequest.setRequestHeaderInfo(headerInfo);
154 healRequest.setVfModuleRequestInput(vfRequestInfo);
155 healRequest.setRequestInfo(requestInfo);
156 healRequest.setServiceInfo(serviceInfo);
157 request.setHealRequest(healRequest);
161 private SdncRequest constructReOptimizeRequest(VirtualControlLoopEvent onset) {
162 // Construct an Sdnc request
163 String serviceInstance = onset.getAai().get("service-instance.service-instance-id");
164 if (serviceInstance == null || serviceInstance.isEmpty()) {
165 // This indicates that AAI Enrichment needs to be done by event producer.
168 SdncHealServiceInfo serviceInfo = new SdncHealServiceInfo();
169 serviceInfo.setServiceInstanceId(serviceInstance);
171 String networkId = onset.getAai().get("network-information.network-id");
172 if (networkId == null || networkId.isEmpty()) {
173 // This indicates that AAI Enrichment needs to be done by event producer.
176 SdncHealNetworkInfo networkInfo = new SdncHealNetworkInfo();
177 networkInfo.setNetworkId(networkId);
179 SdncHealRequestInfo requestInfo = new SdncHealRequestInfo();
180 requestInfo.setRequestAction("ReoptimizeSOTNInstance");
182 SdncHealRequestHeaderInfo headerInfo = new SdncHealRequestHeaderInfo();
183 headerInfo.setSvcAction("reoptimize");
184 headerInfo.setSvcRequestId(UUID.randomUUID().toString());
186 SdncRequest request = new SdncRequest();
187 request.setNsInstanceId(serviceInstance);
188 request.setRequestId(onset.getRequestId());
189 request.setUrl("/GENERIC-RESOURCE-API:network-topology-operation");
191 SdncHealRequest healRequest = new SdncHealRequest();
192 healRequest.setRequestHeaderInfo(headerInfo);
193 healRequest.setNetworkInfo(networkInfo);
194 healRequest.setRequestInfo(requestInfo);
195 healRequest.setServiceInfo(serviceInfo);
196 request.setHealRequest(healRequest);