From 51f0574fe68c87f5e5f9fed2875d9e45ab6cdf7e Mon Sep 17 00:00:00 2001 From: YuanHu Date: Thu, 8 Sep 2016 09:58:30 +0800 Subject: Change java.io.File.deleteOnExit() to java.io.File.delete(). For the latter id more stable. Change-Id: I52c6982fd1fbfcd9146f7a80ccf9f4cf16feba3f Signed-off-by: YuanHu --- .../catalog/model/parser/ToscaYamlModelParser.java | 830 ++++++++++----------- 1 file changed, 415 insertions(+), 415 deletions(-) (limited to 'catalog-core') diff --git a/catalog-core/catalog-mgr/src/main/java/org/openo/commontosca/catalog/model/parser/ToscaYamlModelParser.java b/catalog-core/catalog-mgr/src/main/java/org/openo/commontosca/catalog/model/parser/ToscaYamlModelParser.java index ac381e7d..739ed5ed 100644 --- a/catalog-core/catalog-mgr/src/main/java/org/openo/commontosca/catalog/model/parser/ToscaYamlModelParser.java +++ b/catalog-core/catalog-mgr/src/main/java/org/openo/commontosca/catalog/model/parser/ToscaYamlModelParser.java @@ -1,415 +1,415 @@ -/** - * Copyright 2016 [ZTE] and others. - * - * 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. - */ - -package org.openo.commontosca.catalog.model.parser; - -import org.openo.commontosca.catalog.common.MsbAddrConfig; -import org.openo.commontosca.catalog.common.ToolUtil; -import org.openo.commontosca.catalog.db.exception.CatalogResourceException; -import org.openo.commontosca.catalog.db.resource.TemplateManager; -import org.openo.commontosca.catalog.entity.response.CsarFileUriResponse; -import org.openo.commontosca.catalog.model.common.TemplateDataHelper; -import org.openo.commontosca.catalog.model.entity.EnumDataType; -import org.openo.commontosca.catalog.model.entity.InputParameter; -import org.openo.commontosca.catalog.model.entity.NodeTemplate; -import org.openo.commontosca.catalog.model.entity.OutputParameter; -import org.openo.commontosca.catalog.model.entity.RelationShip; -import org.openo.commontosca.catalog.model.entity.ServiceTemplate; -import org.openo.commontosca.catalog.model.entity.ServiceTemplateOperation; -import org.openo.commontosca.catalog.model.entity.SubstitutionMapping; -import org.openo.commontosca.catalog.model.parser.yaml.YamlParseServiceConsumer; -import org.openo.commontosca.catalog.model.parser.yaml.entity.EnumYamlServiceTemplateInfo; -import org.openo.commontosca.catalog.model.parser.yaml.entity.ParseYamlRequestParemeter; -import org.openo.commontosca.catalog.model.parser.yaml.entity.ParseYamlResult; -import org.openo.commontosca.catalog.model.parser.yaml.entity.ParseYamlResult.Plan; -import org.openo.commontosca.catalog.model.parser.yaml.entity.ParseYamlResult.Plan.PlanValue.PlanInput; -import org.openo.commontosca.catalog.model.parser.yaml.entity.ParseYamlResult.TopologyTemplate.Input; -import org.openo.commontosca.catalog.model.parser.yaml.entity.ParseYamlResult.TopologyTemplate.NodeTemplate.Relationship; -import org.openo.commontosca.catalog.model.parser.yaml.entity.ParseYamlResult.TopologyTemplate.Output; -import org.openo.commontosca.catalog.model.plan.wso2.Wso2ServiceConsumer; -import org.openo.commontosca.catalog.model.plan.wso2.entity.DeployPackageResponse; -import org.openo.commontosca.catalog.wrapper.PackageWrapper; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import java.io.BufferedInputStream; -import java.io.BufferedReader; -import java.io.File; -import java.io.FileInputStream; -import java.io.IOException; -import java.io.InputStream; -import java.io.InputStreamReader; -import java.util.ArrayList; -import java.util.HashMap; -import java.util.List; -import java.util.Map; -import java.util.zip.ZipEntry; -import java.util.zip.ZipFile; -import java.util.zip.ZipInputStream; - - -public class ToscaYamlModelParser extends AbstractModelParser { - - private static final Object TOSCA_META_FIELD_ENTRY_DEFINITIONS = "Entry-Definitions"; - private static final Logger LOGGER = LoggerFactory.getLogger(ToscaYamlModelParser.class); - - @Override - public String parse(String packageId, String fileLocation) throws CatalogResourceException { - ParseYamlResult result = getParseYamlResult(fileLocation); - - Map toscaMeta = parseToscaMeta(fileLocation); - String stFileName = toscaMeta.get(TOSCA_META_FIELD_ENTRY_DEFINITIONS); - CsarFileUriResponse stDownloadUri = - PackageWrapper.getInstance().getCsarFileDownloadUri(packageId, stFileName); - - ServiceTemplate st = parseServiceTemplate(packageId, result, stDownloadUri.getDownloadUri()); - ServiceTemplateOperation[] operations = parseOperations(result.getPlanList(), fileLocation); - st.setOperations(operations); - List ntList = parseNodeTemplates(packageId, st.getServiceTemplateId(), result); - st.setType(getTemplateType(result, ntList).toString()); - - TemplateManager.getInstance().addServiceTemplate( - TemplateDataHelper.convert2TemplateData(st, ToolUtil.toJson(result), ntList)); - - SubstitutionMapping stm = parseSubstitutionMapping(st.getServiceTemplateId(), result); - if (stm != null) { - TemplateManager.getInstance() - .addServiceTemplateMapping(TemplateDataHelper.convert2TemplateMappingData(stm)); - } - - return st.getServiceTemplateId(); - } - - private ParseYamlResult getParseYamlResult(String fileLocation) throws CatalogResourceException { - String destPath = copyTemporaryFile2HttpServer(fileLocation); - try { - String url = getUrl(toTempFileLocalPath(fileLocation)); - return YamlParseServiceConsumer.getServiceTemplates(comboRequest(url)); - } finally { - if (destPath != null && !destPath.isEmpty() && (new File(destPath)).exists()) { - (new File(destPath)).deleteOnExit(); - } - } - } - - private String toTempFileLocalPath(String fileLocation) { - return File.separator + "temp" + File.separator + (new File(fileLocation)).getName(); - } - - private String getUrl(String uri) { - String url = null; - if ((MsbAddrConfig.getMsbAddress().endsWith("/")) && uri.startsWith("/")) { - url = MsbAddrConfig.getMsbAddress() + uri.substring(1); - } - url = MsbAddrConfig.getMsbAddress() + uri; - String urlresult = url.replace("\\", "/"); - return urlresult; - } - - private String copyTemporaryFile2HttpServer(String fileLocation) throws CatalogResourceException { - String destPath = Class.class.getClass().getResource("/").getPath() - + org.openo.commontosca.catalog.filemanage.http.ToolUtil.getHttpServerPath() - + toTempFileLocalPath(fileLocation); - if (!org.openo.commontosca.catalog.filemanage.http.ToolUtil.copyFile(fileLocation, destPath, - true)) { - throw new CatalogResourceException("Copy Temporary To HttpServer Failed."); - } - return destPath; - } - - @SuppressWarnings("resource") - private Map parseToscaMeta(String fileLocation) throws CatalogResourceException { - Map toscaMeta = new HashMap<>(); - - ZipInputStream zin = null; - BufferedReader br = null; - try { - InputStream in = new BufferedInputStream(new FileInputStream(fileLocation)); - zin = new ZipInputStream(in); - ZipEntry ze; - while ((ze = zin.getNextEntry()) != null) { - if (("TOSCA-Metadata" + File.separator + "TOSCA.meta").equals(ze.getName()) - || "TOSCA-Metadata/TOSCA.meta".equals(ze.getName())) { - ZipFile zf = new ZipFile(fileLocation); - br = new BufferedReader(new InputStreamReader(zf.getInputStream(ze))); - String line; - String[] tmps; - while ((line = br.readLine()) != null) { - if (line.indexOf(":") > 0) { - tmps = line.split(":"); - toscaMeta.put(tmps[0].trim(), tmps[1].trim()); - } - } - - return toscaMeta; - } - } - - } catch (IOException e1) { - throw new CatalogResourceException("Parse Tosca Meta Fail.", e1); - } finally { - closeStreamAndReader(zin, br); - } - - return toscaMeta; - } - - private void closeStreamAndReader(ZipInputStream zin, BufferedReader br) { - if (br != null) { - try { - br.close(); - } catch (IOException e1) { - LOGGER.error("Buffered reader close failed !"); - } - } - if (zin != null) { - try { - zin.closeEntry(); - } catch (IOException e2) { - LOGGER.error("Zip inputStream close failed !"); - } - } - } - - private ParseYamlRequestParemeter comboRequest(String fileLocation) { - ParseYamlRequestParemeter request = new ParseYamlRequestParemeter(); - request.setPath(fileLocation); - return request; - } - - private SubstitutionMapping parseSubstitutionMapping(String serviceTemplateId, - ParseYamlResult result) { - String type = getSubstitutionMappingType(result); - if (ToolUtil.isTrimedEmptyString(type)) { - return null; - } - - org.openo.commontosca.catalog.model.parser.yaml.entity.ParseYamlResult - .TopologyTemplate.SubstitutionMapping stm = - result.getTopologyTemplate().getSubstitutionMappings(); - return new SubstitutionMapping(serviceTemplateId, type, stm.getRequirementList(), - stm.getCapabilityList()); - } - - private ServiceTemplate parseServiceTemplate(String packageId, ParseYamlResult result, - String stDownloadUri) { - ServiceTemplate st = new ServiceTemplate(); - - st.setServiceTemplateId(ToolUtil.generateId()); - st.setTemplateName(result.getMetadata().get(EnumYamlServiceTemplateInfo.ID.getName())); - st.setVendor(result.getMetadata().get(EnumYamlServiceTemplateInfo.PROVIDER.getName())); - st.setVersion(result.getMetadata().get(EnumYamlServiceTemplateInfo.VERSION.getName())); - st.setCsarid(packageId); - st.setDownloadUri(stDownloadUri); - st.setInputs(parseInputs(result)); - st.setOutputs(parseOutputs(result)); - return st; - } - - private InputParameter[] parseInputs(ParseYamlResult result) { - List inputList = result.getTopologyTemplate().getInputs(); - if (inputList == null) { - return new InputParameter[0]; - } - List retList = new ArrayList(); - for (Input input : inputList) { - retList.add(new InputParameter(input.getName(), getEnumDataType(input.getType()), - input.getDescription(), input.getDefault(), input.isRequired())); - } - return retList.toArray(new InputParameter[0]); - } - - private OutputParameter[] parseOutputs(ParseYamlResult result) { - List outputList = result.getTopologyTemplate().getOutputs(); - if (outputList == null || outputList.isEmpty()) { - return new OutputParameter[0]; - } - List retList = new ArrayList(); - for (Output output : outputList) { - retList - .add(new OutputParameter(output.getName(), output.getDescription(), output.getValue())); - } - return retList.toArray(new OutputParameter[0]); - } - - private ServiceTemplateOperation[] parseOperations(List planList, String zipFileLocation) - throws CatalogResourceException { - if (planList == null || planList.isEmpty()) { - return new ServiceTemplateOperation[0]; - } - - List opList = new ArrayList<>(); - for (Plan plan : planList) { - ServiceTemplateOperation op = new ServiceTemplateOperation(); - op.setName(plan.getName()); - op.setDescription(plan.getDescription()); - checkPlanLanguage(plan.getPlanLanguage()); - DeployPackageResponse response = - Wso2ServiceConsumer.deployPackage(zipFileLocation, plan.getReference()); - op.setPackageName(parsePackageName(response)); - op.setProcessId(response.getProcessId()); - op.setInputs(parsePlanInputs(plan.getInputList())); - - opList.add(op); - - } - return opList.toArray(new ServiceTemplateOperation[0]); - } - - private String parsePackageName(DeployPackageResponse response) { - String packageName = response.getPackageName(); - if (packageName != null && packageName.indexOf("-") > 0) { - packageName = packageName.substring(0, packageName.lastIndexOf("-")); - } - return packageName; - } - - private void checkPlanLanguage(String planLanguage) throws CatalogResourceException { - if (planLanguage == null || planLanguage.isEmpty()) { - throw new CatalogResourceException("Plan Language is empty."); - } - if (planLanguage.equalsIgnoreCase("bpel")) { - return; - } - if (planLanguage.equalsIgnoreCase("bpmn")) { - return; - } - if (planLanguage.equalsIgnoreCase("bpmn4tosca")) { - return; - } - throw new CatalogResourceException( - "Plan Language is not supported. Language = " + planLanguage); - } - - private InputParameter[] parsePlanInputs(List inputList) { - if (inputList == null || inputList.isEmpty()) { - return new InputParameter[0]; - } - - List retList = new ArrayList<>(); - for (PlanInput input : inputList) { - retList.add(new InputParameter(input.getName(), getEnumDataType(input.getType()), - input.getDescription(), input.getDefault(), input.isRequired())); - } - return retList.toArray(new InputParameter[0]); - } - - private EnumDataType getEnumDataType(String type) { - if (EnumDataType.INTEGER.toString().equalsIgnoreCase(type)) { - return EnumDataType.INTEGER; - } - - if (EnumDataType.FLOAT.toString().equalsIgnoreCase(type)) { - return EnumDataType.FLOAT; - } - - if (EnumDataType.BOOLEAN.toString().equalsIgnoreCase(type)) { - return EnumDataType.BOOLEAN; - } - - return EnumDataType.STRING; - } - - private List parseNodeTemplates(String csarId, String templateId, - ParseYamlResult result) { - List nodetemplateList = - result.getTopologyTemplate().getNodeTemplates(); - if (nodetemplateList == null) { - return null; - } - - List retList = new ArrayList<>(); - for (ParseYamlResult.TopologyTemplate.NodeTemplate nodeTemplate : nodetemplateList) { - NodeTemplate ret = new NodeTemplate(); - ret.setId(nodeTemplate.getName()); - ret.setName(nodeTemplate.getName()); - ret.setType(nodeTemplate.getNodeType()); - ret.setProperties(nodeTemplate.getPropertyList()); - List relationShipList = - parseNodeTemplateRelationShip(nodeTemplate.getRelationships()); - ret.setRelationShips(relationShipList); - - retList.add(ret); - } - - return retList; - } - - - private List parseNodeTemplateRelationShip(List relationshipList) { - List retList = new ArrayList<>(); - - if (relationshipList == null) { - return retList; - } - - for (Relationship relationship : relationshipList) { - RelationShip ret = new RelationShip(); - ret.setSourceNodeId(relationship.getSourceNodeName()); - ret.setSourceNodeName(relationship.getSourceNodeName()); - ret.setTargetNodeId(relationship.getTargetNodeName()); - ret.setTargetNodeName(relationship.getTargetNodeName()); - ret.setType(relationship.getType()); - retList.add(ret); - } - - return retList; - } - - private EnumTemplateType getTemplateType(ParseYamlResult result, List ntList) { - String type = getSubstitutionMappingType(result); - if (isNsType(type)) { - return EnumTemplateType.NS; - } - - if (isVnfType(type)) { - return EnumTemplateType.VNF; - } - - return getTemplateTypeFromNodeTemplates(ntList); - } - - private String getSubstitutionMappingType(ParseYamlResult result) { - if (result.getTopologyTemplate().getSubstitutionMappings() == null) { - return null; - } - return result.getTopologyTemplate().getSubstitutionMappings().getNodeType(); - } - - private EnumTemplateType getTemplateTypeFromNodeTemplates(List ntList) { - for (NodeTemplate nt : ntList) { - if (isNsType(nt.getType()) || isVnfType(nt.getType())) { - return EnumTemplateType.NS; - } - } - - return EnumTemplateType.VNF; - } - - private boolean isVnfType(String type) { - if (ToolUtil.isTrimedEmptyString(type)) { - return false; - } - return type.toUpperCase().contains(".VNF"); - } - - private boolean isNsType(String type) { - if (ToolUtil.isTrimedEmptyString(type)) { - return false; - } - return type.toUpperCase().contains(".NS"); - } -} +/** + * Copyright 2016 [ZTE] and others. + * + * 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. + */ + +package org.openo.commontosca.catalog.model.parser; + +import org.openo.commontosca.catalog.common.MsbAddrConfig; +import org.openo.commontosca.catalog.common.ToolUtil; +import org.openo.commontosca.catalog.db.exception.CatalogResourceException; +import org.openo.commontosca.catalog.db.resource.TemplateManager; +import org.openo.commontosca.catalog.entity.response.CsarFileUriResponse; +import org.openo.commontosca.catalog.model.common.TemplateDataHelper; +import org.openo.commontosca.catalog.model.entity.EnumDataType; +import org.openo.commontosca.catalog.model.entity.InputParameter; +import org.openo.commontosca.catalog.model.entity.NodeTemplate; +import org.openo.commontosca.catalog.model.entity.OutputParameter; +import org.openo.commontosca.catalog.model.entity.RelationShip; +import org.openo.commontosca.catalog.model.entity.ServiceTemplate; +import org.openo.commontosca.catalog.model.entity.ServiceTemplateOperation; +import org.openo.commontosca.catalog.model.entity.SubstitutionMapping; +import org.openo.commontosca.catalog.model.parser.yaml.YamlParseServiceConsumer; +import org.openo.commontosca.catalog.model.parser.yaml.entity.EnumYamlServiceTemplateInfo; +import org.openo.commontosca.catalog.model.parser.yaml.entity.ParseYamlRequestParemeter; +import org.openo.commontosca.catalog.model.parser.yaml.entity.ParseYamlResult; +import org.openo.commontosca.catalog.model.parser.yaml.entity.ParseYamlResult.Plan; +import org.openo.commontosca.catalog.model.parser.yaml.entity.ParseYamlResult.Plan.PlanValue.PlanInput; +import org.openo.commontosca.catalog.model.parser.yaml.entity.ParseYamlResult.TopologyTemplate.Input; +import org.openo.commontosca.catalog.model.parser.yaml.entity.ParseYamlResult.TopologyTemplate.NodeTemplate.Relationship; +import org.openo.commontosca.catalog.model.parser.yaml.entity.ParseYamlResult.TopologyTemplate.Output; +import org.openo.commontosca.catalog.model.plan.wso2.Wso2ServiceConsumer; +import org.openo.commontosca.catalog.model.plan.wso2.entity.DeployPackageResponse; +import org.openo.commontosca.catalog.wrapper.PackageWrapper; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import java.io.BufferedInputStream; +import java.io.BufferedReader; +import java.io.File; +import java.io.FileInputStream; +import java.io.IOException; +import java.io.InputStream; +import java.io.InputStreamReader; +import java.util.ArrayList; +import java.util.HashMap; +import java.util.List; +import java.util.Map; +import java.util.zip.ZipEntry; +import java.util.zip.ZipFile; +import java.util.zip.ZipInputStream; + + +public class ToscaYamlModelParser extends AbstractModelParser { + + private static final Object TOSCA_META_FIELD_ENTRY_DEFINITIONS = "Entry-Definitions"; + private static final Logger LOGGER = LoggerFactory.getLogger(ToscaYamlModelParser.class); + + @Override + public String parse(String packageId, String fileLocation) throws CatalogResourceException { + ParseYamlResult result = getParseYamlResult(fileLocation); + + Map toscaMeta = parseToscaMeta(fileLocation); + String stFileName = toscaMeta.get(TOSCA_META_FIELD_ENTRY_DEFINITIONS); + CsarFileUriResponse stDownloadUri = + PackageWrapper.getInstance().getCsarFileDownloadUri(packageId, stFileName); + + ServiceTemplate st = parseServiceTemplate(packageId, result, stDownloadUri.getDownloadUri()); + ServiceTemplateOperation[] operations = parseOperations(result.getPlanList(), fileLocation); + st.setOperations(operations); + List ntList = parseNodeTemplates(packageId, st.getServiceTemplateId(), result); + st.setType(getTemplateType(result, ntList).toString()); + + TemplateManager.getInstance().addServiceTemplate( + TemplateDataHelper.convert2TemplateData(st, ToolUtil.toJson(result), ntList)); + + SubstitutionMapping stm = parseSubstitutionMapping(st.getServiceTemplateId(), result); + if (stm != null) { + TemplateManager.getInstance() + .addServiceTemplateMapping(TemplateDataHelper.convert2TemplateMappingData(stm)); + } + + return st.getServiceTemplateId(); + } + + private ParseYamlResult getParseYamlResult(String fileLocation) throws CatalogResourceException { + String destPath = copyTemporaryFile2HttpServer(fileLocation); + try { + String url = getUrl(toTempFileLocalPath(fileLocation)); + return YamlParseServiceConsumer.getServiceTemplates(comboRequest(url)); + } finally { + if (destPath != null && !destPath.isEmpty() && (new File(destPath)).exists()) { + (new File(destPath)).delete(); + } + } + } + + private String toTempFileLocalPath(String fileLocation) { + return File.separator + "temp" + File.separator + (new File(fileLocation)).getName(); + } + + private String getUrl(String uri) { + String url = null; + if ((MsbAddrConfig.getMsbAddress().endsWith("/")) && uri.startsWith("/")) { + url = MsbAddrConfig.getMsbAddress() + uri.substring(1); + } + url = MsbAddrConfig.getMsbAddress() + uri; + String urlresult = url.replace("\\", "/"); + return urlresult; + } + + private String copyTemporaryFile2HttpServer(String fileLocation) throws CatalogResourceException { + String destPath = Class.class.getClass().getResource("/").getPath() + + org.openo.commontosca.catalog.filemanage.http.ToolUtil.getHttpServerPath() + + toTempFileLocalPath(fileLocation); + if (!org.openo.commontosca.catalog.filemanage.http.ToolUtil.copyFile(fileLocation, destPath, + true)) { + throw new CatalogResourceException("Copy Temporary To HttpServer Failed."); + } + return destPath; + } + + @SuppressWarnings("resource") + private Map parseToscaMeta(String fileLocation) throws CatalogResourceException { + Map toscaMeta = new HashMap<>(); + + ZipInputStream zin = null; + BufferedReader br = null; + try { + InputStream in = new BufferedInputStream(new FileInputStream(fileLocation)); + zin = new ZipInputStream(in); + ZipEntry ze; + while ((ze = zin.getNextEntry()) != null) { + if (("TOSCA-Metadata" + File.separator + "TOSCA.meta").equals(ze.getName()) + || "TOSCA-Metadata/TOSCA.meta".equals(ze.getName())) { + ZipFile zf = new ZipFile(fileLocation); + br = new BufferedReader(new InputStreamReader(zf.getInputStream(ze))); + String line; + String[] tmps; + while ((line = br.readLine()) != null) { + if (line.indexOf(":") > 0) { + tmps = line.split(":"); + toscaMeta.put(tmps[0].trim(), tmps[1].trim()); + } + } + + return toscaMeta; + } + } + + } catch (IOException e1) { + throw new CatalogResourceException("Parse Tosca Meta Fail.", e1); + } finally { + closeStreamAndReader(zin, br); + } + + return toscaMeta; + } + + private void closeStreamAndReader(ZipInputStream zin, BufferedReader br) { + if (br != null) { + try { + br.close(); + } catch (IOException e1) { + LOGGER.error("Buffered reader close failed !"); + } + } + if (zin != null) { + try { + zin.closeEntry(); + } catch (IOException e2) { + LOGGER.error("Zip inputStream close failed !"); + } + } + } + + private ParseYamlRequestParemeter comboRequest(String fileLocation) { + ParseYamlRequestParemeter request = new ParseYamlRequestParemeter(); + request.setPath(fileLocation); + return request; + } + + private SubstitutionMapping parseSubstitutionMapping(String serviceTemplateId, + ParseYamlResult result) { + String type = getSubstitutionMappingType(result); + if (ToolUtil.isTrimedEmptyString(type)) { + return null; + } + + org.openo.commontosca.catalog.model.parser.yaml.entity.ParseYamlResult + .TopologyTemplate.SubstitutionMapping stm = + result.getTopologyTemplate().getSubstitutionMappings(); + return new SubstitutionMapping(serviceTemplateId, type, stm.getRequirementList(), + stm.getCapabilityList()); + } + + private ServiceTemplate parseServiceTemplate(String packageId, ParseYamlResult result, + String stDownloadUri) { + ServiceTemplate st = new ServiceTemplate(); + + st.setServiceTemplateId(ToolUtil.generateId()); + st.setTemplateName(result.getMetadata().get(EnumYamlServiceTemplateInfo.ID.getName())); + st.setVendor(result.getMetadata().get(EnumYamlServiceTemplateInfo.PROVIDER.getName())); + st.setVersion(result.getMetadata().get(EnumYamlServiceTemplateInfo.VERSION.getName())); + st.setCsarid(packageId); + st.setDownloadUri(stDownloadUri); + st.setInputs(parseInputs(result)); + st.setOutputs(parseOutputs(result)); + return st; + } + + private InputParameter[] parseInputs(ParseYamlResult result) { + List inputList = result.getTopologyTemplate().getInputs(); + if (inputList == null) { + return new InputParameter[0]; + } + List retList = new ArrayList(); + for (Input input : inputList) { + retList.add(new InputParameter(input.getName(), getEnumDataType(input.getType()), + input.getDescription(), input.getDefault(), input.isRequired())); + } + return retList.toArray(new InputParameter[0]); + } + + private OutputParameter[] parseOutputs(ParseYamlResult result) { + List outputList = result.getTopologyTemplate().getOutputs(); + if (outputList == null || outputList.isEmpty()) { + return new OutputParameter[0]; + } + List retList = new ArrayList(); + for (Output output : outputList) { + retList + .add(new OutputParameter(output.getName(), output.getDescription(), output.getValue())); + } + return retList.toArray(new OutputParameter[0]); + } + + private ServiceTemplateOperation[] parseOperations(List planList, String zipFileLocation) + throws CatalogResourceException { + if (planList == null || planList.isEmpty()) { + return new ServiceTemplateOperation[0]; + } + + List opList = new ArrayList<>(); + for (Plan plan : planList) { + ServiceTemplateOperation op = new ServiceTemplateOperation(); + op.setName(plan.getName()); + op.setDescription(plan.getDescription()); + checkPlanLanguage(plan.getPlanLanguage()); + DeployPackageResponse response = + Wso2ServiceConsumer.deployPackage(zipFileLocation, plan.getReference()); + op.setPackageName(parsePackageName(response)); + op.setProcessId(response.getProcessId()); + op.setInputs(parsePlanInputs(plan.getInputList())); + + opList.add(op); + + } + return opList.toArray(new ServiceTemplateOperation[0]); + } + + private String parsePackageName(DeployPackageResponse response) { + String packageName = response.getPackageName(); + if (packageName != null && packageName.indexOf("-") > 0) { + packageName = packageName.substring(0, packageName.lastIndexOf("-")); + } + return packageName; + } + + private void checkPlanLanguage(String planLanguage) throws CatalogResourceException { + if (planLanguage == null || planLanguage.isEmpty()) { + throw new CatalogResourceException("Plan Language is empty."); + } + if (planLanguage.equalsIgnoreCase("bpel")) { + return; + } + if (planLanguage.equalsIgnoreCase("bpmn")) { + return; + } + if (planLanguage.equalsIgnoreCase("bpmn4tosca")) { + return; + } + throw new CatalogResourceException( + "Plan Language is not supported. Language = " + planLanguage); + } + + private InputParameter[] parsePlanInputs(List inputList) { + if (inputList == null || inputList.isEmpty()) { + return new InputParameter[0]; + } + + List retList = new ArrayList<>(); + for (PlanInput input : inputList) { + retList.add(new InputParameter(input.getName(), getEnumDataType(input.getType()), + input.getDescription(), input.getDefault(), input.isRequired())); + } + return retList.toArray(new InputParameter[0]); + } + + private EnumDataType getEnumDataType(String type) { + if (EnumDataType.INTEGER.toString().equalsIgnoreCase(type)) { + return EnumDataType.INTEGER; + } + + if (EnumDataType.FLOAT.toString().equalsIgnoreCase(type)) { + return EnumDataType.FLOAT; + } + + if (EnumDataType.BOOLEAN.toString().equalsIgnoreCase(type)) { + return EnumDataType.BOOLEAN; + } + + return EnumDataType.STRING; + } + + private List parseNodeTemplates(String csarId, String templateId, + ParseYamlResult result) { + List nodetemplateList = + result.getTopologyTemplate().getNodeTemplates(); + if (nodetemplateList == null) { + return null; + } + + List retList = new ArrayList<>(); + for (ParseYamlResult.TopologyTemplate.NodeTemplate nodeTemplate : nodetemplateList) { + NodeTemplate ret = new NodeTemplate(); + ret.setId(nodeTemplate.getName()); + ret.setName(nodeTemplate.getName()); + ret.setType(nodeTemplate.getNodeType()); + ret.setProperties(nodeTemplate.getPropertyList()); + List relationShipList = + parseNodeTemplateRelationShip(nodeTemplate.getRelationships()); + ret.setRelationShips(relationShipList); + + retList.add(ret); + } + + return retList; + } + + + private List parseNodeTemplateRelationShip(List relationshipList) { + List retList = new ArrayList<>(); + + if (relationshipList == null) { + return retList; + } + + for (Relationship relationship : relationshipList) { + RelationShip ret = new RelationShip(); + ret.setSourceNodeId(relationship.getSourceNodeName()); + ret.setSourceNodeName(relationship.getSourceNodeName()); + ret.setTargetNodeId(relationship.getTargetNodeName()); + ret.setTargetNodeName(relationship.getTargetNodeName()); + ret.setType(relationship.getType()); + retList.add(ret); + } + + return retList; + } + + private EnumTemplateType getTemplateType(ParseYamlResult result, List ntList) { + String type = getSubstitutionMappingType(result); + if (isNsType(type)) { + return EnumTemplateType.NS; + } + + if (isVnfType(type)) { + return EnumTemplateType.VNF; + } + + return getTemplateTypeFromNodeTemplates(ntList); + } + + private String getSubstitutionMappingType(ParseYamlResult result) { + if (result.getTopologyTemplate().getSubstitutionMappings() == null) { + return null; + } + return result.getTopologyTemplate().getSubstitutionMappings().getNodeType(); + } + + private EnumTemplateType getTemplateTypeFromNodeTemplates(List ntList) { + for (NodeTemplate nt : ntList) { + if (isNsType(nt.getType()) || isVnfType(nt.getType())) { + return EnumTemplateType.NS; + } + } + + return EnumTemplateType.VNF; + } + + private boolean isVnfType(String type) { + if (ToolUtil.isTrimedEmptyString(type)) { + return false; + } + return type.toUpperCase().contains(".VNF"); + } + + private boolean isNsType(String type) { + if (ToolUtil.isTrimedEmptyString(type)) { + return false; + } + return type.toUpperCase().contains(".NS"); + } +} -- cgit 1.2.3-korg