import org.openecomp.sdc.enrichment.inter.ExternalArtifactEnricherInterface;
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.ToscaServiceModel;
import java.lang.reflect.Constructor;
import java.util.Map;
public class ExternalArtifactEnricher extends Enricher {
- private MdcDataDebugMessage mdcDataDebugMessage = new MdcDataDebugMessage();
private static String EXTERNAL_ARTIFACT_ENRICH_CONF_FILE = "ExternalArtifactConfiguration.json";
private static Collection<String> implementingClasses =
getExternalArtifactEnrichedImplClassesList();
@Override
public Map<String, List<ErrorMessage>> enrich() {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
Map<String, List<ErrorMessage>> errors = new HashMap<>();
try {
logger.debug("",e);
logger.error(e.getMessage());
}
-
- mdcDataDebugMessage.debugExitMessage(null);
return errors;
}
import org.openecomp.sdc.enrichment.inter.ExternalArtifactEnricherInterface;
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.ToscaServiceModel;
import org.openecomp.sdc.tosca.datatypes.model.Directive;
import org.openecomp.sdc.tosca.datatypes.model.NodeTemplate;
private EnrichedServiceModelDao enrichedServiceModelDao;
private ComponentDao componentDao;
private ComponentArtifactDao componentArtifactDao;
- private static MdcDataDebugMessage mdcDataDebugMessage = new MdcDataDebugMessage();
private static final String COMPONENT_PREFIX = "org.openecomp.resource.vfc.";
private final Logger LOG = LoggerFactory.getLogger(this.getClass().getName());
Version version,
ComponentEntity componentEntry,
Set<String> abstractNodeTypes) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
Map<String, List<ErrorMessage>> errors = new HashMap<>();
List<ComponentMonitoringUploadInfo> componentMonitoringUploadInfoList =
componentMonitoringUploadInfoList.forEach(
componentUploadInfo -> enrichComponentMib(vspId, version, componentUploadInfo, errors));
-
- mdcDataDebugMessage.debugExitMessage(null);
return errors;
}
private List<ComponentMonitoringUploadInfo> extractComponentMibInfo(String vspId, Version version,
ComponentEntity componentEntity,
Set<String> abstractNodeTypes) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
String componentId = componentEntity.getId();
ComponentMonitoringUploadEntity entity = new ComponentMonitoringUploadEntity();
abstractNodeTypes.forEach(unifiedComponentNodeType -> componentMonitoringUploadInfoList
.add(updComponentMibInfoByType(unifiedComponentNodeType, entity)));
-
- mdcDataDebugMessage.debugExitMessage(null);
return componentMonitoringUploadInfoList;
}
private ComponentMonitoringUploadInfo updComponentMibInfoByType(String componentName,
ComponentMonitoringUploadEntity componentMonitoringUploadEntity) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
ComponentMonitoringUploadInfo componentMonitoringUploadInfo =
new ComponentMonitoringUploadInfo();
mibArtifact,
componentMonitoringUploadInfo);
}
-
- mdcDataDebugMessage.debugExitMessage(null);
return componentMonitoringUploadInfo;
}
Version version,
ComponentMonitoringUploadInfo componentUploadInfo,
Map<String, List<ErrorMessage>> errors) {
- mdcDataDebugMessage.debugEntryMessage(null);
-
ServiceArtifact mibServiceArtifact = new ServiceArtifact();
mibServiceArtifact.setVspId(vspId);
mibServiceArtifact.setVersion(version);
enrichMibFiles(mibServiceArtifact, componentUploadInfo, errors);
-
-
- mdcDataDebugMessage.debugExitMessage(null);
}
private void enrichMibFiles(ServiceArtifact monitoringArtifact,
ComponentMonitoringUploadInfo componentMonitoringUploadInfo,
Map<String, List<ErrorMessage>> errors) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (componentMonitoringUploadInfo == null) {
return;
}
enrichMibByType(componentMonitoringUploadInfo.getVesEvent(), MonitoringUploadType.VES_EVENTS,
monitoringArtifact,
errors);
-
- mdcDataDebugMessage.debugExitMessage(null);
}
private void enrichMibByType(MonitoringArtifactInfo monitoringArtifactInfo,
MonitoringUploadType type,
ServiceArtifact mibServiceArtifact,
Map<String, List<ErrorMessage>> errors) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
if (monitoringArtifactInfo == null) {
return;
}
mibServiceArtifact.setName(monitoringArtifactInfo.getName() + File.separator + fileName);
getEnrichedServiceModelDao().storeExternalArtifact(mibServiceArtifact);
}
-
- mdcDataDebugMessage.debugExitMessage(null);
}
private EnrichedServiceModelDao getEnrichedServiceModelDao() {
import org.openecomp.sdc.datatypes.error.ErrorMessage;
import org.openecomp.sdc.enrichment.EnrichmentInfo;
import org.openecomp.sdc.enrichment.inter.ExternalArtifactEnricherInterface;
-import org.openecomp.sdc.logging.context.impl.MdcDataDebugMessage;
import org.openecomp.sdc.tosca.datatypes.ToscaServiceModel;
import org.openecomp.sdc.vendorsoftwareproduct.dao.ComponentDao;
import org.openecomp.sdc.vendorsoftwareproduct.dao.ComponentDaoFactory;
private ComponentDao componentDao;
private ProcessDao processDao;
- private static MdcDataDebugMessage mdcDataDebugMessage = new MdcDataDebugMessage();
private EnrichedServiceModelDao enrichedServiceModelDao;
@Override
Map<String, List<ErrorMessage>> enrichComponent(ComponentEntity componentEntry, String vspId,
Version version) {
- mdcDataDebugMessage.debugEntryMessage("LifeCycleOperationArtifactEnricher vspId ",
- vspId);
-
Map<String, List<ErrorMessage>> errors = new HashMap<>();
enrichComponentProcessArtifact(componentEntry, vspId, version, errors);
-
- mdcDataDebugMessage.debugExitMessage("LifeCycleOperationArtifactEnricher vspId ",
- vspId);
return errors;
}
void enrichComponentProcessArtifact(ComponentEntity componentEntity,
String vspId, Version version,
Map<String, List<ErrorMessage>> errors) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
String componentId = componentEntity.getId();
ProcessEntity processEntity = new ProcessEntity(vspId, version, componentId, null);
final Collection<ProcessEntity> processes = getProcessDao().list(processEntity);
enrichServiceArtifact(componentProcessInfo, processServiceArtifact);
}
});
-
- mdcDataDebugMessage.debugExitMessage(null);
}
void enrichServiceArtifact(ComponentProcessInfo componentProcessInfo,
ServiceArtifact processServiceArtifact) {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
processServiceArtifact.setName(componentProcessInfo.getName());
processServiceArtifact.setContentData(FileUtils.toByteArray(componentProcessInfo.getContent()));
getEnrichedServiceModelDao().storeExternalArtifact(processServiceArtifact);
- mdcDataDebugMessage.debugExitMessage(null);
}
private ComponentDao getComponentDao() {
import org.openecomp.sdc.datatypes.error.ErrorMessage;
import org.openecomp.sdc.enrichment.EnrichmentInfo;
import org.openecomp.sdc.enrichment.inter.ExternalArtifactEnricherInterface;
-import org.openecomp.sdc.logging.context.impl.MdcDataDebugMessage;
import org.openecomp.sdc.tosca.datatypes.ToscaServiceModel;
import org.openecomp.sdc.vendorsoftwareproduct.VendorSoftwareProductConstants;
import org.openecomp.sdc.vendorsoftwareproduct.dao.VendorSoftwareProductInfoDao;
* Created by Talio on 11/24/2016
*/
public class VspInformationArtifactEnricher implements ExternalArtifactEnricherInterface {
- private static MdcDataDebugMessage mdcDataDebugMessage = new MdcDataDebugMessage();
private static InformationArtifactGenerator informationArtifactGenerator =
InformationArtifactGeneratorFactory.getInstance().createInterface();
private EnrichedServiceModelDao enrichedServiceModelDao =
private Map<String, List<ErrorMessage>> enrichInformationArtifact(String vspId, Version version)
throws IOException {
-
-
- mdcDataDebugMessage.debugEntryMessage(null);
-
Map<String, List<ErrorMessage>> errors = new HashMap<>();
ByteBuffer infoArtifactByteBuffer = ByteBuffer.wrap(informationArtifactGenerator.generate(
vspId, version).getBytes());
errorList.add(new ErrorMessage(ErrorLevel.ERROR, String.format(
"Cannot enrich information artifact for vendor software product with id %s and version %s",
vspId, version.toString())));
-
- mdcDataDebugMessage.debugExitMessage(null);
return errors;
}
enrichInformationArtifact(vspId, version, infoArtifactByteBuffer);
-
- mdcDataDebugMessage.debugExitMessage(null);
return errors;
}
import org.apache.commons.lang3.StringUtils;
import org.openecomp.sdc.datatypes.error.ErrorMessage;
-import org.openecomp.sdc.logging.context.impl.MdcDataDebugMessage;
import org.openecomp.sdc.tosca.datatypes.ToscaServiceModel;
import org.openecomp.sdc.tosca.datatypes.model.NodeTemplate;
import org.openecomp.sdc.tosca.datatypes.model.RequirementAssignment;
public class AbstractSubstituteToscaEnricher {
private ToscaAnalyzerService toscaAnalyzerService ;
- private static MdcDataDebugMessage mdcDataDebugMessage = new MdcDataDebugMessage();
private ComponentQuestionnaireData componentQuestionnaireData;
public Map<String,List<ErrorMessage>> enrich(ToscaServiceModel toscaModel, String vspId, Version
version) {
-
- mdcDataDebugMessage.debugEntryMessage(vspId, version.toString());
-
componentQuestionnaireData = getComponentQuestionnaireData();
toscaAnalyzerService = new ToscaAnalyzerServiceImpl();
componentDisplayNameToNodeTempalteIds);
}
});
-
- mdcDataDebugMessage.debugExitMessage(vspId, version.toString());
return errors;
}
import org.openecomp.core.utilities.orchestration.OnboardingTypesEnum;
import org.openecomp.sdc.datatypes.error.ErrorMessage;
import org.openecomp.sdc.enrichment.impl.tosca.model.PortMirroringConnectionPointDescription;
-import org.openecomp.sdc.logging.context.impl.MdcDataDebugMessage;
import org.openecomp.sdc.tosca.datatypes.ToscaElementTypes;
import org.openecomp.sdc.tosca.datatypes.ToscaNodeType;
import org.openecomp.sdc.tosca.datatypes.ToscaServiceModel;
//Map of substitution service template name and the list of ports with link requirement from
// the abstract
private Map<String, List<String>> portNodeTemplateIdsFromAbstract = new HashMap<>();
- private static MdcDataDebugMessage mdcDataDebugMessage = new MdcDataDebugMessage();
private Map<String, ServiceTemplate> globalTypesServiceTemplate =
GlobalTypesGenerator.getGlobalTypesServiceTemplate(OnboardingTypesEnum.ZIP);
* @return the map Error descriptor map
*/
public Map<String, List<ErrorMessage>> enrich(ToscaServiceModel toscaServiceModel) {
- mdcDataDebugMessage.debugEntryMessage(null);
Map<String, List<ErrorMessage>> errors = new HashMap<>();
Map<String, ServiceTemplate> serviceTemplates = toscaServiceModel.getServiceTemplates();
serviceTemplates.entrySet().stream()
filterExternalPorts(toscaServiceModel);
//Handle external port changes
handleExternalPorts(toscaServiceModel);
- mdcDataDebugMessage.debugExitMessage(null);
return errors;
}
import org.openecomp.sdc.datatypes.error.ErrorLevel;
import org.openecomp.sdc.datatypes.error.ErrorMessage;
import org.openecomp.sdc.enrichment.inter.Enricher;
-import org.openecomp.sdc.logging.context.impl.MdcDataDebugMessage;
import org.openecomp.sdc.tosca.datatypes.ToscaServiceModel;
import java.util.Arrays;
import java.util.Map;
public class ToscaEnricher extends Enricher {
-
- private static MdcDataDebugMessage mdcDataDebugMessage = new MdcDataDebugMessage();
-
@Override
public Map<String, List<ErrorMessage>> enrich() {
Map<String, List<ErrorMessage>> errors = new HashMap<>();
}
private Map<String, List<ErrorMessage>> enrichAbstractSubstitute() {
- mdcDataDebugMessage.debugEntryMessage(null, null);
-
Map<String, List<ErrorMessage>> enrichErrors = new HashMap<>();
ToscaServiceModel toscaModel = (ToscaServiceModel) model;
enrichErrors.put("Tosca Enrich", Arrays.asList(new ErrorMessage(ErrorLevel.ERROR, e
.getMessage())));
}
-
- mdcDataDebugMessage.debugExitMessage(null, null);
return enrichErrors;
}
private Map<String, List<ErrorMessage>> enrichPortMirroring() {
- mdcDataDebugMessage.debugEntryMessage(null, null);
Map<String, List<ErrorMessage>> enrichErrors = new HashMap<>();
ToscaServiceModel toscaModel = (ToscaServiceModel) model;
PortMirroringEnricher portMirroringEnricher = new PortMirroringEnricher();
enrichErrors.put("Tosca Enrich", Arrays.asList(new ErrorMessage(ErrorLevel.ERROR, e
.getMessage())));
}
- mdcDataDebugMessage.debugExitMessage(null, null);
return enrichErrors;
}
}