import org.openecomp.sdc.common.errors.CoreException;
import org.openecomp.sdc.common.errors.ErrorCategory;
import org.openecomp.sdc.common.errors.ErrorCode;
-import org.openecomp.sdc.logging.context.impl.MdcDataDebugMessage;
import java.util.Optional;
private static final UniqueValueDao uniqueValueDao =
UniqueValueDaoFactory.getInstance().createInterface();
- private static MdcDataDebugMessage mdcDataDebugMessage = new MdcDataDebugMessage();
-
/**
* Create unique value.
*
* @param uniqueCombination the unique combination
*/
public static void createUniqueValue(String type, String... uniqueCombination) {
- mdcDataDebugMessage.debugEntryMessage(null);
-
Optional<String> value = formatValue(uniqueCombination);
if (!value.isPresent()) {
return;
}
validateUniqueValue(type, value.get(), uniqueCombination);
uniqueValueDao.create(new UniqueValueEntity(type, value.get()));
-
- mdcDataDebugMessage.debugExitMessage(null);
}
/**
* @param uniqueCombination the unique combination
*/
public static void deleteUniqueValue(String type, String... uniqueCombination) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
Optional<String> value = formatValue(uniqueCombination);
if (!value.isPresent()) {
return;
}
uniqueValueDao.delete(new UniqueValueEntity(type, value.get()));
-
- mdcDataDebugMessage.debugExitMessage(null);
}
/**
*/
public static void updateUniqueValue(String type, String oldValue, String newValue,
String... uniqueContext) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (newValue == null || oldValue == null || !newValue.equalsIgnoreCase(oldValue)) {
createUniqueValue(type, CommonMethods.concat(uniqueContext, new String[]{newValue}));
deleteUniqueValue(type, CommonMethods.concat(uniqueContext, new String[]{oldValue}));
}
-
- mdcDataDebugMessage.debugExitMessage(null);
}
/**
* @param uniqueCombination the unique combination
*/
public static void validateUniqueValue(String type, String... uniqueCombination) {
- mdcDataDebugMessage.debugEntryMessage(null);
-
Optional<String> value = formatValue(uniqueCombination);
if (!value.isPresent()) {
return;
}
validateUniqueValue(type, value.get(), uniqueCombination);
-
- mdcDataDebugMessage.debugExitMessage(null);
}
private static void validateUniqueValue(String type, String value, String... uniqueCombination) {
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (uniqueValueDao.get(new UniqueValueEntity(type, value)) != null) {
throw new CoreException(new ErrorCode.ErrorCodeBuilder()
.withCategory(ErrorCategory.APPLICATION)
.withMessage(String.format(UNIQUE_VALUE_VIOLATION_MSG, type,
uniqueCombination[uniqueCombination.length - 1])).build());
}
-
- mdcDataDebugMessage.debugExitMessage(null);
}
private static Optional<String> formatValue(String[] uniqueCombination) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (uniqueCombination == null || uniqueCombination.length == 0
|| uniqueCombination[uniqueCombination.length - 1] == null) {
return Optional.empty();
uniqueCombination[uniqueCombination.length - 1] =
uniqueCombination[uniqueCombination.length - 1].toLowerCase();
-
- mdcDataDebugMessage.debugExitMessage(null);
return Optional.of(CommonMethods.arrayToSeparatedString(uniqueCombination, '_'));
}
}
import org.openecomp.sdc.heat.datatypes.model.PropertiesMapKeyTypes;
import org.openecomp.sdc.heat.datatypes.model.Resource;
import org.openecomp.sdc.heat.services.HeatStructureUtil;
-import org.openecomp.sdc.logging.context.impl.MdcDataDebugMessage;
import org.openecomp.sdc.logging.types.LoggerTragetServiceName;
import java.util.Collection;
public class HeatTreeManagerUtil {
private static final String TYPE = "type";
- private static final MdcDataDebugMessage MDC_DATA_DEBUG_MESSAGE = new MdcDataDebugMessage();
private HeatTreeManagerUtil() {
}
*/
public static Set<String> getNestedFiles(String filename, HeatOrchestrationTemplate hot,
GlobalValidationContext globalContext) {
-
- MDC_DATA_DEBUG_MESSAGE.debugEntryMessage(null, null);
-
Set<String> nestedFileList = new HashSet<>();
hot.getResources().values().stream().filter(
resource -> resource.getType().endsWith(".yaml") || resource.getType().endsWith(".yml"))
Set<String> resourceDefNestedFiles = getResourceDefNestedFiles(hot);
nestedFileList.addAll(resourceDefNestedFiles);
-
- MDC_DATA_DEBUG_MESSAGE.debugExitMessage(null, null);
return nestedFileList;
}
*/
public static Set<String> getArtifactFiles(String filename, HeatOrchestrationTemplate hot,
GlobalValidationContext globalContext) {
-
- MDC_DATA_DEBUG_MESSAGE.debugEntryMessage(null, null);
-
Set<String> artifactSet = new HashSet<>();
Collection<Resource> resourcesValue =
hot.getResources() == null ? null : hot.getResources().values();
filename, globalContext);
}
}
-
- MDC_DATA_DEBUG_MESSAGE.debugExitMessage(null, null);
return artifactSet;
}
}
private static Set<String> getResourceDefNestedFiles(HeatOrchestrationTemplate hot) {
-
- MDC_DATA_DEBUG_MESSAGE.debugEntryMessage(null, null);
-
Set<String> resourceDefNestedFiles = new HashSet<>();
hot.getResources()
.entrySet().stream().filter(entry -> entry.getValue().getType()
.getType()))
.forEach(entry -> resourceDefNestedFiles.add(
getResourceDef( entry.getValue()).getType()));
-
- MDC_DATA_DEBUG_MESSAGE.debugExitMessage(null, null);
return resourceDefNestedFiles;
}
*/
@SuppressWarnings("unchecked")
public static Resource getResourceDef( Resource resource) {
-
- MDC_DATA_DEBUG_MESSAGE.debugEntryMessage(null, null);
-
Resource resourceDef = null;
Map<String, Object> resourceDefValueMap = resource.getProperties() == null ? null
: (Map<String, Object>) resource.getProperties().get(
}
}
-
- MDC_DATA_DEBUG_MESSAGE.debugExitMessage(null, null);
return resourceDef;
}
import org.openecomp.sdc.heat.services.tree.HeatTreeManagerUtil;
import org.openecomp.sdc.logging.api.Logger;
import org.openecomp.sdc.logging.api.LoggerFactory;
-import org.openecomp.sdc.logging.context.impl.MdcDataDebugMessage;
import org.openecomp.sdc.logging.context.impl.MdcDataErrorMessage;
import org.openecomp.sdc.logging.types.LoggerConstants;
import org.openecomp.sdc.logging.types.LoggerErrorCode;
private static final Logger LOGGER = LoggerFactory.getLogger(HeatToToscaUtil.class);
public static final String FQ_NAME = "fq_name";
public static final String GET_PARAM = "get_param";
- protected static MdcDataDebugMessage mdcDataDebugMessage = new MdcDataDebugMessage();
private static final String FORWARDER = "forwarder";
private static final String GET_ATTR = "get_attr";
private static final String GET_RESOURCE = "get_resource";
*/
public static TranslatorOutput loadAndTranslateTemplateData(
FileContentHandler fileNameContentMap) {
- mdcDataDebugMessage.debugEntryMessage(null, null);
HeatToToscaTranslator heatToToscaTranslator =
HeatToToscaTranslatorFactory.getInstance().createInterface();
try (InputStream structureFile = getHeatStructureTreeFile(fileNameContentMap)) {
heatToToscaTranslator.addExternalArtifacts(SdcCommon.HEAT_META, structureFile);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return heatToToscaTranslator.translate();
} catch (IOException e) {
// rethrow as a RuntimeException to keep the signature backward compatible
FileDataCollection fileDataCollection,
Map<String, FileData> filteredFiles, Set<String> referenced,
String nestedFileName) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
referenced.add(nestedFileName);
fileDataCollection.addNestedFiles(filteredFiles.get(nestedFileName));
translationContext.getNestedHeatsFiles().add(nestedFileName);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private static Map<String, FileData> filterFileDataListByType(List<FileData> fileDataList,
*/
public static Optional<AttachedResourceId> extractAttachedResourceId(TranslateTo translateTo,
String propertyName) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Object propertyValue = translateTo.getResource().getProperties().get(propertyName);
if (propertyValue == null) {
return Optional.empty();
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return extractAttachedResourceId(translateTo.getHeatFileName(),
translateTo.getHeatOrchestrationTemplate(), translateTo.getContext(), propertyValue);
}
*/
public static Optional<String> getContrailAttachedHeatResourceId(
AttachedResourceId attachedResource) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
if (attachedResource == null) {
return Optional.empty();
}
if (attachedResource.isGetAttr()) {
return getResourceId(attachedResource.getEntityId());
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return Optional.empty();
}
* @return the optional
*/
public static Optional<AttachedPropertyVal> extractProperty(Object propertyValue) {
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
Object attachedPropertyVal;
if (Objects.isNull(propertyValue)) {
return Optional.empty();
} else {
attachedPropertyVal = propertyValue;
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return Optional.of(new AttachedPropertyVal(attachedPropertyVal, referenceType));
}
* @param propertyKey the property key
*/
public static void mapBoolean(NodeTemplate nodeTemplate, String propertyKey) {
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Object value = nodeTemplate.getProperties().get(propertyKey);
if (value != null && !(value instanceof Map)) {
nodeTemplate.getProperties().put(propertyKey, HeatBoolean.eval(value));
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
/**
* @return the boolean
*/
public static boolean isNestedResource(Resource resource) {
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
String resourceType = resource.getType();
if (resourceType.equals(HeatResourcesTypes.RESOURCE_GROUP_RESOURCE_TYPE.getHeatResource())) {
} else if (isYamlFile(resourceType)) {
return true;
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return false;
}
* @return true if the resource represents a VFC and false otherwise.
*/
public static boolean isNestedVfcResource(Resource resource, TranslationContext context) {
- mdcDataDebugMessage.debugEntryMessage(null, null);
Optional<String> nestedHeatFileName = HeatToToscaUtil.getNestedHeatFileName(resource);
HeatOrchestrationTemplate nestedHeatOrchestrationTemplate = new YamlUtil()
.yamlToObject(context.getFileContent(nestedHeatFileName.get()),
}
}
}
- mdcDataDebugMessage.debugExitMessage(null, null);
return false;
}
* @return the nested heat file name
*/
public static Optional<String> getNestedHeatFileName(Resource resource) {
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
if (!isNestedResource(resource)) {
return Optional.empty();
}
String internalResourceType = (String) ((Map) resourceDef).get("type");
return Optional.of(internalResourceType);
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return Optional.of(resourceType);
}
* @return the nested file
*/
public static Optional<String> getNestedFile(Resource resource) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
if (!isNestedResource(resource)) {
return Optional.empty();
}
if (resourceType.equals(HeatResourcesTypes.RESOURCE_GROUP_RESOURCE_TYPE.getHeatResource())) {
Object resourceDef = resource.getProperties().get(HeatConstants.RESOURCE_DEF_PROPERTY_NAME);
String internalResourceType = (String) ((Map) resourceDef).get("type");
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return Optional.of(internalResourceType);
} else {
- mdcDataDebugMessage.debugExitMessage(null, null);
return Optional.of(resourceType);
}
}
*/
public static Resource getResource(HeatOrchestrationTemplate heatOrchestrationTemplate,
String resourceId, String heatFileName) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Resource resource = heatOrchestrationTemplate.getResources().get(resourceId);
if (resource == null) {
MdcDataErrorMessage.createErrorMessageAndUpdateMdc(LoggerConstants.TARGET_ENTITY_DB,
throw new CoreException(
new ResourceNotFoundInHeatFileErrorBuilder(resourceId, heatFileName).build());
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return resource;
}
public static String getResourceType(String resourceId,
HeatOrchestrationTemplate heatOrchestrationTemplate,
String heatFileName) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return HeatToToscaUtil.getResource(heatOrchestrationTemplate, resourceId, heatFileName)
.getType();
}
*/
public static Optional<String> extractContrailGetResourceAttachedHeatResourceId(
Object propertyValue) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
if (propertyValue instanceof Map) {
if (((Map) propertyValue).containsKey(GET_ATTR)) {
return getResourceId(((Map) propertyValue).get(GET_ATTR));
} else if (propertyValue instanceof List) {
return evaluateHeatResourceId((List) propertyValue);
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return Optional.empty();
}
* @return the tosca service model
*/
public static ToscaServiceModel getToscaServiceModel(TranslationContext context) {
- mdcDataDebugMessage.debugEntryMessage(null, null);
- mdcDataDebugMessage.debugExitMessage(null, null);
-
Map<String, String> metadata = new HashMap<>();
metadata.put(ToscaConstants.ST_METADATA_TEMPLATE_NAME, Constants.MAIN_TEMPLATE_NAME);
return getToscaServiceModel(context, metadata);
public static ToscaServiceModel getToscaServiceModel(
TranslationContext context,
Map<String, String> entryDefinitionMetadata) {
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Map<String, ServiceTemplate> serviceTemplates =
new HashMap<>(context.getGlobalServiceTemplates());
Collection<ServiceTemplate> tmpServiceTemplates =
for (ServiceTemplate serviceTemplate : tmpServiceTemplates) {
ToscaUtil.addServiceTemplateToMapWithKeyFileName(serviceTemplates, serviceTemplate);
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return new ToscaServiceModel(null, serviceTemplates,
ToscaUtil.getServiceTemplateFileName(entryDefinitionMetadata));
}
*/
public static Optional<ServiceTemplate> getServiceTemplateFromContext(
String serviceTemplateFileName, TranslationContext context) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
for (ServiceTemplate serviceTemplate : context.getTranslatedServiceTemplates().values()) {
if (ToscaUtil.getServiceTemplateFileName(serviceTemplate).equals(serviceTemplateFileName)) {
- mdcDataDebugMessage.debugExitMessage(null, null);
return Optional.of(serviceTemplate);
}
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return Optional.empty();
}
*/
public static RequirementAssignment addLinkReqFromPortToNetwork(NodeTemplate portNodeTemplate,
String networkTranslatedId) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
RequirementAssignment requirement = new RequirementAssignment();
requirement.setCapability(ToscaCapabilityType.NATIVE_NETWORK_LINKABLE);
requirement.setRelationship(ToscaRelationshipType.NATIVE_NETWORK_LINK_TO);
requirement.setNode(networkTranslatedId);
DataModelUtil.addRequirementAssignment(portNodeTemplate,
ToscaConstants.LINK_REQUIREMENT_ID, requirement);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
-
return requirement;
}
*/
public static void addBindingReqFromSubInterfaceToInterface(
NodeTemplate subInterfaceNodeTemplate, String interfaceTranslatedId) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
RequirementAssignment requirement = new RequirementAssignment();
requirement.setCapability(ToscaCapabilityType.NATIVE_NETWORK_BINDABLE);
requirement.setRelationship(ToscaRelationshipType.NATIVE_NETWORK_BINDS_TO);
DataModelUtil
.addRequirementAssignment(subInterfaceNodeTemplate,
ToscaConstants.BINDING_REQUIREMENT_ID, requirement);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
/**
private Map<String, PropertyDefinition> manageSubstitutionNodeTypeProperties(
ServiceTemplate substitutionServiceTemplate) {
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Map<String, PropertyDefinition> substitutionNodeTypeProperties = new HashMap<>();
Map<String, ParameterDefinition> properties =
substitutionServiceTemplate.getTopology_template().getInputs();
if (properties == null) {
- mdcDataDebugMessage.debugExitMessage(null, null);
return null;
}
propertyDefinition.setStatus(parameterDefinition.getStatus());
substitutionNodeTypeProperties.put(toscaPropertyName, propertyDefinition);
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return substitutionNodeTypeProperties;
}
private Map<String, AttributeDefinition> manageSubstitutionNodeTypeAttributes(
ServiceTemplate substitutionServiceTemplate) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Map<String, AttributeDefinition> substitutionNodeTypeAttributes = new HashMap<>();
Map<String, ParameterDefinition> attributes =
substitutionServiceTemplate.getTopology_template().getOutputs();
if (attributes == null) {
- mdcDataDebugMessage.debugExitMessage(null, null);
return null;
}
AttributeDefinition attributeDefinition;
attributeDefinition.setStatus(parameterDefinition.getStatus());
substitutionNodeTypeAttributes.put(toscaAttributeName, attributeDefinition);
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return substitutionNodeTypeAttributes;
}
TranslateTo translateTo,
Template template,
String templateName) {
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Map<String, Object> substitutionProperties = new HashMap<>();
Map<String, Object> heatProperties = translateTo.getResource().getProperties();
if (Objects.nonNull(heatProperties)) {
substitutionProperties.put(entry.getKey(), property);
}
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return addAbstractSubstitutionProperty(templateName, substitutionProperties);
}
private static Map<String, Object> addAbstractSubstitutionProperty(String templateName,
Map<String, Object>
substitutionProperties) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Map<String, Object> innerProps = new HashMap<>();
innerProps.put(ToscaConstants.SUBSTITUTE_SERVICE_TEMPLATE_PROPERTY_NAME,
ToscaUtil.getServiceTemplateFileName(templateName));
substitutionProperties.put(ToscaConstants.SERVICE_TEMPLATE_FILTER_PROPERTY_NAME, innerProps);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return substitutionProperties;
}
getSubstitutionNodeTypeExposedConnectionPoints(NodeType substitutionNodeType,
ServiceTemplate substitutionServiceTemplate,
TranslationContext context) {
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Map<String, NodeTemplate> nodeTemplates =
substitutionServiceTemplate.getTopology_template().getNode_templates();
String nodeTemplateId;
toscaAnalyzerService.calculateExposedCapabilities(nodeTypeCapabilitiesDefinition,
fullFilledRequirementsDefinition);
DataModelUtil.addNodeTypeCapabilitiesDef(substitutionNodeType, exposedCapabilitiesDefinition);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return substitutionMapping;
}
Map<String, CapabilityDefinition> nodeTypeCapabilitiesDefinition,
Map<String, List<String>> capabilitySubstitutionMapping, String type, String templateName,
ServiceTemplate serviceTemplate, TranslationContext context) {
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
NodeType flatNodeType =
getNodeTypeWithFlatHierarchy(type, serviceTemplate, context);
addCapabilityToSubMapping(
templateName, capabilityNodeEntry, nodeTypeCapabilitiesDefinition, capabilitySubstitutionMapping));
}
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private static boolean shouldCapabilityNeedsToBeAdded(String capabilityKey) {
ServiceTemplate serviceTemplate,
Map<String, List<String>> requirementSubstitutionMapping,
TranslationContext context) {
- mdcDataDebugMessage.debugEntryMessage(null, null);
List<Map<String, RequirementDefinition>> requirementList = new ArrayList<>();
NodeType flatNodeType = getNodeTypeWithFlatHierarchy(type, serviceTemplate, context);
List<String> requirementMapping;
}
}
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return requirementList;
}
public static ToscaServiceModel createToscaServiceModel(ServiceTemplate
entryDefinitionServiceTemplate,
TranslationContext translationContext) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return new ToscaServiceModel(getCsarArtifactFiles(translationContext),
getServiceTemplates(translationContext),
ToscaUtil.getServiceTemplateFileName(entryDefinitionServiceTemplate));
}
private static FileContentHandler getCsarArtifactFiles(TranslationContext translationContext) {
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
FileContentHandler artifactFiles = new FileContentHandler();
artifactFiles.setFiles(translationContext.getFiles());
artifactFiles.setFiles(translationContext.getExternalArtifacts());
byte[] validationStructureFile =
FileUtils.convertToBytes(validationStructureList, FileUtils.FileExtension.JSON);
artifactFiles.addFile("HEAT.meta", validationStructureFile);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return artifactFiles;
}
private static Map<String, ServiceTemplate> getServiceTemplates(TranslationContext
translationContext) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
List<ServiceTemplate> serviceTemplates = new ArrayList<>();
serviceTemplates.addAll(GlobalTypesGenerator
.getGlobalTypesServiceTemplate(OnboardingTypesEnum.ZIP).values());
for (ServiceTemplate template : serviceTemplates) {
serviceTemplatesMap.put(ToscaUtil.getServiceTemplateFileName(template), template);
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return serviceTemplatesMap;
}
import org.openecomp.sdc.heat.datatypes.model.Resource;
import org.openecomp.sdc.logging.api.Logger;
import org.openecomp.sdc.logging.api.LoggerFactory;
-import org.openecomp.sdc.logging.context.impl.MdcDataDebugMessage;
import org.openecomp.sdc.logging.context.impl.MdcDataErrorMessage;
import org.openecomp.sdc.logging.types.LoggerConstants;
import org.openecomp.sdc.logging.types.LoggerErrorCode;
public class TranslationService {
protected static Logger logger = (Logger) LoggerFactory.getLogger(TranslationService.class);
- protected static MdcDataDebugMessage mdcDataDebugMessage = new MdcDataDebugMessage();
-
/**
* Gets types to process by translator.
*
* @return the translator output
*/
public TranslatorOutput translateHeatFiles(TranslationContext translationContext) {
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
ServiceTemplate mainServiceTemplate = createMainServiceTemplate(translationContext);
List<FileData> fileDataList = translationContext.getManifest().getContent().getData();
FileDataCollection fileDataCollection = HeatToToscaUtil.getFileCollectionsByFilter(fileDataList,
translatorOutput.setNonUnifiedToscaServiceModel(
ToscaServiceModel.getClonedServiceModel(toscaServiceModel));
translatorOutput.setToscaServiceModel(toscaServiceModel);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return translatorOutput;
}
private ServiceTemplate createMainServiceTemplate(TranslationContext translationContext) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
ServiceTemplate mainServiceTemplate = new ServiceTemplate();
translationContext.getTranslatedServiceTemplates()
.put(Constants.MAIN_TEMPLATE_NAME, mainServiceTemplate);
mainServiceTemplate.setMetadata(templateMetadata);
mainServiceTemplate.setTopology_template(new TopologyTemplate());
mainServiceTemplate.setImports(GlobalTypesGenerator.getGlobalTypesImportList());
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return mainServiceTemplate;
}
*/
public void translateHeatFile(ServiceTemplate serviceTemplate, FileData heatFileData,
TranslationContext context) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
String heatFileName = heatFileData.getFile();
HeatOrchestrationTemplate heatOrchestrationTemplate = new YamlUtil()
.yamlToObject(context.getFileContent(heatFileName), HeatOrchestrationTemplate.class);
heatFileData.getData().stream().filter(data -> data.getType() == FileData.Type.HEAT_VOL)
.forEach(data -> translateHeatFile(serviceTemplate, data, context));
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void handleHeatPseudoParam(String heatFileName, ServiceTemplate serviceTemplate,
private void createHeatStackGroup(ServiceTemplate serviceTemplate, FileData heatFileData,
HeatOrchestrationTemplate heatOrchestrationTemplate,
TranslationContext context) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
ToscaFileOutputService toscaFileOutputService = new ToscaFileOutputServiceCsarImpl();
final String fileName = heatFileData.getFile();
final String heatStackGroupId = FileUtils.getFileWithoutExtention(fileName) + "_group";
groupDefinition.getMembers().addAll(heatStackGroupMembersIds);
DataModelUtil
.addGroupDefinitionToTopologyTemplate(serviceTemplate, heatStackGroupId, groupDefinition);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private Set<String> getHeatStackGroupMembers(String heatFileName,
HeatOrchestrationTemplate heatOrchestrationTemplate,
FileData heatFileData, TranslationContext context,
String heatFileName) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
if (heatOrchestrationTemplate.getParameters() == null) {
return;
}
} else {
inputs.putAll(parameterDefinitionMap);
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void translateOutputParameters(ServiceTemplate serviceTemplate,
HeatOrchestrationTemplate heatOrchestrationTemplate,
FileData heatFileData, String heatFileName,
TranslationContext context) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
if (heatOrchestrationTemplate.getOutputs() == null) {
return;
}
updateSharedResources(serviceTemplate, heatFileName, heatOrchestrationTemplate,
heatOrchestrationTemplate.getOutputs(), context);
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void updateSharedResources(ServiceTemplate serviceTemplate, String heatFileName,
HeatOrchestrationTemplate heatOrchestrationTemplate,
Map<String, Output> outputs, TranslationContext context) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
for (Map.Entry<String, Output> parameter : outputs.entrySet()) {
Optional<AttachedResourceId> attachedSharedResourceId = HeatToToscaUtil
.extractAttachedResourceId(heatFileName, heatOrchestrationTemplate, context,
&& serviceTemplate.getTopology_template().getOutputs().size() == 0) {
serviceTemplate.getTopology_template().setOutputs(null);
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void updateSharedResource(ServiceTemplate serviceTemplate, TranslationContext context,
Map.Entry<String, Output> paramName,
String sharedTranslatedResourceId, Resource resource) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
context.addHeatSharedResourcesByParam(paramName.getKey(), sharedTranslatedResourceId, resource);
serviceTemplate.getTopology_template().getOutputs().remove(paramName.getKey());
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void translateResources(String heatFileName, ServiceTemplate serviceTemplate,
HeatOrchestrationTemplate heatOrchestrationTemplate,
TranslationContext context) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
if(MapUtils.isEmpty(heatOrchestrationTemplate.getResources())){
return;
}
.translateResource(heatFileName, serviceTemplate, heatOrchestrationTemplate, resource,
resourceId, context);
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private Environment getHeatEnvFile(FileData heatFileData, TranslationContext context) {
import org.openecomp.sdc.heat.services.HeatConstants;
import org.openecomp.sdc.logging.api.Logger;
import org.openecomp.sdc.logging.api.LoggerFactory;
-import org.openecomp.sdc.logging.context.impl.MdcDataDebugMessage;
import org.openecomp.sdc.tosca.datatypes.ToscaFunctions;
import org.openecomp.sdc.tosca.datatypes.ToscaGroupType;
import org.openecomp.sdc.tosca.datatypes.ToscaNodeType;
protected static Logger logger =
(Logger) LoggerFactory.getLogger(UnifiedCompositionService.class);
- protected static MdcDataDebugMessage mdcDataDebugMessage = new MdcDataDebugMessage();
private static Map<String, ImplementationConfiguration> unifiedCompositionImplMap;
static {
ServiceTemplate nestedServiceTemplate,
List<UnifiedCompositionData> unifiedCompositionDataList,
UnifiedCompositionMode mode, TranslationContext context) {
- mdcDataDebugMessage.debugEntryMessage(null, null);
Optional<UnifiedComposition> unifiedCompositionInstance = getUnifiedCompositionInstance(mode);
if (!unifiedCompositionInstance.isPresent()) {
return;
unifiedCompositionInstance.get()
.createUnifiedComposition(serviceTemplate, nestedServiceTemplate,
unifiedCompositionDataList, context);
- mdcDataDebugMessage.debugExitMessage(null, null);
}
/**
@Override
protected void translate(TranslateTo translateTo) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
RelationshipTemplate relationTemplate = new RelationshipTemplate();
relationTemplate.setType(ToscaRelationshipType.CINDER_VOLUME_ATTACHES_TO);
String relationshipTemplateId = translateTo.getTranslatedId();
+ "' include 'instance_uuid' property without 'get_resource' function, therefore this "
+ "resource will be ignored in TOSCA translation.");
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
@Override
}
private AttachedResourceId getAttachedResourceId(TranslateTo translateTo, String propertyName) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Optional<AttachedResourceId> attachedResourceId =
HeatToToscaUtil.extractAttachedResourceId(translateTo, propertyName);
if (!attachedResourceId.isPresent()) {
LoggerErrorDescription.MISSING_MANDATORY_PROPERTY);
throw new CoreException(new MissingMandatoryPropertyErrorBuilder(propertyName).build());
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return attachedResourceId.get();
}
private void handleNovaGetResource(TranslateTo translateTo, RelationshipTemplate relationTemplate,
String relationshipTemplateId, String heatFileName,
AttachedResourceId volResourceId, String novaResourceId) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
RequirementAssignment requirement = new RequirementAssignment();
requirement.setCapability(toscaCapabilityAttachment);
if (volResourceId.isGetResource()) {
+ " The connection to the volume is ignored. "
+ "Supported types are: "
+ HeatResourcesTypes.CINDER_VOLUME_RESOURCE_TYPE.getHeatResource());
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return;
}
requirement.setNode((String) volResourceId.getTranslatedId());
+ " The connection to the volume is ignored. "
+ "Supported types are: "
+ HeatResourcesTypes.CINDER_VOLUME_RESOURCE_TYPE.getHeatResource());
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return;
}
requirement.setNode(
+ " The connection to the nova server is ignored. "
+ "Supported types are: "
+ HeatResourcesTypes.NOVA_SERVER_RESOURCE_TYPE.getHeatResource());
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return;
}
Optional<String> translatedNovaServerId =
novaServerNodeTemplate.getType(), translatedNovaServerId.get(), ToscaConstants
.LOCAL_STORAGE_REQUIREMENT_ID, requirement);
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void handleUnsharedVolume(TranslateTo translateTo, RelationshipTemplate relationTemplate,
String relationshipTemplateId, String heatFileName,
RequirementAssignment requirement, String volumeResourceId) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
List<FileData> allFilesData = translateTo.getContext().getManifest().getContent().getData();
Optional<FileData> fileData = HeatToToscaUtil.getFileData(heatFileName, allFilesData);
if (fileData.isPresent()) {
resourceFileDataAndIDs -> addRelationshipToServiceTemplate(translateTo, relationTemplate,
relationshipTemplateId, requirement, resourceFileDataAndIDs));
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private boolean isHeatFileNested(TranslateTo translateTo, String heatFileName) {
String relationshipTemplateId,
RequirementAssignment requirement,
ResourceFileDataAndIDs resourceFileDataAndIDs) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
String translatedId = resourceFileDataAndIDs.getTranslatedResourceId();
String toscaVolIdPropName =
HeatToToscaUtil.getToscaPropertyName(translateTo, HeatConstants.VOL_ID_PROPERTY_NAME);
requirement.setRelationship(relationshipTemplateId);
DataModelUtil.addRelationshipTemplate(translateTo.getServiceTemplate(), relationshipTemplateId,
relationTemplate);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
}
@Override
protected void translate(TranslateTo translateTo) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
if (new ContrailV2VirtualMachineInterfaceHelper().isVlanSubInterfaceResource(translateTo
.getResource())) {
translateVlanSubInterfaceResource(translateTo);
} else {
translateVirtualMachineInterfaceResource(translateTo);
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void translateVirtualMachineInterfaceResource(TranslateTo translateTo) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
NodeTemplate nodeTemplate = new NodeTemplate();
nodeTemplate.setType(ToscaNodeType.CONTRAILV2_VIRTUAL_MACHINE_INTERFACE);
nodeTemplate.setProperties(TranslatorHeatToToscaPropertyConverter
.connectVmiToNetwork(this, translateTo, nodeTemplate);
DataModelUtil.addNodeTemplate(translateTo.getServiceTemplate(), translateTo.getTranslatedId(),
nodeTemplate);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void handleVmiMacAddressesInProperties(TranslateTo translateTo,
}
private void translateVlanSubInterfaceResource(TranslateTo translateTo) {
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
new ResourceTranslationContrailV2VlanSubInterfaceImpl().translate(translateTo);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
}
@Override
public void translate(TranslateTo translateTo) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
//no translation is needed, this default is used for unsupported resources
logger.warn("Heat resource: '" + translateTo.getResourceId() + "' with type: '"
+ translateTo.getResource().getType()
+ "' is not supported, will be ignored in TOSCA translation");
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
@Override
@Override
public void translate(TranslateTo translateTo) {
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Optional<AttachedResourceId> subnetNetwork = getAttachedNetworkResource(translateTo);
if (!subnetNetwork.isPresent() || !subnetNetwork.get().isGetResource()) {
subNetMap.put(translateTo.getResourceId(), properties);
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
@Override
protected String generateTranslatedId(TranslateTo translateTo) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Optional<AttachedResourceId> subnetNetwork = getAttachedNetworkResource(translateTo);
if (!subnetNetwork.isPresent() || !subnetNetwork.get().isGetResource()) {
+ translateTo.getResource().getType()
+ "' include 'network_id/'network'' property without 'get_resource' function, therefore"
+ " this resource will be ignored in TOSCA translation.");
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return null;
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return (String) subnetNetwork.get().getTranslatedId();
}
private void handleDhcpProperty(TranslateTo translateTo, NodeTemplate networkNodeTemplate) {
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Object dhcpEnabled =
networkNodeTemplate.getProperties().get(ToscaConstants.DHCP_ENABLED_PROPERTY_NAME);
if (dhcpEnabled instanceof Map) {
}
}
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private Optional<AttachedResourceId> getAttachedNetworkResource(TranslateTo translateTo) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Optional<AttachedResourceId> subnetNetwork = Optional.empty();
Optional<AttachedResourceId> attachedNetworkId =
HeatToToscaUtil.extractAttachedResourceId(translateTo, "network_id");
} else {
subnetNetwork = attachedNetworkId;
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return subnetNetwork;
}
}
import org.openecomp.sdc.datatypes.error.ErrorLevel;
import org.openecomp.sdc.logging.api.Logger;
import org.openecomp.sdc.logging.api.LoggerFactory;
-import org.openecomp.sdc.logging.context.impl.MdcDataDebugMessage;
import org.openecomp.sdc.logging.context.impl.MdcDataErrorMessage;
import org.openecomp.sdc.logging.types.LoggerConstants;
import org.openecomp.sdc.logging.types.LoggerErrorCode;
public class VersioningManagerImpl implements VersioningManager {
private static final Logger LOGGER = LoggerFactory.getLogger(VersioningManagerImpl.class);
private static final Version INITIAL_ACTIVE_VERSION = new Version(0, 0);
- private static final MdcDataDebugMessage MDC_DATA_DEBUG_MESSAGE = new MdcDataDebugMessage();
private static final Map<String, Set<VersionableEntityMetadata>> VERSIONABLE_ENTITIES =
new HashMap<>();
Version latestFinalVersion,
Set<Version> viewableVersions,
VersionableEntityAction action, String user) {
-
-
- MDC_DATA_DEBUG_MESSAGE.debugEntryMessage("entity Id", entityId);
-
Version activeVersion;
if (action == VersionableEntityAction.Write) {
versionInfo.getViewableVersions().add(candidate.getVersion());
}
}
-
- MDC_DATA_DEBUG_MESSAGE.debugExitMessage("entity Id", entityId);
return versionInfo;
}
import org.openecomp.sdc.datatypes.error.ErrorLevel;
import org.openecomp.sdc.logging.api.Logger;
import org.openecomp.sdc.logging.api.LoggerFactory;
-import org.openecomp.sdc.logging.context.impl.MdcDataDebugMessage;
import org.openecomp.sdc.logging.context.impl.MdcDataErrorMessage;
import org.openecomp.sdc.logging.types.LoggerConstants;
import org.openecomp.sdc.logging.types.LoggerErrorCode;
/**
* Add substitution mapping.
*/
-
- private static final MdcDataDebugMessage mdcDataDebugMessage = new MdcDataDebugMessage();
private static final Logger logger = LoggerFactory.getLogger(DataModelUtil.class);
private static final String SERVICE_TEMPLATE = "Service Template";
private static final String NODE_TYPE = "Node Type";
*/
public static void addSubstitutionMapping(ServiceTemplate serviceTemplate,
SubstitutionMapping substitutionMapping) {
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (serviceTemplate == null) {
MdcDataErrorMessage.createErrorMessageAndUpdateMdc(LoggerConstants.TARGET_ENTITY_DB,
LoggerTragetServiceName.ADD_ENTITIES_TO_TOSCA, ErrorLevel.ERROR.name(),
serviceTemplate.setTopology_template(new TopologyTemplate());
}
serviceTemplate.getTopology_template().setSubstitution_mappings(substitutionMapping);
-
- mdcDataDebugMessage.debugExitMessage(null);
}
public static List<String> getDirectives(NodeTemplate nodeTemplate) {
public static void addSubstitutionMappingReq(ServiceTemplate serviceTemplate,
String substitutionMappingRequirementId,
List<String> substitutionMappingRequirementList) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (serviceTemplate == null) {
MdcDataErrorMessage.createErrorMessageAndUpdateMdc(LoggerConstants.TARGET_ENTITY_DB,
LoggerTragetServiceName.ADD_ENTITIES_TO_TOSCA, ErrorLevel.ERROR.name(),
serviceTemplate.getTopology_template().getSubstitution_mappings().getRequirements()
.put(substitutionMappingRequirementId, substitutionMappingRequirementList);
-
- mdcDataDebugMessage.debugExitMessage(null);
}
/**
public static void addSubstitutionMappingCapability(ServiceTemplate serviceTemplate,
String substitutionMappingCapabilityId,
List<String> substitutionMappingCapabilityList) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (serviceTemplate == null) {
MdcDataErrorMessage.createErrorMessageAndUpdateMdc(LoggerConstants.TARGET_ENTITY_DB,
LoggerTragetServiceName.ADD_ENTITIES_TO_TOSCA, ErrorLevel.ERROR.name(),
serviceTemplate.getTopology_template().getSubstitution_mappings().getCapabilities()
.putIfAbsent(substitutionMappingCapabilityId, substitutionMappingCapabilityList);
-
- mdcDataDebugMessage.debugExitMessage(null);
}
public static Map<String, NodeTemplate> getNodeTemplates(ServiceTemplate serviceTemplate) {
*/
public static void addNodeTemplate(ServiceTemplate serviceTemplate, String nodeTemplateId,
NodeTemplate nodeTemplate) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (serviceTemplate == null) {
MdcDataErrorMessage.createErrorMessageAndUpdateMdc(LoggerConstants.TARGET_ENTITY_DB,
LoggerTragetServiceName.ADD_ENTITIES_TO_TOSCA, ErrorLevel.ERROR.name(),
topologyTemplate.setNode_templates(new HashMap<>());
}
topologyTemplate.getNode_templates().put(nodeTemplateId, nodeTemplate);
-
- mdcDataDebugMessage.debugExitMessage(null);
-
}
/**
*/
public static void addNodeTypeCapabilitiesDef(NodeType nodeType,
Map<String, CapabilityDefinition> capabilities) {
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (MapUtils.isEmpty(capabilities) || capabilities.entrySet().isEmpty()) {
return;
}
for (Map.Entry<String, CapabilityDefinition> entry : capabilities.entrySet()) {
nodeType.getCapabilities().put(entry.getKey(), entry.getValue());
}
-
- mdcDataDebugMessage.debugExitMessage(null);
}
/**
*/
public static void addPolicyDefinition(ServiceTemplate serviceTemplate, String policyId,
PolicyDefinition policyDefinition) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (serviceTemplate == null) {
MdcDataErrorMessage.createErrorMessageAndUpdateMdc(LoggerConstants.TARGET_ENTITY_DB,
LoggerTragetServiceName.ADD_ENTITIES_TO_TOSCA, ErrorLevel.ERROR.name(),
topologyTemplate.setPolicies(new HashMap<>());
}
topologyTemplate.getPolicies().put(policyId, policyDefinition);
-
- mdcDataDebugMessage.debugExitMessage(null);
}
/**
*/
public static void addNodeType(ServiceTemplate serviceTemplate, String nodeTypeId,
NodeType nodeType) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (serviceTemplate == null) {
MdcDataErrorMessage.createErrorMessageAndUpdateMdc(LoggerConstants.TARGET_ENTITY_DB,
LoggerTragetServiceName.ADD_ENTITIES_TO_TOSCA, ErrorLevel.ERROR.name(),
serviceTemplate.setNode_types(new HashMap<>());
}
serviceTemplate.getNode_types().put(nodeTypeId, nodeType);
-
- mdcDataDebugMessage.debugExitMessage(null);
}
public static void removeNodeType(ServiceTemplate serviceTemplate,
serviceTemplate.setNode_types(new HashMap<>());
}
serviceTemplate.getNode_types().remove(nodeTypeId);
-
- mdcDataDebugMessage.debugExitMessage(null);
}
/**
public static void addRelationshipTemplate(ServiceTemplate serviceTemplate,
String relationshipTemplateId,
RelationshipTemplate relationshipTemplate) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (serviceTemplate == null) {
MdcDataErrorMessage.createErrorMessageAndUpdateMdc(LoggerConstants.TARGET_ENTITY_DB,
LoggerTragetServiceName.ADD_ENTITIES_TO_TOSCA, ErrorLevel.ERROR.name(),
}
serviceTemplate.getTopology_template().getRelationship_templates()
.put(relationshipTemplateId, relationshipTemplate);
-
- mdcDataDebugMessage.debugExitMessage(null);
}
/**
*/
public static void addRequirementAssignment(NodeTemplate nodeTemplate, String requirementId,
RequirementAssignment requirementAssignment) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (nodeTemplate == null) {
MdcDataErrorMessage.createErrorMessageAndUpdateMdc(LoggerConstants.TARGET_ENTITY_DB,
LoggerTragetServiceName.ADD_ENTITIES_TO_TOSCA, ErrorLevel.ERROR.name(),
Map<String, RequirementAssignment> requirement = new HashMap<>();
requirement.put(requirementId, requirementAssignment);
nodeTemplate.getRequirements().add(requirement);
-
- mdcDataDebugMessage.debugExitMessage(null);
}
/**
*/
public static NodeTemplate getNodeTemplate(ServiceTemplate serviceTemplate,
String nodeTemplateId) {
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (serviceTemplate == null
|| serviceTemplate.getTopology_template() == null
|| serviceTemplate.getTopology_template().getNode_templates() == null) {
return null;
}
-
- mdcDataDebugMessage.debugExitMessage(null);
return serviceTemplate.getTopology_template().getNode_templates().get(nodeTemplateId);
}
* @return the node type
*/
public static NodeType getNodeType(ServiceTemplate serviceTemplate, String nodeTypeId) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
if (serviceTemplate == null || serviceTemplate.getNode_types() == null) {
return null;
}
-
- mdcDataDebugMessage.debugExitMessage(null);
return serviceTemplate.getNode_types().get(nodeTypeId);
}
public static Optional<RequirementDefinition> getRequirementDefinition(
NodeType nodeType,
String requirementDefinitionId) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (nodeType == null || nodeType.getRequirements() == null || requirementDefinitionId == null) {
return Optional.empty();
}
return Optional.of(reqMap.get(requirementDefinitionId));
}
}
-
- mdcDataDebugMessage.debugExitMessage(null);
return Optional.empty();
}
public static Optional<RequirementDefinition> getRequirementDefinition(
List<Map<String, RequirementDefinition>> requirementsDefinitionList,
String requirementKey) {
- mdcDataDebugMessage.debugEntryMessage(null);
if (CollectionUtils.isEmpty(requirementsDefinitionList)) {
return Optional.empty();
}
for (Map<String, RequirementDefinition> requirementMap : requirementsDefinitionList) {
if (requirementMap.containsKey(requirementKey)) {
- mdcDataDebugMessage.debugExitMessage(null);
return Optional.of(requirementMap.get(requirementKey));
}
}
-
- mdcDataDebugMessage.debugExitMessage(null);
return Optional.empty();
}
public static Optional<CapabilityDefinition> getCapabilityDefinition(
NodeType nodeType,
String capabilityDefinitionId) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (nodeType == null || nodeType.getCapabilities() == null || capabilityDefinitionId == null) {
return Optional.empty();
}
-
- mdcDataDebugMessage.debugExitMessage(null);
return Optional.ofNullable(nodeType.getCapabilities().get(capabilityDefinitionId));
}
*/
public static void addGroupDefinitionToTopologyTemplate(ServiceTemplate serviceTemplate,
String groupName, GroupDefinition group) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (serviceTemplate == null) {
MdcDataErrorMessage.createErrorMessageAndUpdateMdc(LoggerConstants.TARGET_ENTITY_DB,
LoggerTragetServiceName.ADD_ENTITIES_TO_TOSCA, ErrorLevel.ERROR.name(),
}
serviceTemplate.getTopology_template().getGroups().put(groupName, group);
- mdcDataDebugMessage.debugExitMessage(null);
}
/**
Status status,
EntrySchema entrySchema,
Object defaultVal) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
ParameterDefinition paramDef = new ParameterDefinition();
paramDef.setType(type);
paramDef.setDescription(description);
}
paramDef.setEntry_schema(entrySchema == null ? null : entrySchema.clone());
paramDef.set_default(defaultVal);
-
- mdcDataDebugMessage.debugExitMessage(null);
return paramDef;
}
*/
public static RequirementDefinition createRequirement(String capability, String node,
String relationship, Object[] occurrences) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
RequirementDefinition requirementDefinition = new RequirementDefinition();
requirementDefinition.setCapability(capability);
requirementDefinition.setNode(node);
if (occurrences != null) {
requirementDefinition.setOccurrences(occurrences);
}
-
- mdcDataDebugMessage.debugExitMessage(null);
return requirementDefinition;
}
*/
public static EntrySchema createEntrySchema(String type, String description,
List<Constraint> constraints) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (Objects.isNull(type) && Objects.isNull(description) &&
CollectionUtils.isEmpty(constraints)) {
return null;
entrySchema.setType(type);
entrySchema.setDescription(description);
entrySchema.setConstraints(constraints);
-
- mdcDataDebugMessage.debugExitMessage(null);
return entrySchema;
}
public static Map createGetInputPropertyValueFromListParameter(String inputPropertyListName,
int indexInTheList,
String... nestedPropertyName) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
List propertyList = new ArrayList<>();
propertyList.add(inputPropertyListName);
propertyList.add(indexInTheList);
}
Map getInputProperty = new HashMap<>();
getInputProperty.put(ToscaFunctions.GET_INPUT.getDisplayName(), propertyList);
-
- mdcDataDebugMessage.debugExitMessage(null);
return getInputProperty;
}
*/
public static ParameterDefinitionExt convertPropertyDefToParameterDef(
PropertyDefinition propertyDefinition) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (propertyDefinition == null) {
return null;
}
: propertyDefinition.getEntry_schema().clone());
parameterDefinition.setHidden(false);
parameterDefinition.setImmutable(false);
-
- mdcDataDebugMessage.debugExitMessage(null);
return parameterDefinition;
}
*/
public static ParameterDefinitionExt convertAttributeDefToParameterDef(
AttributeDefinition attributeDefinition, Map<String, List> outputValue) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (attributeDefinition == null) {
return null;
}
ParameterDefinitionExt parameterDefinition = new ParameterDefinitionExt();
parameterDefinition.setDescription(attributeDefinition.getDescription());
parameterDefinition.setValue(outputValue);
-
- mdcDataDebugMessage.debugExitMessage(null);
return parameterDefinition;
}
public static void addInputParameterToTopologyTemplate(ServiceTemplate serviceTemplate,
String parameterDefinitionId,
ParameterDefinition parameterDefinition) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (Objects.isNull(serviceTemplate)) {
MdcDataErrorMessage.createErrorMessageAndUpdateMdc(LoggerConstants.TARGET_ENTITY_DB,
LoggerTragetServiceName.ADD_ENTITIES_TO_TOSCA, ErrorLevel.ERROR.name(),
topologyTemplate.setInputs(new HashMap<>());
}
topologyTemplate.getInputs().put(parameterDefinitionId, parameterDefinition);
-
- mdcDataDebugMessage.debugExitMessage(null);
-
}
/**
public static void addOutputParameterToTopologyTemplate(ServiceTemplate serviceTemplate,
String parameterDefinitionId,
ParameterDefinition parameterDefinition) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (Objects.isNull(serviceTemplate)) {
MdcDataErrorMessage.createErrorMessageAndUpdateMdc(LoggerConstants.TARGET_ENTITY_DB,
LoggerTragetServiceName.ADD_ENTITIES_TO_TOSCA, ErrorLevel.ERROR.name(),
topologyTemplate.setOutputs(new HashMap<>());
}
topologyTemplate.getOutputs().put(parameterDefinitionId, parameterDefinition);
-
- mdcDataDebugMessage.debugExitMessage(null);
-
}
/**
*/
public static Map<String, RequirementAssignment> getNodeTemplateRequirements(
NodeTemplate nodeTemplate) {
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (Objects.isNull(nodeTemplate)) {
return null;
}
.put(requirementEntry.getKey(), requirementAssignment);
}
}
-
- mdcDataDebugMessage.debugExitMessage(null);
return nodeTemplateRequirementsAssignment;
}
*/
public static List<Map<String, RequirementAssignment>> getNodeTemplateRequirementList(
NodeTemplate nodeTemplate) {
- mdcDataDebugMessage.debugEntryMessage(null);
ToscaExtensionYamlUtil toscaExtensionYamlUtil = new ToscaExtensionYamlUtil();
//Creating concrete objects
List<Map<String, RequirementAssignment>> requirements = nodeTemplate.getRequirements();
requirements.addAll(concreteRequirementList);
nodeTemplate.setRequirements(requirements);
}
- mdcDataDebugMessage.debugExitMessage(null);
return concreteRequirementList;
}
public static Optional<List<RequirementAssignment>> getRequirementAssignment(
List<Map<String, RequirementAssignment>> requirementsAssignmentList,
String requirementKey) {
-
- mdcDataDebugMessage.debugEntryMessage(null);
if (CollectionUtils.isEmpty(requirementsAssignmentList)) {
return Optional.empty();
}
matchRequirementAssignmentList.add(requirementAssignment);
}
}
-
- mdcDataDebugMessage.debugExitMessage(null);
return Optional.of(matchRequirementAssignmentList);
}
public static void removeRequirementsDefinition(
List<Map<String, RequirementDefinition>> requirementsDefinitionList,
String requirementKey) {
- mdcDataDebugMessage.debugEntryMessage(null);
if (requirementsDefinitionList == null) {
return;
}
for (Map<String, RequirementDefinition> removeMap : mapToBeRemoved) {
requirementsDefinitionList.remove(removeMap);
}
-
- mdcDataDebugMessage.debugExitMessage(null);
}
/**
public static void removeRequirementsAssignment(
List<Map<String, RequirementAssignment>> requirementsAssignmentList,
String requirementKey) {
- mdcDataDebugMessage.debugEntryMessage(null);
if (requirementsAssignmentList == null) {
return;
}
for (Map<String, RequirementAssignment> removeMap : mapToBeRemoved) {
requirementsAssignmentList.remove(removeMap);
}
-
- mdcDataDebugMessage.debugExitMessage(null);
}
NodeTemplate nodeTemplate,
String requirementKey,
RequirementAssignment requirementAssignmentToBeDeleted) {
- mdcDataDebugMessage.debugEntryMessage(null);
ToscaAnalyzerService toscaAnalyzerService = new ToscaAnalyzerServiceImpl();
List<Map<String, RequirementAssignment>> nodeTemplateRequirements = nodeTemplate
.getRequirements();
}
}
}
-
- mdcDataDebugMessage.debugExitMessage(null);
}
/**
*/
public static ParameterDefinition getOuputParameter(ServiceTemplate serviceTemplate,
String outputParameterId) {
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (serviceTemplate == null
|| serviceTemplate.getTopology_template() == null
|| serviceTemplate.getTopology_template().getOutputs() == null) {
return null;
}
-
- mdcDataDebugMessage.debugExitMessage(null);
return serviceTemplate.getTopology_template().getOutputs().get(outputParameterId);
}
*/
public static Object getPropertyValue(NodeTemplate nodeTemplate,
String propertyId) {
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (nodeTemplate == null
|| nodeTemplate.getProperties() == null) {
return null;
}
-
- mdcDataDebugMessage.debugExitMessage(null);
return nodeTemplate.getProperties().get(propertyId);
}
*/
public static Map<String, Object> getNodeTemplateProperties(ServiceTemplate serviceTemplate,
String nodeTemplateId) {
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (serviceTemplate == null
|| serviceTemplate.getTopology_template() == null
|| serviceTemplate.getTopology_template().getNode_templates() == null
|| serviceTemplate.getTopology_template().getNode_templates().get(nodeTemplateId) == null) {
return null;
}
-
- mdcDataDebugMessage.debugExitMessage(null);
return serviceTemplate.getTopology_template().getNode_templates().get(nodeTemplateId)
.getProperties();
}
* @return the substitution mappings
*/
public static SubstitutionMapping getSubstitutionMappings(ServiceTemplate serviceTemplate) {
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (serviceTemplate == null
|| serviceTemplate.getTopology_template() == null
|| serviceTemplate.getTopology_template().getSubstitution_mappings() == null) {
return null;
}
-
- mdcDataDebugMessage.debugExitMessage(null);
return serviceTemplate.getTopology_template().getSubstitution_mappings();
}
*/
public static void addBindingReqFromPortToCompute(String computeNodeTemplateId,
NodeTemplate portNodeTemplate) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
RequirementAssignment requirementAssignment = new RequirementAssignment();
requirementAssignment.setCapability(ToscaCapabilityType.NATIVE_NETWORK_BINDABLE);
requirementAssignment.setRelationship(ToscaRelationshipType.NATIVE_NETWORK_BINDS_TO);
requirementAssignment.setNode(computeNodeTemplateId);
addRequirementAssignment(portNodeTemplate, ToscaConstants.BINDING_REQUIREMENT_ID,
requirementAssignment);
- mdcDataDebugMessage.debugExitMessage(null);
}
public static SubstitutionMapping createSubstitutionTemplateSubMapping(
String nodeTypeKey,
NodeType substitutionNodeType,
Map<String, Map<String, List<String>>> mapping) {
- mdcDataDebugMessage.debugEntryMessage(null);
SubstitutionMapping substitutionMapping = new SubstitutionMapping();
substitutionMapping.setNode_type(nodeTypeKey);
substitutionMapping.setCapabilities(
substitutionMapping.setRequirements(
manageRequirementMapping(substitutionNodeType.getRequirements(),
mapping.get("requirement")));
-
- mdcDataDebugMessage.debugExitMessage(null);
return substitutionMapping;
}
private static Map<String, List<String>> manageRequirementMapping(
List<Map<String, RequirementDefinition>> requirementList,
Map<String, List<String>> requirementSubstitutionMapping) {
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (requirementList == null) {
return null;
}
requirementMapping.put(requirementKey, requirementMap);
}
}
-
- mdcDataDebugMessage.debugExitMessage(null);
return requirementMapping;
}
private static Map<String, List<String>> manageCapabilityMapping(
Map<String, CapabilityDefinition> capabilities,
Map<String, List<String>> capabilitySubstitutionMapping) {
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (capabilities == null) {
- mdcDataDebugMessage.debugExitMessage(null);
return null;
}
capabilityMap = capabilitySubstitutionMapping.get(capabilityKey);
capabilityMapping.put(capabilityKey, capabilityMap);
}
-
- mdcDataDebugMessage.debugExitMessage(null);
return capabilityMapping;
}
List<Map<String, RequirementDefinition>>
requirementsList,
String templateName) {
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (CollectionUtils.isEmpty(requirementsList)) {
return;
}
substitutionNodeType.getRequirements().add(requirementMap);
}
}
-
- mdcDataDebugMessage.debugExitMessage(null);
}
public static boolean isNodeTemplateSectionMissingFromServiceTemplate(
import org.openecomp.core.utilities.CommonMethods;
import org.openecomp.sdc.common.errors.CoreException;
import org.openecomp.sdc.datatypes.error.ErrorLevel;
-import org.openecomp.sdc.logging.context.impl.MdcDataDebugMessage;
import org.openecomp.sdc.logging.context.impl.MdcDataErrorMessage;
import org.openecomp.sdc.logging.types.LoggerConstants;
import org.openecomp.sdc.logging.types.LoggerErrorCode;
import java.util.Set;
public class ToscaAnalyzerServiceImpl implements ToscaAnalyzerService {
-
- protected static final MdcDataDebugMessage MDC_DATA_DEBUG_MESSAGE = new MdcDataDebugMessage();
-
public List<Map<String, RequirementDefinition>> calculateExposedRequirements(
List<Map<String, RequirementDefinition>> nodeTypeRequirementsDefinitionList,
Map<String, RequirementAssignment> nodeTemplateRequirementsAssignment) {
- MDC_DATA_DEBUG_MESSAGE.debugEntryMessage(null, null);
-
if (nodeTypeRequirementsDefinitionList == null) {
return null;
}
}
}
}
-
- MDC_DATA_DEBUG_MESSAGE.debugExitMessage(null, null);
return nodeTypeRequirementsDefinitionList;
}
public Map<String, CapabilityDefinition> calculateExposedCapabilities(
Map<String, CapabilityDefinition> nodeTypeCapabilitiesDefinition,
Map<String, Map<String, RequirementAssignment>> fullFilledRequirementsDefinitionMap) {
-
-
- MDC_DATA_DEBUG_MESSAGE.debugEntryMessage(null, null);
-
String capabilityKey;
String capability;
String node;
.entrySet()) {
exposedCapabilitiesDefinition.put(entry.getKey(), entry.getValue());
}
-
- MDC_DATA_DEBUG_MESSAGE.debugExitMessage(null, null);
return exposedCapabilitiesDefinition;
}
Code Review / sdc.git / commitdiff