* ============LICENSE_END=========================================================
*/
-package org.openecomp.sdnc.config.params.transformer.tosca;
-
-import com.att.eelf.configuration.EELFLogger;
-import com.att.eelf.configuration.EELFManager;
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import com.fasterxml.jackson.dataformat.yaml.YAMLFactory;
-import org.apache.commons.lang.StringUtils;
-
-import org.openecomp.sdc.tosca.datatypes.model.*;
-import org.openecomp.sdc.tosca.services.YamlUtil;
-import org.openecomp.sdnc.config.params.data.Parameter;
-import org.openecomp.sdnc.config.params.data.PropertyDefinition;
-import org.openecomp.sdnc.config.params.data.RequestKey;
-import org.openecomp.sdnc.config.params.data.ResponseKey;
-import org.openecomp.sdnc.config.params.transformer.tosca.exceptions.ArtifactProcessorException;
-import org.slf4j.MDC;
+package org.onap.sdnc.config.params.transformer.tosca;
+import static com.att.eelf.configuration.Configuration.MDC_SERVICE_NAME;
import java.io.IOException;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.Iterator;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Map;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
+import org.apache.commons.lang.StringUtils;
+import org.onap.sdnc.config.params.data.Parameter;
+import org.onap.sdnc.config.params.data.PropertyDefinition;
+import org.onap.sdnc.config.params.data.RequestKey;
+import org.onap.sdnc.config.params.data.ResponseKey;
+import org.onap.sdnc.config.params.transformer.tosca.exceptions.ArtifactProcessorException;
+import org.openecomp.sdc.tosca.datatypes.model.NodeTemplate;
+import org.openecomp.sdc.tosca.datatypes.model.NodeType;
+import org.openecomp.sdc.tosca.datatypes.model.ServiceTemplate;
+import org.openecomp.sdc.tosca.datatypes.model.TopologyTemplate;
+import org.openecomp.sdc.tosca.services.YamlUtil;
+import org.slf4j.MDC;
+import com.att.eelf.configuration.EELFLogger;
+import com.att.eelf.configuration.EELFManager;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.dataformat.yaml.YAMLFactory;
-import static com.att.eelf.configuration.Configuration.MDC_SERVICE_NAME;
-
-public class ArtifactProcessorImpl implements ArtifactProcessor
-{
+public class ArtifactProcessorImpl implements ArtifactProcessor {
private static final String DERIVEDFROM = "org.openecomp.genericvnf";
- private static final EELFLogger Log = EELFManager.getInstance().getLogger(ArtifactProcessorImpl.class);
+ private static final EELFLogger Log =
+ EELFManager.getInstance().getLogger(ArtifactProcessorImpl.class);
private static final String EQUALSENCODING = "=";
private static final String COLONENCODING = ":";
private static final String COMMAENCODING = ",";
private static final String LESSTHANENCODING = "<";
@Override
- public void generateArtifact(PropertyDefinition artifact, OutputStream stream) throws ArtifactProcessorException
- {
+ public void generateArtifact(PropertyDefinition artifact, OutputStream stream)
+ throws ArtifactProcessorException {
MDC.clear();
- MDC.put(MDC_SERVICE_NAME,"ArtifactGenerator");
+ MDC.put(MDC_SERVICE_NAME, "ArtifactGenerator");
Log.info("Entered into generateArtifact");
- if(!StringUtils.isBlank(artifact.getKind())) {
+ if (!StringUtils.isBlank(artifact.getKind())) {
logArtifact(artifact);
ServiceTemplate serviceTemplate = new ServiceTemplate();
}
MDC.clear();
}
- }
- else
- {
+ } else {
Log.error("Kind in PropertyDefinition is blank or null");
throw new ArtifactProcessorException("Kind in PropertyDefinition is blank or null");
}
}
@Override
- public void generateArtifact(String artifact, OutputStream stream) throws ArtifactProcessorException
- {
+ public void generateArtifact(String artifact, OutputStream stream)
+ throws ArtifactProcessorException {
ObjectMapper mapper = new ObjectMapper(new YAMLFactory());
try {
PropertyDefinition pd = mapper.readValue(artifact, PropertyDefinition.class);
generateArtifact(pd, stream);
- }
- catch (IOException e)
- {
- Log.error("Error parsing property definition content = "+ artifact,e);
+ } catch (IOException e) {
+ Log.error("Error parsing property definition content = " + artifact, e);
throw new ArtifactProcessorException(e);
}
}
@Override
- public PropertyDefinition readArtifact(String toscaArtifact) throws ArtifactProcessorException{
+ public PropertyDefinition readArtifact(String toscaArtifact) throws ArtifactProcessorException {
Log.info("Entered into readArtifact.");
Log.info("Received ToscaArtifact:\n" + toscaArtifact);
PropertyDefinition propertyDefinitionObj = new PropertyDefinition();
- ServiceTemplate serviceTemplate = new YamlUtil().yamlToObject(toscaArtifact, ServiceTemplate.class);
+ ServiceTemplate serviceTemplate =
+ new YamlUtil().yamlToObject(toscaArtifact, ServiceTemplate.class);
- //mapping parameters
+ // mapping parameters
Map<String, NodeType> nodeTypeMap = serviceTemplate.getNode_types();
- Map<String, NodeTemplate> nodeTemplateMap = serviceTemplate.getTopology_template().getNode_templates();
+ Map<String, NodeTemplate> nodeTemplateMap =
+ serviceTemplate.getTopology_template().getNode_templates();
String nodeTemplateName = nodeTemplateMap.keySet().toArray(new String[0])[0];
NodeTemplate nodeTemplate = nodeTemplateMap.get(nodeTemplateName);
String kind = nodeTypeMap.keySet().toArray(new String[0])[0];
NodeType nodeType = nodeTypeMap.get(kind);
String version = nodeType.getVersion();
- Log.info("ReadArtifact for "+ kind + " with version "+version);
+ Log.info("ReadArtifact for " + kind + " with version " + version);
propertyDefinitionObj.setKind(kind);
propertyDefinitionObj.setVersion(version);
List<Parameter> parameterList = new LinkedList<>();
- Map<String, org.openecomp.sdc.tosca.datatypes.model.PropertyDefinition> propertyDefinitionFromTOSCA = nodeType.getProperties();
- if(null != propertyDefinitionFromTOSCA){
+ Map<String, org.openecomp.sdc.tosca.datatypes.model.PropertyDefinition> propertyDefinitionFromTOSCA =
+ nodeType.getProperties();
+ if (null != propertyDefinitionFromTOSCA) {
for (String propertyName : propertyDefinitionFromTOSCA.keySet()) {
- org.openecomp.sdc.tosca.datatypes.model.PropertyDefinition propertyDefinition = propertyDefinitionFromTOSCA.get(propertyName);
+ org.openecomp.sdc.tosca.datatypes.model.PropertyDefinition propertyDefinition =
+ propertyDefinitionFromTOSCA.get(propertyName);
Parameter parameter = new Parameter();
parameter.setName(propertyName);
String propertValueExpr = (String) nodeTemplateProperties.get(propertyName);
String[] stringTokens = parsePropertyValueExpression(propertValueExpr);
- String ruleType = stringTokens[0].substring(stringTokens[0].indexOf('=')+1,stringTokens[0].length()).replaceAll(">","").trim();
- String responseExpression = stringTokens[1].substring(stringTokens[1].indexOf('=')+1,stringTokens[1].length());
- String source = stringTokens[2].substring(stringTokens[2].indexOf('=')+1,stringTokens[2].length()).replaceAll(">","").trim();
- String requestExpression = stringTokens[3].substring(stringTokens[3].indexOf('=')+1,stringTokens[3].length());
+ String ruleType = stringTokens[0]
+ .substring(stringTokens[0].indexOf('=') + 1, stringTokens[0].length())
+ .replaceAll(">", "").trim();
+ String responseExpression = stringTokens[1]
+ .substring(stringTokens[1].indexOf('=') + 1, stringTokens[1].length());
+ String source = stringTokens[2]
+ .substring(stringTokens[2].indexOf('=') + 1, stringTokens[2].length())
+ .replaceAll(">", "").trim();
+ String requestExpression = stringTokens[3]
+ .substring(stringTokens[3].indexOf('=') + 1, stringTokens[3].length());
List<RequestKey> requestKeys = readRequestKeys(requestExpression);
List<ResponseKey> responseKeys = readResponseKeys(responseExpression);
return propertyDefinitionObj;
}
- private List<ResponseKey> readResponseKeys(String responseExpression) throws ArtifactProcessorException {
+ private List<ResponseKey> readResponseKeys(String responseExpression)
+ throws ArtifactProcessorException {
Log.info("Entered into readResponseKeys.");
List<ResponseKey> responseKeyList = null;
String expression;
for (String responseKeyStr : responseKeys) {
ResponseKey responseKey = new ResponseKey();
try {
- responseKey.setUniqueKeyName(responseKeyStr.split(":")[0].replaceAll(LESSTHANENCODING, "<").replaceAll(GREATERTHANENCODING, ">").replaceAll(COLONENCODING, ":").replaceAll(COMMAENCODING, ",").replaceAll(EQUALSENCODING,"=").trim());
- responseKey.setUniqueKeyValue(responseKeyStr.split(":")[1].replaceAll(LESSTHANENCODING, "<").replaceAll(GREATERTHANENCODING, ">").replaceAll(COLONENCODING, ":").replaceAll(COMMAENCODING, ",").replaceAll(EQUALSENCODING,"=").trim());
- responseKey.setFieldKeyName(responseKeyStr.split(":")[2].replaceAll(LESSTHANENCODING, "<").replaceAll(GREATERTHANENCODING, ">").replaceAll(COLONENCODING, ":").replaceAll(COMMAENCODING, ",").replaceAll(EQUALSENCODING,"=").trim());
+ responseKey.setUniqueKeyName(responseKeyStr.split(":")[0]
+ .replaceAll(LESSTHANENCODING, "<").replaceAll(GREATERTHANENCODING, ">")
+ .replaceAll(COLONENCODING, ":").replaceAll(COMMAENCODING, ",")
+ .replaceAll(EQUALSENCODING, "=").trim());
+ responseKey.setUniqueKeyValue(responseKeyStr.split(":")[1]
+ .replaceAll(LESSTHANENCODING, "<").replaceAll(GREATERTHANENCODING, ">")
+ .replaceAll(COLONENCODING, ":").replaceAll(COMMAENCODING, ",")
+ .replaceAll(EQUALSENCODING, "=").trim());
+ responseKey.setFieldKeyName(responseKeyStr.split(":")[2]
+ .replaceAll(LESSTHANENCODING, "<").replaceAll(GREATERTHANENCODING, ">")
+ .replaceAll(COLONENCODING, ":").replaceAll(COMMAENCODING, ",")
+ .replaceAll(EQUALSENCODING, "=").trim());
} catch (ArrayIndexOutOfBoundsException e) {
- Log.error("Invalid response attribute found :" + responseKeyStr + "due to "+e);
- throw new ArtifactProcessorException("Invalid response attribute found :" + responseKeyStr);
+ Log.error(
+ "Invalid response attribute found :" + responseKeyStr + "due to " + e);
+ throw new ArtifactProcessorException(
+ "Invalid response attribute found :" + responseKeyStr);
}
responseKeyList.add(responseKey);
}
Log.info("Entered into readRequestKeys.");
List<RequestKey> requestKeyList = null;
String expression;
- expression = requestExpression.replaceAll("<","").replaceAll(">","").trim();
- if(StringUtils.isNotEmpty(expression)){
+ expression = requestExpression.replaceAll("<", "").replaceAll(">", "").trim();
+ if (StringUtils.isNotEmpty(expression)) {
requestKeyList = new ArrayList<>();
String[] requestKeys = expression.split(",");
- for(String responseKeyStr :requestKeys){
+ for (String responseKeyStr : requestKeys) {
RequestKey requestKey = new RequestKey();
- requestKey.setKeyName(responseKeyStr.split(":")[0].replaceAll(LESSTHANENCODING, "<").replaceAll(GREATERTHANENCODING, ">").replaceAll(COLONENCODING,":").replaceAll(COMMAENCODING,",").replaceAll(EQUALSENCODING,"=").trim());
- requestKey.setKeyValue(responseKeyStr.split(":")[1].replaceAll(LESSTHANENCODING, "<").replaceAll(GREATERTHANENCODING, ">").replaceAll(COLONENCODING,":").replaceAll(COMMAENCODING,",").replaceAll(EQUALSENCODING,"=").trim());
+ requestKey.setKeyName(responseKeyStr.split(":")[0].replaceAll(LESSTHANENCODING, "<")
+ .replaceAll(GREATERTHANENCODING, ">").replaceAll(COLONENCODING, ":")
+ .replaceAll(COMMAENCODING, ",").replaceAll(EQUALSENCODING, "=").trim());
+ requestKey.setKeyValue(responseKeyStr.split(":")[1]
+ .replaceAll(LESSTHANENCODING, "<").replaceAll(GREATERTHANENCODING, ">")
+ .replaceAll(COLONENCODING, ":").replaceAll(COMMAENCODING, ",")
+ .replaceAll(EQUALSENCODING, "=").trim());
requestKeyList.add(requestKey);
}
}
return requestKeyList;
}
- private String[] parsePropertyValueExpression(String propertValueExpr) throws ArtifactProcessorException{
+ private String[] parsePropertyValueExpression(String propertValueExpr)
+ throws ArtifactProcessorException {
Log.info("Entered into parsePropertyValueExpression.");
String nodeRegex = "<(.*?)>";
Pattern pattern = Pattern.compile(nodeRegex, Pattern.CASE_INSENSITIVE);
Matcher matcher = pattern.matcher(propertValueExpr);
List<String> stringTokens = new ArrayList<>();
- while(matcher.find()){
+ while (matcher.find()) {
stringTokens.add(matcher.group(0));
}
String[] propertiesArr = new String[stringTokens.size()];
propertiesArr = stringTokens.toArray(propertiesArr);
- if(propertiesArr.length!=4){
+ if (propertiesArr.length != 4) {
throw new ArtifactProcessorException("Invalid input found " + propertValueExpr);
}
Log.info("Exiting from parsePropertyValueExpression.");
return propertiesArr;
}
- private void addNodeType(PropertyDefinition artifact, ServiceTemplate toscaTemplate) throws ArtifactProcessorException {
- //Add basic fields for the node
+ private void addNodeType(PropertyDefinition artifact, ServiceTemplate toscaTemplate)
+ throws ArtifactProcessorException {
+ // Add basic fields for the node
NodeType toscaNodeType = new NodeType();
toscaNodeType.setDerived_from(DERIVEDFROM);
toscaNodeType.setVersion(artifact.getVersion());
toscaNodeType.setDescription("");
- if(artifact.getParameters()!=null) {
- Map<String, org.openecomp.sdc.tosca.datatypes.model.PropertyDefinition> toscaPropertyMap = new HashMap<>();
+ if (artifact.getParameters() != null) {
+ Map<String, org.openecomp.sdc.tosca.datatypes.model.PropertyDefinition> toscaPropertyMap =
+ new HashMap<>();
toscaNodeType.setProperties(toscaPropertyMap);
- //Add properties from parameters of PD
+ // Add properties from parameters of PD
for (Parameter pdParameter : artifact.getParameters()) {
addProperty(toscaNodeType, pdParameter);
}
}
// This is where it adds node in node Map and adds the map in tosca template
- Map<String,NodeType> toscaNodeMap = new HashMap<>();
- toscaNodeMap.put(artifact.getKind(),toscaNodeType);
+ Map<String, NodeType> toscaNodeMap = new HashMap<>();
+ toscaNodeMap.put(artifact.getKind(), toscaNodeType);
toscaTemplate.setNode_types(toscaNodeMap);
}
- private void addProperty(NodeType toscaNodeType, Parameter pdParameter) throws ArtifactProcessorException {
- if(!StringUtils.isBlank(pdParameter.getName())&& !pdParameter.getName().matches(".*\\s+.*")) {
+ private void addProperty(NodeType toscaNodeType, Parameter pdParameter)
+ throws ArtifactProcessorException {
+ if (!StringUtils.isBlank(pdParameter.getName())
+ && !pdParameter.getName().matches(".*\\s+.*")) {
Log.info("Adding parameter " + pdParameter.getName() + " in node type");
- org.openecomp.sdc.tosca.datatypes.model.PropertyDefinition toscaProperty = new org.openecomp.sdc.tosca.datatypes.model.PropertyDefinition();
+ org.openecomp.sdc.tosca.datatypes.model.PropertyDefinition toscaProperty =
+ new org.openecomp.sdc.tosca.datatypes.model.PropertyDefinition();
- toscaProperty.setType(StringUtils.isBlank(pdParameter.getType()) ? "string" : pdParameter.getType());
+ toscaProperty.setType(
+ StringUtils.isBlank(pdParameter.getType()) ? "string" : pdParameter.getType());
toscaProperty.set_default(pdParameter.getDefaultValue());
toscaProperty.setDescription(pdParameter.getDescription());
toscaProperty.setRequired(pdParameter.isRequired());
toscaNodeType.getProperties().put(pdParameter.getName(), toscaProperty);
- }
- else
- {
- String message ="Parameter name is empty,null or contains whitespace";
+ } else {
+ String message = "Parameter name is empty,null or contains whitespace";
Log.error(message);
throw new ArtifactProcessorException(message);
}
}
- private void addNodeTemplate(PropertyDefinition artifact, ServiceTemplate toscaTemplate)
- {
+ private void addNodeTemplate(PropertyDefinition artifact, ServiceTemplate toscaTemplate) {
NodeTemplate nodeTemplate = new NodeTemplate();
nodeTemplate.setType(artifact.getKind());
- Map<String,Object> templateProperties = new HashMap<>();
- //Add properties from parameters of PD
- if(artifact.getParameters()!=null) {
+ Map<String, Object> templateProperties = new HashMap<>();
+ // Add properties from parameters of PD
+ if (artifact.getParameters() != null) {
for (Parameter pdParameter : artifact.getParameters()) {
addTemplateProperty(templateProperties, pdParameter);
}
nodeTemplate.setProperties(templateProperties);
}
- Map<String,NodeTemplate> nodeTemplateMap = new HashMap<>();
- nodeTemplateMap.put(artifact.getKind()+"_Template",nodeTemplate);
+ Map<String, NodeTemplate> nodeTemplateMap = new HashMap<>();
+ nodeTemplateMap.put(artifact.getKind() + "_Template", nodeTemplate);
toscaTemplate.getTopology_template().setNode_templates(nodeTemplateMap);
}
- private void addTemplateProperty(Map<String,Object> templateProperties, Parameter pdParameter)
- {
- Log.info("Adding parameter "+ pdParameter.getName() + " in node templates");
+ private void addTemplateProperty(Map<String, Object> templateProperties,
+ Parameter pdParameter) {
+ Log.info("Adding parameter " + pdParameter.getName() + " in node templates");
String responseKeys = buildResponseKeyExpression(pdParameter.getResponseKeys());
String requestKeys = buildRequestKeyExpression(pdParameter.getRequestKeys());
String ruleType = buildRuleType(pdParameter.getRuleType());
String source = buildSourceSystem(pdParameter.getSource());
String properties = ruleType + " " + responseKeys + " " + source + " " + requestKeys;
- templateProperties.put(pdParameter.getName(),properties);
+ templateProperties.put(pdParameter.getName(), properties);
}
- protected String buildResponseKeyExpression(List<ResponseKey> responseKeys)
- {
+ protected String buildResponseKeyExpression(List<ResponseKey> responseKeys) {
StringBuilder propertyBuilder = new StringBuilder();
propertyBuilder.append("<response-keys = ");
- if(responseKeys!=null) {
+ if (responseKeys != null) {
Iterator<ResponseKey> itr = responseKeys.iterator();
while (itr.hasNext()) {
ResponseKey res = itr.next();
- if(res!=null)
- propertyBuilder.append(encode(res.getUniqueKeyName()) + ":" + encode(res.getUniqueKeyValue()) + ":" + encode(res.getFieldKeyName()));
+ if (res != null)
+ propertyBuilder.append(
+ encode(res.getUniqueKeyName()) + ":" + encode(res.getUniqueKeyValue())
+ + ":" + encode(res.getFieldKeyName()));
if (itr.hasNext())
propertyBuilder.append(" , ");
}
return propertyBuilder.toString();
}
- protected String buildRequestKeyExpression(List<RequestKey> requestKeys)
- {
+ protected String buildRequestKeyExpression(List<RequestKey> requestKeys) {
StringBuilder propertyBuilder = new StringBuilder();
propertyBuilder.append("<request-keys = ");
- if(requestKeys!=null) {
+ if (requestKeys != null) {
Iterator<RequestKey> itr = requestKeys.iterator();
while (itr.hasNext()) {
RequestKey res = itr.next();
- if(res!=null)
- propertyBuilder.append(encode(res.getKeyName()) + ":" + encode(res.getKeyValue()));
+ if (res != null)
+ propertyBuilder
+ .append(encode(res.getKeyName()) + ":" + encode(res.getKeyValue()));
if (itr.hasNext())
propertyBuilder.append(" , ");
}
return propertyBuilder.toString();
}
- protected String buildRuleType(String classType)
- {
+ protected String buildRuleType(String classType) {
StringBuilder propertyBuilder = new StringBuilder();
- String encodedClassType = StringUtils.isBlank(encode(classType))?"":encode(classType);
+ String encodedClassType = StringUtils.isBlank(encode(classType)) ? "" : encode(classType);
propertyBuilder.append("<");
- propertyBuilder.append("rule-type = "+encodedClassType);
+ propertyBuilder.append("rule-type = " + encodedClassType);
propertyBuilder.append(">");
return propertyBuilder.toString();
}
- protected String buildSourceSystem(String source)
- {
+ protected String buildSourceSystem(String source) {
StringBuilder sourceBuilder = new StringBuilder();
sourceBuilder.append("<source-system = ");
- sourceBuilder.append(StringUtils.isBlank(encode(source))?"":encode(source));
+ sourceBuilder.append(StringUtils.isBlank(encode(source)) ? "" : encode(source));
sourceBuilder.append(">");
return sourceBuilder.toString();
}
- protected String encode(String string)
- {
+ protected String encode(String string) {
String encodedString = null;
- if(string!=null) {
- encodedString = string.trim().replaceAll("<", "<").replaceAll(">", ">").replaceAll(":",":").replaceAll(",",",").replaceAll("=","=");
+ if (string != null) {
+ encodedString = string.trim().replaceAll("<", "<").replaceAll(">", ">")
+ .replaceAll(":", ":").replaceAll(",", ",")
+ .replaceAll("=", "=");
}
return encodedString;
}
- private void logArtifact(PropertyDefinition artifact)
- {
+ private void logArtifact(PropertyDefinition artifact) {
ObjectMapper mapper = new ObjectMapper(new YAMLFactory());
- String stringArtifact=null;
- try
- {
+ String stringArtifact = null;
+ try {
stringArtifact = mapper.writeValueAsString(artifact);
Log.info("Received PropertyDefinition:\n" + stringArtifact);
- }
- catch (JsonProcessingException e)
- {
- Log.error("Exception while logging artifact:",e);
+ } catch (JsonProcessingException e) {
+ Log.error("Exception while logging artifact:", e);
}
}
Code Review / appc.git / blobdiff