+++ /dev/null
-/*
- * Copyright © 2016-2017 European Support Limited
- *
- * 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.openecomp.sdc.logging.context.impl;
-
-import org.openecomp.sdc.logging.api.Logger;
-import org.openecomp.sdc.logging.api.LoggerFactory;
-import org.openecomp.sdc.logging.context.MdcData;
-import org.openecomp.sdc.logging.messages.DebugMessages;
-import org.openecomp.sdc.logging.types.DebugConstants;
-import org.openecomp.sdc.logging.types.LoggerErrorCategory;
-import org.openecomp.sdc.logging.util.LoggingUtils;
-
-import java.util.HashMap;
-import java.util.Map;
-
-public class MdcDataDebugMessage extends MdcData {
-
- private Logger logger;
- private static Map<String, String> mapExitOrEntryToMessage;
-
- static {
- mapExitOrEntryToMessage = new HashMap<>();
- mapExitOrEntryToMessage.put(DebugConstants.ENTER, DebugMessages.ENTER_METHOD);
- mapExitOrEntryToMessage.put(DebugConstants.ENTER_DEFAULT, DebugMessages.DEFAULT_ENTER_METHOD);
- mapExitOrEntryToMessage.put(DebugConstants.EXIT, DebugMessages.EXIT_METHOD);
- mapExitOrEntryToMessage.put(DebugConstants.EXIT_DEFAULT, DebugMessages.DEFAULT_EXIT_METHOD);
- }
-
- public MdcDataDebugMessage() {
- super(LoggerErrorCategory.DEBUG.name(), null);
- }
-
- //todo add more explanations as to the first parameter structure in case of multiples and in
- // case of no params in method
- /**
- * Debug entry message.
- *
- * @param entityParameter the entity parameter
- * @param ids the ids
- */
- public void debugEntryMessage(String entityParameter, String... ids) {
- logDebugMessage(entityParameter, DebugConstants.ENTER, ids);
- }
-
- /**
- * Debug exit message.
- *
- * @param entityParameter the entity parameter
- * @param ids the ids
- */
- public void debugExitMessage(String entityParameter, String... ids) {
- logDebugMessage(entityParameter, DebugConstants.EXIT, ids);
- }
-
- private void logDebugMessage(String entityParameter, String enterOrExit, String... ids) {
- String methodName = LoggingUtils.getCallingMethodNameForDebugging();
- String declaringClass = LoggingUtils.getDeclaringClass();
- logger = LoggerFactory.getLogger(declaringClass);
- String messageToWrite;
-
- if (entityParameter == null || ids == null) {
- messageToWrite = mapExitOrEntryToMessage.get(enterOrExit + "_" + DebugConstants.DEFAULT);
- logger.debug(String.format(messageToWrite, methodName));
- } else {
- messageToWrite = mapExitOrEntryToMessage.get(enterOrExit);
- logger.debug(String
- .format(messageToWrite, methodName, entityParameter, String.join(",", ids)));
- }
- }
-}
import org.openecomp.sdc.datatypes.error.ErrorLevel;
import org.openecomp.sdc.heat.datatypes.model.HeatOrchestrationTemplate;
import org.openecomp.sdc.heat.datatypes.model.Resource;
-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 abstract class ResourceTranslationBase {
protected static Logger logger = (Logger) LoggerFactory.getLogger(ResourceTranslationBase.class);
- protected static MdcDataDebugMessage mdcDataDebugMessage = new MdcDataDebugMessage();
-
protected abstract void translate(TranslateTo translateTo);
/**
HeatOrchestrationTemplate heatOrchestrationTemplate,
Resource resource, String resourceId,
TranslationContext context) {
-
- mdcDataDebugMessage.debugEntryMessage("file, resource", heatFileName, resourceId);
Optional<String> translatedId =
getResourceTranslatedId(heatFileName, heatOrchestrationTemplate, resourceId, context);
context.getTranslatedResources().putIfAbsent(heatFileName, new HashSet<>());
context.getHeatStackGroupMembers().get(heatFileName).add(translatedId.get());
updateResourceDependency(translateTo);
}
-
- mdcDataDebugMessage.debugExitMessage("file, resource", heatFileName, resourceId);
return translatedId;
}
heatOrchestrationTemplate,
String resourceId,
TranslationContext context) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
if (!context.getTranslatedIds().containsKey(heatFileName)) {
context.getTranslatedIds().put(heatFileName, new HashMap<>());
}
throw new CoreException(
new ResourceNotFoundInHeatFileErrorBuilder(resourceId, heatFileName).build());
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return getTranslatedResourceId(resourceId, heatFileName, resource, heatOrchestrationTemplate,
context
);
String heatFileName,
HeatOrchestrationTemplate heatOrchestrationTemplate,
String resourceId, TranslationContext context) {
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Resource resource = heatOrchestrationTemplate.getResources().get(resourceId);
if (resource == null) {
MdcDataErrorMessage.createErrorMessageAndUpdateMdc(LoggerConstants.TARGET_ENTITY_DB,
Optional<ToscaTopologyTemplateElements> translatedElementTemplate =
ResourceTranslationFactory.getInstance(resource)
.getTranslatedToscaTopologyElement(translateTo);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return translatedElementTemplate;
}
private void updateResourceDependency(TranslateTo translateTo) {
String heatFileName = translateTo.getHeatFileName();
- mdcDataDebugMessage.debugEntryMessage("file", heatFileName);
-
Resource resource = translateTo.getResource();
HeatOrchestrationTemplate heatOrchestrationTemplate = translateTo
.getHeatOrchestrationTemplate();
String dependsOnResourceId = (String) resource.getDepends_on();
addDependOnRequirement(dependsOnResourceId, translateTo);
}
-
- mdcDataDebugMessage.debugExitMessage("file", heatFileName);
}
private void addDependOnRequirement(String dependsOnResourceId, TranslateTo translateTo) {
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
String nodeTemplateId = translateTo.getTranslatedId();
ServiceTemplate serviceTemplate = translateTo.getServiceTemplate();
String heatFileName = translateTo.getHeatFileName();
requirementAssignment);
}
}
- mdcDataDebugMessage.debugExitMessage(null, null);
}
Optional<List<Map.Entry<String, Resource>>> getResourceByTranslatedResourceId(
String translatedResourceId,
TranslateTo translateTo,
String heatResourceType) {
- mdcDataDebugMessage.debugEntryMessage(null, null);
List<Map.Entry<String, Resource>> list = heatOrchestrationTemplate.getResources().entrySet()
.stream()
.filter(entry -> getPredicatesForTranslatedIdToResourceId(heatFileName,
.allMatch(p -> p.test(entry)))
.collect(Collectors.toList());
if (CollectionUtils.isEmpty(list)) {
- mdcDataDebugMessage.debugExitMessage(null, null);
return Optional.empty();
} else {
- mdcDataDebugMessage.debugExitMessage(null, null);
return Optional.of(list);
}
}
@Override
protected void translate(TranslateTo translateTo) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
String heatFileName = translateTo.getHeatFileName();
String translatedNetworkResourceId = getTranslatedNetworkResourceId(translateTo);
if (translatedNetworkResourceId == null) {
- mdcDataDebugMessage.debugExitMessage(null, null);
return;
}
.addRequirementAssignment(policyNodeTemplate, ToscaConstants.NETWORK_REQUIREMENT_ID,
createRequirementAssignment(translatedNetworkResourceId));
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
@Override
private NodeTemplate getTranslatedPolicyNodeTemplate(TranslateTo translateTo,
String heatFileName) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
AttachedResourceId attachedPolicyResourceId =
extractAttachedResourceIdHandleMissing(translateTo, "policy");
NodeTemplate policyNodeTemplate = new NodeTemplate();
+ "' include 'policy' property without 'get_attr' of 'fq_name'/'get_resource' function,"
+ " therefore this resource will be ignored in TOSCA translation.");
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return policyNodeTemplate;
}
private NodeTemplate getPolicyNodeTemplate(TranslateTo translateTo, String heatFileName,
String policyResourceId) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Resource policyResource = HeatToToscaUtil
.getResource(translateTo.getHeatOrchestrationTemplate(), policyResourceId, heatFileName);
Optional<String> translatedPolicyResourceId =
+ translateTo.getResource().getType()
+ "' include unsupported policy resource, therefore this resource will be ignored in "
+ "TOSCA translation. ");
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return null;
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return DataModelUtil
.getNodeTemplate(translateTo.getServiceTemplate(), translatedPolicyResourceId.get());
}
private String getTranslatedNetworkResourceId(TranslateTo translateTo) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
AttachedResourceId attachedNetworkResourceId =
extractAttachedResourceIdHandleMissing(translateTo, "network");
+ "' include 'network' property without 'get_resource' function, therefore this "
+ "resource will be ignored in TOSCA translation.");
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return translatedNetworkResourceId;
}
private RequirementAssignment createRequirementAssignment(String translatedNetworkResourceId) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
RequirementAssignment requirement = new RequirementAssignment();
requirement.setCapability(ToscaCapabilityType.NATIVE_ATTACHMENT);
requirement.setNode(translatedNetworkResourceId);
requirement.setRelationship(ToscaRelationshipType.ATTACHES_TO);
- mdcDataDebugMessage.debugExitMessage(null, null);
return requirement;
}
private AttachedResourceId extractAttachedResourceIdHandleMissing(
TranslateTo translateTo, String propertyName) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Optional<AttachedResourceId> attachedResourceId =
HeatToToscaUtil.extractAttachedResourceId(translateTo, propertyName);
LoggerErrorDescription.MISSING_MANDATORY_PROPERTY);
throw new CoreException(new MissingMandatoryPropertyErrorBuilder(propertyName).build());
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return attachedResourceId.get();
}
}
@Override
protected void translate(TranslateTo translateTo) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
NodeTemplate nodeTemplate = new NodeTemplate();
nodeTemplate.setType(ToscaNodeType.CONTRAIL_NETWORK_RULE);
DataModelUtil.addNodeTemplate(translateTo.getServiceTemplate(), translateTo.getTranslatedId(),
nodeTemplate);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
}
@Override
public void translate(TranslateTo translateTo) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Resource serviceInstanceResource = translateTo.getResource();
AttachedResourceId contrailServiceTemplateAttached =
getServiceTemplateAttachedId(translateTo, serviceInstanceResource);
+ "' in property service_template. Invalid type, resource type should be type of '"
+ HeatResourcesTypes.CONTRAIL_SERVICE_TEMPLATE.getHeatResource()
+ "', therefore this resource will be ignored in TOSCA translation.");
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return;
}
Optional<String> contrailServiceTemplateTranslatedId =
+ "' with type '" + contrailServiceTemplateResource.getType()
+ "' in property 'service_template'"
+ ", therefore this resource will be ignored in TOSCA translation.");
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return;
/*throw new CoreException(new ReferenceToUnsupportedResourceErrorBuilder
(translateTo.getResourceId(), translateTo.getResource().getType(),
logger.warn("More than one ServiceInstance pointing to the same ServiceTemplate '"
+ contrailServiceTemplateResourceId + " ' with different number of interfaces."
+ ", therefore this resource will be ignored in TOSCA translation.");
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return;
}
+ "' include 'service_template' property without 'get_resource' function, currently not"
+ " supported, therefore this resource will be ignored in TOSCA translation.");
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void addAbstractSubstitutionProperty(TranslateTo translateTo,
Map<String, Object> substitutionProperties,
ServiceTemplate nestedServiceTemplate,
Resource contrailServiceTemplateResource) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Map<String, Object> innerProps = new HashMap<>();
innerProps.put(ToscaConstants.SUBSTITUTE_SERVICE_TEMPLATE_PROPERTY_NAME,
ToscaUtil.getServiceTemplateFileName(nestedServiceTemplate));
}
innerProps.put("mandatory", mandatory);
substitutionProperties.put(ToscaConstants.SERVICE_TEMPLATE_FILTER_PROPERTY_NAME, innerProps);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private Object handleScaleOutProperty(TranslateTo translateTo, Map<String, Object> innerProps) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Object scaleOutPropertyValue =
translateTo.getResource().getProperties().get(HeatConstants.SCALE_OUT_PROPERTY_NAME);
Object countValue = null;
} else {
innerProps.put(ToscaConstants.COUNT_PROPERTY_NAME, 1);
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return countValue;
}
private void handleServiceScalingProperty(TranslateTo translateTo, Map<String, Object> innerProps,
Resource contrailServiceTemplateResource) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Object serviceScalingPropertyValue = contrailServiceTemplateResource.getProperties()
.get(HeatConstants.SERVICE_SCALING_PROPERTY_NAME);
Object serviceScalingValue = null;
.eval(serviceScalingValue) : serviceScalingValue);
}
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private boolean getOrderedInterfaces(Resource contrailServiceTemplate) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Object orderedInterfaces = contrailServiceTemplate.getProperties().get("ordered_interfaces");
if (orderedInterfaces == null) {
- mdcDataDebugMessage.debugExitMessage(null, null);
return false;
}
if (orderedInterfaces instanceof String) {
- mdcDataDebugMessage.debugExitMessage(null, null);
return HeatBoolean.eval(orderedInterfaces);
}
//if get_param, set default value to true
- mdcDataDebugMessage.debugExitMessage(null, null);
return true;
}
String substitutedNodeTypeId,
NodeTemplate substitutedNodeTemplate,
boolean orderedInterfaces) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
ServiceTemplate nestedSubstitutionServiceTemplate = new ServiceTemplate();
setNestedServiceTemplateGeneralDetails(translateTo, nestedSubstitutionServiceTemplate);
String heatStackGroupKey = addHeatStackGroup(translateTo, nestedSubstitutionServiceTemplate);
handleOutputParameters(nestedSubstitutionServiceTemplate, computeNodeTemplateId, translateTo);
handleServiceInstanceInterfaces(translateTo, nestedSubstitutionServiceTemplate,
substitutedNodeTemplate, heatStackGroupKey, orderedInterfaces, computeNodeTemplateId);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return nestedSubstitutionServiceTemplate;
}
private void handleOutputParameters(ServiceTemplate nestedSubstitutionServiceTemplate,
String nodeTemplateId, TranslateTo translateTo) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
if (nodeTemplateId == null) {
return;
}
nestedSubstitutionServiceTemplate.getTopology_template()
.setOutputs(nestedSubstitutionServiceTemplateOutputs);
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void handleServiceInstanceInterfaces(TranslateTo translateTo,
NodeTemplate substitutedNodeTemplate,
String heatStackGroupKey, boolean orderedInterfaces,
String computeNodeTemplateId) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Resource serviceInstanceResource = translateTo.getResource();
Object interfaceListProperty =
serviceInstanceResource.getProperties().get(HeatConstants.INTERFACE_LIST_PROPERTY_NAME);
handleInterface(translateTo, interfaceListProperty, null, nestedSubstitutionServiceTemplate,
heatStackGroupKey, substitutedNodeTemplate, orderedInterfaces, computeNodeTemplateId);
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void handleInterface(TranslateTo translateTo, Object interfacePropertyValue,
ServiceTemplate nestedSubstitutionServiceTemplate,
String heatStackGroupKey, NodeTemplate substitutedNodeTemplate,
boolean orderedInterfaces, String computeNodeTemplateId) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
if (index == null) {
index = new Integer(0);
}
updateHeatStackGroup(nestedSubstitutionServiceTemplate, heatStackGroupKey, portNodeTemplateId);
connectPortToNetwork(translateTo, interfacePropertyValue, substitutedNodeTemplate,
portReqMappingKey);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void connectPortToNetwork(TranslateTo translateTo, Object interfacePropertyValue,
NodeTemplate substitutedNodeTemplate,
String portReqMappingKey) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
List<String> validNetworksForConnections = Arrays
.asList(HeatResourcesTypes.NEUTRON_NET_RESOURCE_TYPE.getHeatResource(),
HeatResourcesTypes.CONTRAIL_VIRTUAL_NETWORK_RESOURCE_TYPE.getHeatResource());
// MissingMandatoryPropertyErrorBuilder("virtual_network").build());
}
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private NodeTemplate createPortNodeTemplate(Integer index, boolean orderedInterfaces,
String computeNodeTemplateId) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
NodeTemplate portNodeTemplate = new NodeTemplate();
portNodeTemplate.setType(ToscaNodeType.CONTRAIL_PORT);
Map<String, Object> portProperties = new HashMap<>();
}
portNodeTemplate.setProperties(portProperties);
DataModelUtil.addBindingReqFromPortToCompute(computeNodeTemplateId, portNodeTemplate);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return portNodeTemplate;
}
private void addLinkToNetworkRequirementAssignment(NodeTemplate nodeTemplate,
String connectedNodeTranslatedId,
String requirementId) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
if (nodeTemplate == null || connectedNodeTranslatedId == null) {
return;
}
requirement.setRelationship(ToscaRelationshipType.NATIVE_NETWORK_LINK_TO);
requirement.setNode(connectedNodeTranslatedId);
DataModelUtil.addRequirementAssignment(nodeTemplate, requirementId, requirement);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void updateHeatStackGroup(ServiceTemplate serviceTemplate, String heatStackGroupKey,
String memberId) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
serviceTemplate.getTopology_template().getGroups().get(heatStackGroupKey).getMembers()
.add(memberId);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void updateSubstitutionMappingRequirement(ServiceTemplate serviceTemplate,
String portReqMappingKey,
String portNodeTemplateId) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
List<String> portReqMappingValue = new ArrayList<>();
portReqMappingValue.add(portNodeTemplateId);
portReqMappingValue.add(ToscaConstants.LINK_REQUIREMENT_ID);
DataModelUtil
.addSubstitutionMappingReq(serviceTemplate, portReqMappingKey, portReqMappingValue);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void addSubstitutionMappingEntry(ServiceTemplate nestedSubstitutionServiceTemplate,
String substitutedNodeTypeId) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
SubstitutionMapping substitutionMappings = new SubstitutionMapping();
substitutionMappings.setNode_type(substitutedNodeTypeId);
DataModelUtil.addSubstitutionMapping(nestedSubstitutionServiceTemplate, substitutionMappings);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void handleInputParameters(ServiceTemplate nestedSubstitutionServiceTemplate,
TranslateTo translateTo) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
ToscaAnalyzerService toscaAnalyzerService = new ToscaAnalyzerServiceImpl();
Optional<NodeType> contrailAbstractNodeType =
nestedSubstitutionServiceTemplate.getTopology_template()
.setInputs(nestedSubstitutionServiceTemplateInputs);
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private String handleComputeNodeTemplate(TranslateTo translateTo, String computeNodeTypeId,
ServiceTemplate nestedSubstitutionServiceTemplate,
String heatStackGroupKey) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
ToscaAnalyzerService toscaAnalyzerService = new ToscaAnalyzerServiceImpl();
Optional<NodeType> contrailComputeNodeType = toscaAnalyzerService
.fetchNodeType(ToscaNodeType.CONTRAIL_COMPUTE,
computeNodeTemplate);
nestedSubstitutionServiceTemplate.getTopology_template().getGroups().get(heatStackGroupKey)
.getMembers().add(computeNodeTemplateId);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return computeNodeTemplateId;
}
private String addHeatStackGroup(TranslateTo translateTo, ServiceTemplate serviceTemplate) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
GroupDefinition serviceInstanceGroupDefinition = new GroupDefinition();
serviceInstanceGroupDefinition.setType(ToscaGroupType.HEAT_STACK);
Map<String, Object> groupProperties = new HashMap<>();
String heatStackGroupKey = translateTo.getTranslatedId() + "_group";
DataModelUtil.addGroupDefinitionToTopologyTemplate(serviceTemplate, heatStackGroupKey,
serviceInstanceGroupDefinition);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return heatStackGroupKey;
}
private void setNestedServiceTemplateGeneralDetails(TranslateTo translateTo,
ServiceTemplate
nestedSubstitutionServiceTemplate) {
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Map<String, String> nestedTemplateMetadata = new HashMap<>();
String nestedTemplateName = new ContrailTranslationHelper()
.getSubstitutionContrailServiceTemplateMetadata(translateTo.getHeatFileName(),
globalTypesImportList.addAll(
HeatToToscaUtil.createImportList(Constants.GLOBAL_SUBSTITUTION_TYPES_TEMPLATE_NAME));
nestedSubstitutionServiceTemplate.setImports(globalTypesImportList);
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private NodeTemplate createSubstitutedNodeTemplate(TranslateTo translateTo,
Resource contrailServiceTemplateResource,
String contrailServiceTemplateTranslatedId,
int numberOfPorts) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
boolean isImportAddedToServiceTemplate =
DataModelUtil
.isImportAddedToServiceTemplate(translateTo.getServiceTemplate().getImports(), Constants
String substitutedNodeTemplateId = translateTo.getTranslatedId();
DataModelUtil.addNodeTemplate(translateTo.getServiceTemplate(), substitutedNodeTemplateId,
substitutesNodeTemplate);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return substitutesNodeTemplate;
}
private void addNetworkLinkRequirements(NodeType nodeType, int numberOfPorts) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
if (nodeType.getRequirements() == null) {
List<Map<String, RequirementDefinition>> requirementList = new ArrayList<>();
for (int i = 0; i < numberOfPorts; i++) {
nodeType.setRequirements(requirementList);
}
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private int getServiceInstanceNumberOfPorts(Resource serviceInstanceResource) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
int numberOfPorts;
Object interfaceTypeProperty =
serviceInstanceResource.getProperties().get(HeatConstants.INTERFACE_LIST_PROPERTY_NAME);
} else {
numberOfPorts = 0;
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return numberOfPorts;
}
private AttachedResourceId getServiceTemplateAttachedId(TranslateTo translateTo,
Resource serviceInstanceResource) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Object serviceTemplateProperty =
serviceInstanceResource.getProperties().get("service_template");
Optional<AttachedResourceId> serviceTemplateId = HeatToToscaUtil
translateTo.getHeatOrchestrationTemplate(), translateTo.getContext(),
serviceTemplateProperty);
if (serviceTemplateId.isPresent()) {
- mdcDataDebugMessage.debugExitMessage(null, null);
return serviceTemplateId.get();
} else {
MdcDataErrorMessage.createErrorMessageAndUpdateMdc(LoggerConstants.TARGET_ENTITY_DB,
@Override
protected void translate(TranslateTo translateTo) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
NodeTemplate nodeTemplate = new NodeTemplate();
nodeTemplate.setType(ToscaNodeType.CONTRAILV2_VLAN_SUB_INTERFACE);
connectSubInterfaceToInterface(translateTo, nodeTemplate);
DataModelUtil.addNodeTemplate(translateTo.getServiceTemplate(), translateTo.getTranslatedId(),
nodeTemplate);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
//connection to shared interface is not supported
private void connectSubInterfaceToInterface(TranslateTo translateTo,
NodeTemplate vlanSubInterfaceNodeTemplate) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Object interfaceRefs =
translateTo.getResource().getProperties().get(HeatConstants.VMI_REFS_PROPERTY_NAME);
if (Objects.isNull(interfaceRefs) || !(interfaceRefs instanceof List)
+ "', therefore, this connection will be ignored in TOSCA translation.");
}
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
}
@Override
public void translate(TranslateTo translateTo) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
NodeTemplate nodeTemplate = new NodeTemplate();
nodeTemplate.setType(ToscaNodeType.CONTRAIL_VIRTUAL_NETWORK);
nodeTemplate.setProperties(TranslatorHeatToToscaPropertyConverter
nodeTemplate, translateTo.getContext()));
DataModelUtil.addNodeTemplate(translateTo.getServiceTemplate(),
translateTo.getTranslatedId(),nodeTemplate);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
}
@Override
public void translate(TranslateTo translateTo) {
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
TranslationContext context = translateTo.getContext();
FileData nestedFileData =
HeatToToscaUtil.getFileData(translateTo.getResource().getType(), context);
if(DataModelUtil.isNodeTemplateSectionMissingFromServiceTemplate(substitutionServiceTemplate)){
handleSubstitutionServiceTemplateWithoutNodeTemplates(
templateName, translateTo);
- mdcDataDebugMessage.debugExitMessage(null, null);
return;
}
NodeTemplate substitutionNodeTemplate =
//Add nested node template id to consolidation data
ConsolidationDataUtil.updateNestedNodeTemplateId(translateTo);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void handleSubstitutionServiceTemplateWithoutNodeTemplates(String templateName,
FileData nestedFileData,
NodeTemplate substitutionNodeTemplate,
String substitutionNodeTypeId) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
ServiceTemplate globalSubstitutionTemplate =
translateTo.getContext().getTranslatedServiceTemplates()
.get(Constants.GLOBAL_SUBSTITUTION_TYPES_TEMPLATE_NAME);
nodeType);
handleVlanSubInterfaceToInterfaceConnections(translateTo, nestedFileData,
substitutionNodeTemplate, nodeType);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void handleVlanSubInterfaceToInterfaceConnections(TranslateTo translateTo,
FileData nestedFileData,
NodeTemplate substitutionNodeTemplate,
NodeType nodeType) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
ContrailV2VlanToInterfaceResourceConnection linker =
new ContrailV2VlanToInterfaceResourceConnection(this, translateTo, nestedFileData,
substitutionNodeTemplate, nodeType);
linker.connect();
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
FileData nestedFileData,
NodeTemplate substitutionNodeTemplate,
NodeType nodeType) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
ContrailV2VmInterfaceToNetResourceConnection linker =
new ContrailV2VmInterfaceToNetResourceConnection(this, translateTo, nestedFileData,
substitutionNodeTemplate, nodeType);
linker.connect();
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void handleNovaToVolConnection(TranslateTo translateTo, FileData nestedFileData,
NodeTemplate substitutionNodeTemplate, NodeType nodeType) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
NovaToVolResourceConnection linker =
new NovaToVolResourceConnection(this, translateTo, nestedFileData, substitutionNodeTemplate,
nodeType);
linker.connect();
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void handleSecurityRulesToPortConnections(TranslateTo translateTo,
FileData nestedFileData,
NodeTemplate substitutionNodeTemplate,
NodeType nodeType) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
SecurityRulesToPortResourceConnection linker =
new SecurityRulesToPortResourceConnection(this, translateTo, nestedFileData,
substitutionNodeTemplate, nodeType);
linker.connect();
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void handlePortToNetConnections(TranslateTo translateTo, FileData nestedFileData,
NodeTemplate substitutionNodeTemplate,
NodeType nodeType) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
PortToNetResourceConnection linker =
new PortToNetResourceConnection(this, translateTo, nestedFileData, substitutionNodeTemplate,
nodeType);
linker.connect();
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void handleContrailPortToNetConnections(TranslateTo translateTo, FileData nestedFileData,
NodeTemplate substitutionNodeTemplate,
NodeType nodeType) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
ContrailPortToNetResourceConnection linker =
new ContrailPortToNetResourceConnection(this, translateTo, nestedFileData,
substitutionNodeTemplate, nodeType);
linker.connect();
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
}
@Override
public void translate(TranslateTo translateTo) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
NodeTemplate nodeTemplate = new NodeTemplate();
nodeTemplate.setType(ToscaNodeType.NEUTRON_PORT);
nodeTemplate.setProperties(TranslatorHeatToToscaPropertyConverter
String resourceTranslatedId = handleSecurityRulesRequirement(translateTo);
DataModelUtil
.addNodeTemplate(translateTo.getServiceTemplate(), resourceTranslatedId, nodeTemplate);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private String handleSecurityRulesRequirement(TranslateTo translateTo) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
String resourceTranslatedId = translateTo.getTranslatedId();
Map<String, Object> properties = translateTo.getResource().getProperties();
Optional<Object> securityGroups =
attachedResourceId));
});
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return resourceTranslatedId;
}
private void handleSecurityGroupResourceId(TranslateTo translateTo, String resourceTranslatedId,
AttachedResourceId securityGroupResourceId) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
List<String> supportedSecurityGroupsTypes = Collections
.singletonList(HeatResourcesTypes.NEUTRON_SECURITY_GROUP_RESOURCE_TYPE.getHeatResource());
if (securityGroupResourceId.isGetResource()) {
handleGetParam(translateTo, resourceTranslatedId, securityGroupResourceId,
supportedSecurityGroupsTypes);
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void handleGetParam(TranslateTo translateTo, String resourceTranslatedId,
AttachedResourceId securityGroupResourceId,
List<String> supportedSecurityGroupsTypes) {
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
if (!(securityGroupResourceId.getEntityId() instanceof String)) {
- mdcDataDebugMessage.debugExitMessage(null, null);
return;
}
TranslatedHeatResource translatedSharedResourceId =
&& !HeatToToscaUtil.isHeatFileNested(translateTo, translateTo.getHeatFileName())) {
if (validateResourceTypeSupportedForReqCreation(translateTo, supportedSecurityGroupsTypes,
translatedSharedResourceId.getHeatResource(), "security_groups")) {
- mdcDataDebugMessage.debugExitMessage(null, null);
return;
}
final NodeTemplate securityGroupNodeTemplate = DataModelUtil
ConsolidationEntityType.PORT, translateTo.getResourceId(),
ToscaConstants.PORT_REQUIREMENT_ID, requirement);
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void handleGetResource(TranslateTo translateTo, String resourceTranslatedId,
AttachedResourceId securityGroupResourceId,
List<String> supportedSecurityGroupsTypes) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
String resourceId = (String) securityGroupResourceId.getEntityId();
Resource securityGroupResource = HeatToToscaUtil
.getResource(translateTo.getHeatOrchestrationTemplate(), resourceId,
if (securityGroupTranslatedId.isPresent()) {
if (validateResourceTypeSupportedForReqCreation(translateTo, supportedSecurityGroupsTypes,
securityGroupResource, "security_groups")) {
- mdcDataDebugMessage.debugExitMessage(null, null);
return;
}
final NodeTemplate securityGroupNodeTemplate = DataModelUtil
ConsolidationEntityType.PORT, translateTo.getResourceId(),
ToscaConstants.PORT_REQUIREMENT_ID, requirement);
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void handleNetworkRequirement(TranslateTo translateTo, NodeTemplate nodeTemplate) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Optional<AttachedResourceId> networkResourceId =
HeatToToscaUtil.extractAttachedResourceId(translateTo, "network");
if (networkResourceId.isPresent()) {
addRequirementAssignmentForNetworkResource(translateTo, nodeTemplate, attachedResourceId);
}
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void addRequirementAssignmentForNetworkResource(TranslateTo translateTo,
NodeTemplate nodeTemplate,
AttachedResourceId attachedResourceId) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
String networkTranslatedId;
List<String> supportedNetworkTypes =
Arrays.asList(HeatResourcesTypes.NEUTRON_NET_RESOURCE_TYPE.getHeatResource(),
ToscaConstants.LINK_REQUIREMENT_ID, requirementAssignment);
}
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
List<String> supportedTypes,
Resource heatResource,
final String propertyName) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
if (!isResourceTypeSupported(heatResource, supportedTypes)) {
logger.warn(
"'" + propertyName + "' property of port resource('" + translateTo.getResourceId()
+ "') is pointing to a resource of type '" + heatResource.getType() + "' "
+ "which is not supported for this requirement. "
+ "Supported types are: " + supportedTypes.toString());
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return true;
}
- mdcDataDebugMessage.debugExitMessage(null, null);
return false;
}
@Override
protected void translate(TranslateTo translateTo) {
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
String resourceId = translateTo.getResourceId();
List<String> toscaPolicyTypes = getToscaPolicies(translateTo.getResource(), resourceId);
if (!CollectionUtils.isEmpty(toscaPolicyTypes)) {
String translatedGroupId = addGroupToTopology(translateTo, resourceId);
addPoliciesToTopology(translateTo, translatedGroupId, toscaPolicyTypes);
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void addPoliciesToTopology(TranslateTo translateTo, String policyTargetEntityId,
List<String> toscaPolicyTypes) {
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
logger.info("******** Start creating policies for resource '%s' ********",
translateTo.getResourceId());
for (int i = 0; i < toscaPolicyTypes.size(); i++) {
logger
.info("******** All policies for resource '%s' created successfully ********",
translateTo.getResourceId());
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private String getTranslatedPolicyId(TranslateTo translateTo, List<String> toscaPolicyTypes,
int policyIndex) {
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return translateTo.getResourceId() + (toscaPolicyTypes.size() > 1 ? policyIndex : "")
+ "_policy";
}
private String addGroupToTopology(TranslateTo translateTo, String resourceId) {
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
logger.info("******** Start creating group for resource '%s' ********", resourceId);
GroupDefinition group = new GroupDefinition();
group.setMembers(new ArrayList<>());
.addGroupDefinitionToTopologyTemplate(translateTo.getServiceTemplate(),
translatedGroupId, group);
logger.info("******** Creating group '%s' for resource '%s' ********", resourceId, resourceId);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return translatedGroupId;
}
}
private List<String> getToscaPolicies(Resource resource, String resourceId) {
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Map<String, Object> properties = resource.getProperties();
if (Objects.isNull(properties) || Objects.isNull(properties.get("policies"))) {
return Arrays.asList(ToscaPolicyType.PLACEMENT_ANTILOCATE);
retList.add(getToscaPolicyByHotPolicy(policy));
}
});
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return retList;
}
@Override
protected void translate(TranslateTo translateTo) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
final String heatFileName = translateTo.getHeatFileName();
Object resourceDef =
translateTo.getResource().getProperties().get(HeatConstants.RESOURCE_DEF_PROPERTY_NAME);
+ HeatResourcesTypes.RESOURCE_GROUP_RESOURCE_TYPE.getHeatResource()
+ "' with resourceDef which is not pointing to nested heat file is not supported and "
+ "will be ignored in the translation ");
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return;
}
substitutionNodeTemplate);
}
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private void handlingIndexVar(TranslateTo translateTo, NodeTemplate substitutionNodeTemplate) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
String indexVarValue = getIndexVarValue(translateTo);
replacePropertiesIndexVarValue(indexVarValue, substitutionNodeTemplate.getProperties());
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private Map<String, List> getNewIndexVarValue() {
private void replacePropertiesIndexVarValue(String indexVarValue,
Map<String, Object> properties) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
if (properties == null || properties.isEmpty()) {
return;
}
properties.put(propertyEntry.getKey(), newPropertyValue);
}
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
private Object getUpdatedPropertyValueWithIndex(String indexVarValue, Object propertyValue) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
if (propertyValue != null && propertyValue instanceof String) {
if (propertyValue.equals(indexVarValue)) {
return getNewIndexVarValue();
concatMap.put(ToscaFunctions.CONCAT.getDisplayName(), concatList);
return concatMap;
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return propertyValue; //no update is needed
} else if (propertyValue instanceof Map && !((Map) propertyValue).isEmpty()) {
replacePropertiesIndexVarValue(indexVarValue, (Map<String, Object>) propertyValue);
for (Object entry : ((List) propertyValue)) {
newPropertyValueList.add(getUpdatedPropertyValueWithIndex(indexVarValue, entry));
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return newPropertyValueList;
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return propertyValue;
}
private String getIndexVarValue(TranslateTo translateTo) {
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Object indexVar =
translateTo.getResource().getProperties().get(HeatConstants.INDEX_PROPERTY_NAME);
if (indexVar == null) {
}
if (indexVar instanceof String) {
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return (String) indexVar;
} else {
MdcDataErrorMessage.createErrorMessageAndUpdateMdc(LoggerConstants.TARGET_ENTITY_DB,
private void populateServiceTemplateFilterProperties(TranslateTo translateTo,
NodeTemplate substitutionNodeTemplate,
Map serviceTemplateFilter) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
boolean mandatory = false;
Object countValue = TranslatorHeatToToscaPropertyConverter
.getToscaPropertyValue(translateTo.getServiceTemplate(),translateTo.getResourceId(),
mandatory = true;
}
serviceTemplateFilter.put("mandatory", mandatory);
-
- mdcDataDebugMessage.debugExitMessage(null, null);
}
}
Code Review / sdc.git / commitdiff