summaryrefslogtreecommitdiffstats
path: root/adapters/mso-vnf-adapter/src/main/java/org/openecomp/mso/adapters/vnf/AriaVduPlugin.java
diff options
context:
space:
mode:
Diffstat (limited to 'adapters/mso-vnf-adapter/src/main/java/org/openecomp/mso/adapters/vnf/AriaVduPlugin.java')
-rw-r--r--adapters/mso-vnf-adapter/src/main/java/org/openecomp/mso/adapters/vnf/AriaVduPlugin.java305
1 files changed, 0 insertions, 305 deletions
diff --git a/adapters/mso-vnf-adapter/src/main/java/org/openecomp/mso/adapters/vnf/AriaVduPlugin.java b/adapters/mso-vnf-adapter/src/main/java/org/openecomp/mso/adapters/vnf/AriaVduPlugin.java
deleted file mode 100644
index 5258b978cc..0000000000
--- a/adapters/mso-vnf-adapter/src/main/java/org/openecomp/mso/adapters/vnf/AriaVduPlugin.java
+++ /dev/null
@@ -1,305 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * ONAP - SO
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-package org.openecomp.mso.adapters.vnf;
-
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-import com.gigaspaces.aria.rest.client.AriaClient;
-import com.gigaspaces.aria.rest.client.AriaClientFactory;
-import com.gigaspaces.aria.rest.client.ExecutionDetails;
-import com.gigaspaces.aria.rest.client.Input;
-import com.gigaspaces.aria.rest.client.InputImpl;
-import com.gigaspaces.aria.rest.client.Output;
-import com.gigaspaces.aria.rest.client.Service;
-import com.gigaspaces.aria.rest.client.ServiceTemplate;
-import com.gigaspaces.aria.rest.client.ServiceTemplateImpl;
-import org.openecomp.mso.logger.MessageEnum;
-import org.openecomp.mso.logger.MsoLogger;
-import org.openecomp.mso.openstack.exceptions.MsoAdapterException;
-import org.openecomp.mso.openstack.exceptions.MsoException;
-import org.openecomp.mso.vdu.utils.VduBlueprint;
-import org.openecomp.mso.vdu.utils.VduInfo;
-import org.openecomp.mso.vdu.utils.VduPlugin;
-import org.openecomp.mso.vdu.utils.VduStatus;
-
-/**
- * ARIA VDU Plugin. Pluggable interface for the ARIA REST API to support TOSCA
- * orchestration.
- *
- * @author DeWayne
- *
- */
-public class AriaVduPlugin implements VduPlugin {
- private static final String API_VERSION = "0.1";
- private static final MsoLogger logger = MsoLogger.getMsoLogger(MsoLogger.Catalog.RA);
- private AriaClient client=null;
- private Map<String,Integer> templateIds = new HashMap<>();
- private Map<String,Integer> serviceIds = new HashMap<>();
- private Map<String,Map<String,Object>> inputsCache = new HashMap<>();
-
- public AriaVduPlugin() {
- super();
- }
-
- public AriaVduPlugin( String host, int port) {
- try {
- client = new AriaClientFactory().createRestClient("http", host, port, API_VERSION);
- }catch(Exception e) {
- logger.error (MessageEnum.RA_CREATE_VNF_ERR, "", "", "", "", "aria", MsoLogger.ErrorCode.AvailabilityError, "Connection to ARIA REST API failed", e);
- throw e;
- }
- }
-
- /**
- * Instantiate VDU in ARIA. <code>vduInstanceName</code> is used for both service template
- * name and service name.<
- */
- @SuppressWarnings("unchecked")
- @Override
- public VduInfo instantiateVdu(String cloudSiteId, String tenantId, String vduInstanceName,
- VduBlueprint vduBlueprint, Map<String, ? extends Object> inputs, String environmentFile, int timeoutMinutes,
- boolean suppressBackout) throws MsoException {
-
- VduInfo vinfo = new VduInfo(vduInstanceName);
- byte[] csar = new CSAR(vduBlueprint).create();
- ServiceTemplate template = new ServiceTemplateImpl( vduInstanceName, csar);
- try {
- client.install_service_template(template);
- }
- catch(Exception e) {
- logger.error(MessageEnum.RA_CREATE_VNF_ERR, "","","","", vduInstanceName, MsoLogger.ErrorCode.BusinessProcesssError,
- "instantiate vdu via csar failed", e);
- throw new MsoAdapterException(e.getMessage());
- }
-
- /**
- * Create a service
- */
-
- try {
- int templateId=-1;
- for(ServiceTemplate stemplate:(List<ServiceTemplate>)client.list_service_templates()) {
- if(stemplate.getName().equals(vduInstanceName)) {
- templateId = stemplate.getId();
- }
- }
- List<Input> sinputs = new ArrayList<Input>();
- for(Map.Entry<String, ? extends Object> entry: inputs.entrySet()) {
- Input inp = new InputImpl(entry.getKey(),entry.getValue().toString(),"");
- sinputs.add(inp);
- }
- client.create_service(templateId, vduInstanceName, sinputs);
- }
- catch(Exception e) {
- logger.error(MessageEnum.RA_CREATE_VNF_ERR, "","","","", vduInstanceName, MsoLogger.ErrorCode.BusinessProcesssError,
- "aria service creation failed", e);
- throw new MsoAdapterException(e.getMessage());
- }
-
- // Get the service ID and cache it
- int sid = getServiceId(vduInstanceName);
- serviceIds.put(vduInstanceName, sid);
-
- /**
- * Run install
- */
-
- try {
- client.start_execution( sid, "install", new ExecutionDetails());
- }
- catch(Exception e) {
- logger.error(MessageEnum.RA_CREATE_VNF_ERR, "","","","", vduInstanceName, MsoLogger.ErrorCode.BusinessProcesssError,
- "aria install workflow failed", e);
- throw new MsoAdapterException(e.getMessage());
- }
-
- /**
- * Get the outputs and return
- */
-
- try {
- Map<String,Object> voutputs = getOutputs(sid);
-
- VduInfo vi = new VduInfo(vduInstanceName);
- vi.setInputs((Map<String,Object>)inputs);
- inputsCache.put(vduInstanceName,vi.getInputs());
- vi.setOutputs(voutputs);
- vi.setStatus(VduStatus.INSTANTIATED);
- return vi;
- }
- catch(Exception e) {
- logger.error(MessageEnum.RA_CREATE_VNF_ERR, "","","","", vduInstanceName, MsoLogger.ErrorCode.BusinessProcesssError,
- "aria service output fetch failed", e);
- throw new MsoAdapterException(e.getMessage());
- }
-
- }
-
- /**
- * Queries ARIA for VDU status. vduInstanceId used as template and service name in ARIA (by convention).
- */
- @Override
- public VduInfo queryVdu(String cloudSiteId, String tenantId, String vduInstanceId) throws MsoException {
- if(client == null) {
- throw new MsoAdapterException("Internal error: no ARIA connection found");
- }
-
- VduInfo vif = new VduInfo(vduInstanceId);
- Integer sid = serviceIds.get(vduInstanceId);
- if(sid == null) {
- // service doesn't exist
- vif.setStatus(VduStatus.NOTFOUND);
- return vif;
- }
- Service service = client.get_service(sid);
- if(service == null) {
- throw new MsoAdapterException(String.format("Internal error: cached service id %s not found in ARIA",sid));
- }
- Map<String,Object> voutputs = getOutputs(sid);
- vif.setOutputs(voutputs);
- vif.setInputs(inputsCache.get(vduInstanceId));
- vif.setStatus(VduStatus.INSTANTIATED);
- return vif;
- }
-
- @Override
- public VduInfo deleteVdu(String cloudSiteId, String tenantId, String vduInstanceId, int timeoutMinutes,
- boolean keepBlueprintLoaded) throws MsoException {
-
- if(client == null) {
- throw new MsoAdapterException("Internal error: no ARIA connection found");
- }
- Integer sid = serviceIds.get(vduInstanceId);
- VduInfo vif = new VduInfo(vduInstanceId);
- if(sid == null) {
- // service doesn't exist
- vif.setStatus(VduStatus.NOTFOUND);
- return vif;
- }
-
- /**
- * Run uninstall
- */
- try {
- client.start_execution( sid, "uninstall", new ExecutionDetails());
- }
- catch(Exception e) {
- logger.error(MessageEnum.RA_CREATE_VNF_ERR, "","","","", vduInstanceId, MsoLogger.ErrorCode.BusinessProcesssError,
- "aria uninstall workflow failed", e);
- throw new MsoAdapterException(e.getMessage());
- }
-
- /**
- * Delete the service
- */
- try {
- client.delete_service(sid);
- }
- catch(Exception e) {
- logger.error(MessageEnum.RA_CREATE_VNF_ERR, "","","","", vduInstanceId, MsoLogger.ErrorCode.BusinessProcesssError,
- String.format("aria service delete failed. Service id: %d",sid), e);
- throw new MsoAdapterException(e.getMessage());
- }
-
- /**
- * Delete the blueprint
- */
- try {
- client.delete_service_template(templateIds.get(vduInstanceId));
- }
- catch(Exception e) {
- logger.error(MessageEnum.RA_CREATE_VNF_ERR, "","","","", vduInstanceId, MsoLogger.ErrorCode.BusinessProcesssError,
- "aria template delete failed", e);
- throw new MsoAdapterException(e.getMessage());
- }
-
- vif.setStatus(VduStatus.DELETED);
- return vif;
- }
-
- /**
- * Deployment update not possible with ARIA
- */
- @Override
- public VduInfo updateVdu(String cloudSiteId, String tenantId, String vduInstanceId, VduBlueprint vduBlueprint,
- Map<String, ? extends Object> inputs, String environmentFile, int timeoutMinutes) throws MsoException {
- throw new MsoAdapterException("NOT IMPLEMENTED");
- }
-
- /**
- * Nonsensical in the context of ARIA: blueprint lifespan = vdulifespan
- */
- @Override
- public boolean isBlueprintLoaded(String cloudSiteId, String vduModelId) throws MsoException {
- throw new MsoAdapterException("NOT IMPLEMENTED");
- }
-
- /**
- * Nonsensical in the context of ARIA: blueprint lifespan = vdulifespan
- */
- @Override
- public void uploadBlueprint(String cloudSiteId, VduBlueprint vduBlueprint, boolean failIfExists)
- throws MsoException {
- throw new MsoAdapterException("NOT IMPLEMENTED");
- }
-
- @Override
- public boolean blueprintUploadSupported() {
- return false;
- }
-
- /**
- * Private
- */
-
- /**p
- * Gets and repacks service outputs for internal use
- * @param sid the service id (ARIA service id)
- * @return
- */
- private Map<String,Object> getOutputs(int sid) {
- @SuppressWarnings("unchecked")
- List<Output> outputs=(List<Output>)client.list_service_outputs(sid);
- Map<String,Object> voutputs = new HashMap<>();
- for(Output output: outputs) {
- voutputs.put(output.getName(), output.getValue());
- }
- return voutputs;
- }
-
- @SuppressWarnings("unchecked")
- private int getServiceId(String service_name) throws MsoAdapterException{
- int sid = -1;
- List<Service> services = (List<Service>)client.list_services();
- for(Service service:services) {
- if(service.getName().equals(service_name)) {
- sid = service.getId();
- }
- }
- if(sid == -1) {
- throw new MsoAdapterException(String.format("Internal error: just created service not found: %s",service_name));
- }
- return sid;
- }
-
-}