diff options
author | 2016-09-08 09:58:30 +0800 | |
---|---|---|
committer | 2016-09-08 09:58:30 +0800 | |
commit | 51f0574fe68c87f5e5f9fed2875d9e45ab6cdf7e (patch) | |
tree | 97fcb1edf22e7cb9e75034b3d60881e7ca62bc75 /catalog-core/catalog-mgr/src | |
parent | 0a57e28d2f48fb4a70664fa96e0c978ad30eb4ab (diff) |
Change java.io.File.deleteOnExit() to java.io.File.delete(). For the latter id more stable.
Change-Id: I52c6982fd1fbfcd9146f7a80ccf9f4cf16feba3f
Signed-off-by: YuanHu <yuan.hu1@zte.com.cn>
Diffstat (limited to 'catalog-core/catalog-mgr/src')
-rw-r--r-- | catalog-core/catalog-mgr/src/main/java/org/openo/commontosca/catalog/model/parser/ToscaYamlModelParser.java | 830 |
1 files changed, 415 insertions, 415 deletions
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<String, String> 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<NodeTemplate> 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<String, String> parseToscaMeta(String fileLocation) throws CatalogResourceException {
- Map<String, String> 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<Input> inputList = result.getTopologyTemplate().getInputs();
- if (inputList == null) {
- return new InputParameter[0];
- }
- List<InputParameter> retList = new ArrayList<InputParameter>();
- 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<Output> outputList = result.getTopologyTemplate().getOutputs();
- if (outputList == null || outputList.isEmpty()) {
- return new OutputParameter[0];
- }
- List<OutputParameter> retList = new ArrayList<OutputParameter>();
- for (Output output : outputList) {
- retList
- .add(new OutputParameter(output.getName(), output.getDescription(), output.getValue()));
- }
- return retList.toArray(new OutputParameter[0]);
- }
-
- private ServiceTemplateOperation[] parseOperations(List<Plan> planList, String zipFileLocation)
- throws CatalogResourceException {
- if (planList == null || planList.isEmpty()) {
- return new ServiceTemplateOperation[0];
- }
-
- List<ServiceTemplateOperation> 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<PlanInput> inputList) {
- if (inputList == null || inputList.isEmpty()) {
- return new InputParameter[0];
- }
-
- List<InputParameter> 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<NodeTemplate> parseNodeTemplates(String csarId, String templateId,
- ParseYamlResult result) {
- List<ParseYamlResult.TopologyTemplate.NodeTemplate> nodetemplateList =
- result.getTopologyTemplate().getNodeTemplates();
- if (nodetemplateList == null) {
- return null;
- }
-
- List<NodeTemplate> 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<RelationShip> relationShipList =
- parseNodeTemplateRelationShip(nodeTemplate.getRelationships());
- ret.setRelationShips(relationShipList);
-
- retList.add(ret);
- }
-
- return retList;
- }
-
-
- private List<RelationShip> parseNodeTemplateRelationShip(List<Relationship> relationshipList) {
- List<RelationShip> 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<NodeTemplate> 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<NodeTemplate> 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<String, String> 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<NodeTemplate> 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<String, String> parseToscaMeta(String fileLocation) throws CatalogResourceException { + Map<String, String> 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<Input> inputList = result.getTopologyTemplate().getInputs(); + if (inputList == null) { + return new InputParameter[0]; + } + List<InputParameter> retList = new ArrayList<InputParameter>(); + 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<Output> outputList = result.getTopologyTemplate().getOutputs(); + if (outputList == null || outputList.isEmpty()) { + return new OutputParameter[0]; + } + List<OutputParameter> retList = new ArrayList<OutputParameter>(); + for (Output output : outputList) { + retList + .add(new OutputParameter(output.getName(), output.getDescription(), output.getValue())); + } + return retList.toArray(new OutputParameter[0]); + } + + private ServiceTemplateOperation[] parseOperations(List<Plan> planList, String zipFileLocation) + throws CatalogResourceException { + if (planList == null || planList.isEmpty()) { + return new ServiceTemplateOperation[0]; + } + + List<ServiceTemplateOperation> 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<PlanInput> inputList) { + if (inputList == null || inputList.isEmpty()) { + return new InputParameter[0]; + } + + List<InputParameter> 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<NodeTemplate> parseNodeTemplates(String csarId, String templateId, + ParseYamlResult result) { + List<ParseYamlResult.TopologyTemplate.NodeTemplate> nodetemplateList = + result.getTopologyTemplate().getNodeTemplates(); + if (nodetemplateList == null) { + return null; + } + + List<NodeTemplate> 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<RelationShip> relationShipList = + parseNodeTemplateRelationShip(nodeTemplate.getRelationships()); + ret.setRelationShips(relationShipList); + + retList.add(ret); + } + + return retList; + } + + + private List<RelationShip> parseNodeTemplateRelationShip(List<Relationship> relationshipList) { + List<RelationShip> 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<NodeTemplate> 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<NodeTemplate> 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"); + } +} |