diff options
3 files changed, 495 insertions, 0 deletions
diff --git a/adapters/mso-vnf-adapter/pom.xml b/adapters/mso-vnf-adapter/pom.xml index 9a290f4f00..643f42f2ba 100644 --- a/adapters/mso-vnf-adapter/pom.xml +++ b/adapters/mso-vnf-adapter/pom.xml @@ -145,6 +145,11 @@ <version>${project.version}</version>
</dependency>
<dependency>
+ <groupId>org.onap.so</groupId>
+ <artifactId>aria-client</artifactId>
+ <version>1.2.0</version>
+ </dependency>
+ <dependency>
<groupId>org.jmockit</groupId>
<artifactId>jmockit</artifactId>
<version>1.8</version>
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 new file mode 100644 index 0000000000..5258b978cc --- /dev/null +++ b/adapters/mso-vnf-adapter/src/main/java/org/openecomp/mso/adapters/vnf/AriaVduPlugin.java @@ -0,0 +1,305 @@ +/*- + * ============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; + } + +} diff --git a/adapters/mso-vnf-adapter/src/main/java/org/openecomp/mso/adapters/vnf/CSAR.java b/adapters/mso-vnf-adapter/src/main/java/org/openecomp/mso/adapters/vnf/CSAR.java new file mode 100644 index 0000000000..8bea228629 --- /dev/null +++ b/adapters/mso-vnf-adapter/src/main/java/org/openecomp/mso/adapters/vnf/CSAR.java @@ -0,0 +1,185 @@ +/* + * ============LICENSE_START=================================================== + * Copyright (c) 2017 Cloudify.co. 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.io.ByteArrayOutputStream; +import java.io.File; +import java.io.FileInputStream; +import java.io.FileOutputStream; +import java.io.IOException; +import java.io.OutputStream; +import java.io.PrintStream; +import java.util.Map; +import java.util.zip.ZipEntry; +import java.util.zip.ZipOutputStream; + +import org.openecomp.mso.vdu.utils.VduBlueprint; + +import com.google.common.io.Files; + +/** + * The purpose of this class is to create a CSAR byte array from Vdu inputs for the purpose + * of forwarding to a TOSCA orchestrator. + * + * @author DeWayne + * + */ +public class CSAR { + private static final String MANIFEST_FILENAME = "MANIFEST.MF"; + + private VduBlueprint blueprint; + + + public CSAR(VduBlueprint blueprint) { + this.blueprint = blueprint; + } + + /** + * Creates a byte array representation of a CSAR corresponding to the VduBlueprint arg in the + * constructor. + * + * @return + */ + public byte[] create() { + File dir = Files.createTempDir(); + + /** + * Create subdir + */ + File metadir = new File(dir.getAbsolutePath() + "/" + "TOSCA-Metadata"); + if (!metadir.mkdir()) { + throw new RuntimeException("CSAR TOSCA-Metadata directory create failed"); + } + + /** + * Write template files + */ + OutputStream ofs = null; + try { + ofs = new FileOutputStream(new File(dir, blueprint.getMainTemplateName())); + ofs.write(blueprint.getTemplateFiles().get(blueprint.getMainTemplateName())); + ofs.close(); + + /** + * Write other files + */ + if (blueprint.getTemplateFiles() != null) { + for (Map.Entry<String, byte[]> entry : blueprint.getTemplateFiles().entrySet()) { + if (!entry.getKey().equals(blueprint.getMainTemplateName())) { + ofs = new FileOutputStream(new File(dir, entry.getKey())); + ofs.write(entry.getValue()); + ofs.close(); + } + } + } + + /** + * Write attached files + */ + if (blueprint.getAttachedFiles() != null) { + for (Map.Entry<String, byte[]> entry : blueprint.getAttachedFiles().entrySet()) { + ofs = new FileOutputStream(new File(dir, entry.getKey())); + ofs.write(entry.getValue()); + ofs.close(); + } + } + + /** + * Create manifest + */ + PrintStream mfstream = new PrintStream(new File(metadir.getAbsolutePath() + "/" + MANIFEST_FILENAME)); + mfstream.println("TOSCA-Meta-File-Version: 1.0"); + mfstream.println("CSAR-Version: 1.1"); + mfstream.println("Created-by: ONAP"); + mfstream.println("Entry-Definitions: " + blueprint.getMainTemplateName()); + mfstream.close(); + + /** + * ZIP it up + */ + ByteArrayOutputStream zipbytes = new ByteArrayOutputStream(); + ZipOutputStream zos = new ZipOutputStream(zipbytes); + compressTree(zos, "", dir, dir); + zos.close(); + return zipbytes.toByteArray(); + + } catch (Exception e) { + throw new RuntimeException("Failed to create CSAR: " + e.getMessage()); + } finally { + + /** + * Clean up tmpdir + */ + deleteDirectory(dir); + } + } + + /** + * Private methods + */ + + /** + * Compresses (ZIPs) a directory tree + * + * @param dir + * @throws IOException + */ + private void compressTree(ZipOutputStream zos, String path, File basedir, File dir) throws IOException { + if (!dir.isDirectory()) + return; + + for (File f : dir.listFiles()) { + if (f.isDirectory()) { + String newpath = path + f.getName() + "/"; + ZipEntry entry = new ZipEntry(newpath); + zos.putNextEntry(entry); + zos.closeEntry(); + compressTree(zos, newpath, basedir, f); + } else { + ZipEntry ze = new ZipEntry( + f.getAbsolutePath().substring(basedir.getAbsolutePath().length() + 1).replaceAll("\\\\", "/")); + zos.putNextEntry(ze); + // read the file and write to ZipOutputStream + FileInputStream fis = new FileInputStream(f); + byte[] buffer = new byte[1024]; + int len; + while ((len = fis.read(buffer)) > 0) { + zos.write(buffer, 0, len); + } + zos.closeEntry(); + fis.close(); + } + } + } + + private boolean deleteDirectory(File directory) { + if (directory.exists()) { + File[] files = directory.listFiles(); + if (null != files) { + for (int i = 0; i < files.length; i++) { + if (files[i].isDirectory()) { + deleteDirectory(files[i]); + } else { + files[i].delete(); + } + } + } + } + return (directory.delete()); + } +} |