models-interactions/model-actors/actor.sdnc/src/main/java/org/onap/policy/controlloop/actor/sdnc/SdncActorServiceProvider.java

   1 /*-
   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-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
  12  *
  13  *      http://www.apache.org/licenses/LICENSE-2.0
  14  *
  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=========================================================
  21  */
  22
  23 package org.onap.policy.controlloop.actor.sdnc;
  24
  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.Map;
  30 import java.util.UUID;
  31 import java.util.function.Function;
  32 import org.onap.policy.controlloop.ControlLoopOperation;
  33 import org.onap.policy.controlloop.VirtualControlLoopEvent;
  34 import org.onap.policy.controlloop.actorserviceprovider.Util;
  35 import org.onap.policy.controlloop.actorserviceprovider.impl.ActorImpl;
  36 import org.onap.policy.controlloop.actorserviceprovider.parameters.HttpActorParams;
  37 import org.onap.policy.controlloop.policy.Policy;
  38 import org.onap.policy.sdnc.SdncHealNetworkInfo;
  39 import org.onap.policy.sdnc.SdncHealRequest;
  40 import org.onap.policy.sdnc.SdncHealRequestHeaderInfo;
  41 import org.onap.policy.sdnc.SdncHealRequestInfo;
  42 import org.onap.policy.sdnc.SdncHealServiceInfo;
  43 import org.onap.policy.sdnc.SdncHealVfModuleInfo;
  44 import org.onap.policy.sdnc.SdncHealVfModuleParameter;
  45 import org.onap.policy.sdnc.SdncHealVfModuleParametersInfo;
  46 import org.onap.policy.sdnc.SdncHealVfModuleRequestInput;
  47 import org.onap.policy.sdnc.SdncHealVnfInfo;
  48 import org.onap.policy.sdnc.SdncRequest;
  49 import org.slf4j.Logger;
  50 import org.slf4j.LoggerFactory;
  51
  52 public class SdncActorServiceProvider extends ActorImpl {
  53     private static final Logger logger = LoggerFactory.getLogger(SdncActorServiceProvider.class);
  54
  55     public static final String NAME = "SDNC";
  56
  57     // TODO old code: remove lines down to **HERE**
  58
  59     // Strings for Sdnc Actor
  60     private static final String SDNC_ACTOR = "SDNC";
  61
  62     // Strings for targets
  63     private static final String TARGET_VM = "VM";
  64
  65     // Strings for recipes
  66     private static final String RECIPE_REROUTE = "Reroute";
  67
  68     // Strings for recipes
  69     private static final String RECIPE_BW_ON_DEMAND = "BandwidthOnDemand";
  70
  71     private static final ImmutableList<String> recipes = ImmutableList.of(RECIPE_REROUTE);
  72     private static final ImmutableMap<String, List<String>> targets = new ImmutableMap.Builder<String, List<String>>()
  73                     .put(RECIPE_REROUTE, ImmutableList.of(TARGET_VM)).build();
  74
  75     // **HERE**
  76
  77     /**
  78      * Constructs the object.
  79      */
  80     public SdncActorServiceProvider() {
  81         // @formatter:off
  82         super(NAME,
  83             new RerouteOperator(NAME),
  84             new BandwidthOnDemandOperator(NAME));
  85
  86         // @formatter:on
  87     }
  88
  89     @Override
  90     protected Function<String, Map<String, Object>> makeOperatorParameters(Map<String, Object> actorParameters) {
  91         String actorName = getName();
  92
  93         // @formatter:off
  94         return Util.translate(actorName, actorParameters, HttpActorParams.class)
  95                         .doValidation(actorName)
  96                         .makeOperationParameters(actorName);
  97         // @formatter:on
  98     }
  99
 100
 101     // TODO old code: remove lines down to **HERE**
 102
 103     @Override
 104     public String actor() {
 105         return SDNC_ACTOR;
 106     }
 107
 108     @Override
 109     public List<String> recipes() {
 110         return ImmutableList.copyOf(recipes);
 111     }
 112
 113     @Override
 114     public List<String> recipeTargets(String recipe) {
 115         return ImmutableList.copyOf(targets.getOrDefault(recipe, Collections.emptyList()));
 116     }
 117
 118     @Override
 119     public List<String> recipePayloads(String recipe) {
 120         return Collections.emptyList();
 121     }
 122
 123     /**
 124      * Construct a request.
 125      *
 126      * @param onset the onset event
 127      * @param operation the control loop operation
 128      * @param policy the policy
 129      * @return the constructed request
 130      */
 131     public SdncRequest constructRequest(VirtualControlLoopEvent onset, ControlLoopOperation operation, Policy policy) {
 132         switch (policy.getRecipe()) {
 133             case RECIPE_REROUTE:
 134                 return constructReOptimizeRequest(onset);
 135             case RECIPE_BW_ON_DEMAND:
 136                 logger.info("Construct request for receipe {}", RECIPE_BW_ON_DEMAND);
 137                 return constructBwOnDemandRequest(onset);
 138             default:
 139                 logger.info("Unsupported recipe {}", policy.getRecipe());
 140                 return null;
 141         }
 142     }
 143
 144     private SdncRequest constructBwOnDemandRequest(VirtualControlLoopEvent onset) {
 145         // Construct an Sdnc request
 146         String serviceInstance = onset.getAai().get("service-instance.service-instance-id");
 147         if (serviceInstance == null || serviceInstance.isEmpty()) {
 148             // This indicates that AAI Enrichment needs to be done by event producer.
 149             return null;
 150         }
 151         SdncHealVfModuleParameter bandwidth = new SdncHealVfModuleParameter();
 152         bandwidth.setName("bandwidth");
 153         bandwidth.setValue(onset.getAai().get("bandwidth"));
 154
 155         SdncHealVfModuleParameter timeStamp = new SdncHealVfModuleParameter();
 156         timeStamp.setName("bandwidth-change-time");
 157         timeStamp.setValue(onset.getAai().get("bandwidth-change-time"));
 158
 159         SdncHealVfModuleParametersInfo vfParametersInfo = new SdncHealVfModuleParametersInfo();
 160         vfParametersInfo.addParameters(bandwidth);
 161         vfParametersInfo.addParameters(timeStamp);
 162
 163         SdncHealVfModuleRequestInput vfRequestInfo = new SdncHealVfModuleRequestInput();
 164         vfRequestInfo.setVfModuleParametersInfo(vfParametersInfo);
 165
 166         SdncHealServiceInfo serviceInfo = new SdncHealServiceInfo();
 167         serviceInfo.setServiceInstanceId(serviceInstance);
 168
 169         SdncHealRequestInfo requestInfo = new SdncHealRequestInfo();
 170         requestInfo.setRequestAction("SdwanBandwidthChange");
 171
 172         SdncHealRequestHeaderInfo headerInfo = new SdncHealRequestHeaderInfo();
 173         headerInfo.setSvcAction("update");
 174         headerInfo.setSvcRequestId(UUID.randomUUID().toString());
 175
 176         SdncRequest request = new SdncRequest();
 177         request.setNsInstanceId(serviceInstance);
 178         request.setRequestId(onset.getRequestId());
 179         request.setUrl("/GENERIC-RESOURCE-API:vf-module-topology-operation");
 180
 181         SdncHealVnfInfo vnfInfo = new SdncHealVnfInfo();
 182         vnfInfo.setVnfId(onset.getAai().get("vnfId"));
 183
 184         SdncHealVfModuleInfo vfModuleInfo = new SdncHealVfModuleInfo();
 185         vfModuleInfo.setVfModuleId("");
 186
 187         SdncHealRequest healRequest = new SdncHealRequest();
 188         healRequest.setVnfInfo(vnfInfo);
 189         healRequest.setVfModuleInfo(vfModuleInfo);
 190         healRequest.setRequestHeaderInfo(headerInfo);
 191         healRequest.setVfModuleRequestInput(vfRequestInfo);
 192         healRequest.setRequestInfo(requestInfo);
 193         healRequest.setServiceInfo(serviceInfo);
 194         request.setHealRequest(healRequest);
 195         return request;
 196     }
 197
 198     private SdncRequest constructReOptimizeRequest(VirtualControlLoopEvent onset) {
 199         // Construct an Sdnc request
 200         String serviceInstance = onset.getAai().get("service-instance.service-instance-id");
 201         if (serviceInstance == null || serviceInstance.isEmpty()) {
 202             // This indicates that AAI Enrichment needs to be done by event producer.
 203             return null;
 204         }
 205         SdncHealServiceInfo serviceInfo = new SdncHealServiceInfo();
 206         serviceInfo.setServiceInstanceId(serviceInstance);
 207
 208         String networkId = onset.getAai().get("network-information.network-id");
 209         if (networkId == null || networkId.isEmpty()) {
 210             // This indicates that AAI Enrichment needs to be done by event producer.
 211             return null;
 212         }
 213         SdncHealNetworkInfo networkInfo = new SdncHealNetworkInfo();
 214         networkInfo.setNetworkId(networkId);
 215
 216         SdncHealRequestInfo requestInfo = new SdncHealRequestInfo();
 217         requestInfo.setRequestAction("ReoptimizeSOTNInstance");
 218
 219         SdncHealRequestHeaderInfo headerInfo = new SdncHealRequestHeaderInfo();
 220         headerInfo.setSvcAction("reoptimize");
 221         headerInfo.setSvcRequestId(UUID.randomUUID().toString());
 222
 223         SdncRequest request = new SdncRequest();
 224         request.setNsInstanceId(serviceInstance);
 225         request.setRequestId(onset.getRequestId());
 226         request.setUrl("/GENERIC-RESOURCE-API:network-topology-operation");
 227
 228         SdncHealRequest healRequest = new SdncHealRequest();
 229         healRequest.setRequestHeaderInfo(headerInfo);
 230         healRequest.setNetworkInfo(networkInfo);
 231         healRequest.setRequestInfo(requestInfo);
 232         healRequest.setServiceInfo(serviceInfo);
 233         request.setHealRequest(healRequest);
 234         return request;
 235     }
 236
 237     // **HERE**
 238 }