package org.openecomp.vid.asdc.parser; import org.openecomp.sdc.tosca.parser.api.ISdcCsarHelper; import org.openecomp.sdc.tosca.parser.exceptions.SdcToscaParserException; import org.openecomp.sdc.tosca.parser.impl.FilterType; import org.openecomp.sdc.tosca.parser.impl.SdcToscaParserFactory; import org.openecomp.sdc.toscaparser.api.Group; import org.openecomp.sdc.toscaparser.api.NodeTemplate; import org.openecomp.sdc.toscaparser.api.Property; import org.openecomp.sdc.toscaparser.api.parameters.Input; import org.openecomp.vid.asdc.beans.Service; import org.openecomp.vid.model.*; import java.nio.file.Path; import java.util.HashMap; import java.util.List; import java.util.Map; public class ToscaParserImpl2 { public class Constants { public final static String uuid = "UUID"; public final static String description = "description"; public final static String serviceType = "serviceType"; public final static String serviceRole = "serviceRole"; public final static String ecompGeneratedNaming = "ecompGeneratedNaming"; public final static String customizationUUID = "customizationUUID"; public final static String vfModuleModelVersion = "vfModuleModelVersion"; public final static String vfModuleModelCustomizationUUID = "vfModuleModelCustomizationUUID"; public final static String volume_group = "volume_group"; public final static String vfModuleModelInvariantUUID = "vfModuleModelInvariantUUID"; public final static String vfModuleModelUUID = "vfModuleModelUUID"; public final static String invariantUUID = "invariantUUID"; public final static String version = "version"; public final static String name = "name"; public final static String category = "category"; public final static String vfModuleModelName = "vfModuleModelName"; public final static String getInput = "get_input"; } public ToscaParserImpl2() { } public ServiceModel makeServiceModel(Path path, Service asdcServiceMetadata) throws Exception { ServiceModel serviceModel = new ServiceModel(); SdcToscaParserFactory factory = SdcToscaParserFactory.getInstance(); ISdcCsarHelper sdcCsarHelper = factory.getSdcCsarHelper(path.toFile().getAbsolutePath()); //, false); serviceModel.setService(extractServiceFromCsar(asdcServiceMetadata, sdcCsarHelper)); serviceModel.setVolumeGroups(extractVolumeGroups(sdcCsarHelper)); serviceModel.setVfModules(extractVfModuleFromCsar(sdcCsarHelper)); serviceModel.setVnfs(extractVnfsFromCsar(serviceModel,sdcCsarHelper)); serviceModel.setNetworks(extractNetworksFromCsar(sdcCsarHelper)); return serviceModel; } private org.openecomp.vid.model.Service extractServiceFromCsar(Service asdcServiceMetadata, ISdcCsarHelper csarHelper) throws SdcToscaParserException { org.openecomp.vid.model.Service service = new org.openecomp.vid.model.Service(); service.setName(csarHelper.getServiceMetadata().getValue(Constants.name)); service.setCategory(csarHelper.getServiceMetadata().getValue(Constants.category)); service.setInvariantUuid(csarHelper.getServiceMetadata().getValue(Constants.invariantUUID)); service.setUuid(csarHelper.getServiceMetadata().getValue(Constants.uuid)); service.setVersion(asdcServiceMetadata.getVersion()); service.setDescription(csarHelper.getServiceMetadata().getValue(Constants.description)); service.setInputs(inputsListToInputsMap(csarHelper.getServiceInputs())); service.setServiceEcompNaming(csarHelper.getServiceMetadata().getValue(Constants.ecompGeneratedNaming)); service.setServiceType(csarHelper.getServiceMetadata().getValue(Constants.serviceType)); service.setServiceRole(csarHelper.getServiceMetadata().getValue(Constants.serviceRole)); return service; } private Map extractVnfsFromCsar(ServiceModel serviceModel,ISdcCsarHelper csarHelper) { List nodeTemplates = csarHelper.getServiceVfList(); Map vnfsMaps = new HashMap(); for (NodeTemplate nodeTemplate : nodeTemplates) { VNF vnf = new VNF(); populateNodeFromNodeTemplate(nodeTemplate, csarHelper, vnf); vnf.setModelCustomizationName(nodeTemplate.getName()); Map vfModuleHashMap = getVfModulesFromVF(csarHelper, vnf.getCustomizationUuid()); vnf.setVfModules(vfModuleHashMap); Map volumeGroupMap = getVolumeGroupsFromVF(csarHelper, vnf.getCustomizationUuid()); vnf.setVolumeGroups(volumeGroupMap); vnfsMaps.put(nodeTemplate.getName(), vnf); } return vnfsMaps; } private Map getVfModulesFromVF(ISdcCsarHelper csarHelper, String vfUuid) { Map vfModuleHashMap = new HashMap(); for (Group group : csarHelper.getVfModulesByVf(vfUuid)) { vfModuleHashMap.put(group.getName(), populateVfModuleFromGroup(group)); } return vfModuleHashMap; } private Map getVolumeGroupsFromVF(ISdcCsarHelper csarHelper, String vfCustomizationUuid) { Map volumeGroupMap = new HashMap(); List groups = csarHelper.getVfModulesByVf(vfCustomizationUuid); for (Group group : groups) { boolean isVolumeGroup = Boolean.valueOf(group.getPropertyValue(Constants.volume_group).toString()); if (isVolumeGroup) { volumeGroupMap.put(group.getName(), populateVolumeGroupFromGroup(group)); } } return volumeGroupMap; } private Map extractNetworksFromCsar(ISdcCsarHelper csarHelper) { List nodeTemplates = csarHelper.getServiceVlList(); Map networksMap = new HashMap(); for (NodeTemplate nodeTemplate : nodeTemplates) { Network newNetwork = new Network(); populateNodeFromNodeTemplate(nodeTemplate, csarHelper, newNetwork); newNetwork.setModelCustomizationName(nodeTemplate.getName()); networksMap.put(nodeTemplate.getName(), newNetwork); } return networksMap; } private Map extractVfModuleFromCsar(ISdcCsarHelper csarHelper) { List serviceVfList = csarHelper.getServiceVfList(); HashMap vfModuleHashMap = new HashMap<>(); for (NodeTemplate nodeTemplate : serviceVfList) { Map nodeTemplateVfModule = getVfModulesFromVF(csarHelper, nodeTemplate.getMetaData().getValue(Constants.customizationUUID)); vfModuleHashMap.putAll(nodeTemplateVfModule); } return vfModuleHashMap; } private Map extractVolumeGroups(ISdcCsarHelper csarHelper) { HashMap volumeGroupHashMap = new HashMap<>(); for (NodeTemplate nodeTemplate : csarHelper.getServiceVfList()) { Map nodeTemplateVolumeGroups = getVolumeGroupsFromVF(csarHelper, csarHelper.getNodeTemplateCustomizationUuid(nodeTemplate)); volumeGroupHashMap.putAll(nodeTemplateVolumeGroups); } return volumeGroupHashMap; } private Map inputsListToInputsMap(List inputList) { Map inputs = new HashMap<>(); for (org.openecomp.sdc.toscaparser.api.parameters.Input input : inputList) { inputs.put(input.getName(), convertInput(input, new org.openecomp.vid.asdc.beans.tosca.Input())); } return inputs; } private Node populateNodeFromNodeTemplate(NodeTemplate nodeTemplate, ISdcCsarHelper csarHelper, Node newNode) { newNode.setCustomizationUuid(csarHelper.getNodeTemplateCustomizationUuid(nodeTemplate)); newNode.setDescription(nodeTemplate.getMetaData().getValue(Constants.description)); newNode.setInvariantUuid(nodeTemplate.getMetaData().getValue(Constants.invariantUUID)); newNode.setUuid(nodeTemplate.getMetaData().getValue(Constants.uuid)); newNode.setName(nodeTemplate.getMetaData().getValue(Constants.name)); newNode.setVersion(nodeTemplate.getMetaData().getValue(Constants.version)); newNode.setInputs(extractInputsAndCommandsForNodeTemplate(nodeTemplate, csarHelper, newNode)); Map propertiesMap = setPropertiesOfVnf(nodeTemplate.getPropertiesObjects()); newNode.setProperties(propertiesMap); return newNode; } private VfModule populateVfModuleFromGroup(Group group){ VfModule vfModule = new VfModule(); vfModule.setVersion(group.getMetadata().getValue(Constants.vfModuleModelVersion)); vfModule.setCustomizationUuid(group.getMetadata().getValue(Constants.vfModuleModelCustomizationUUID)); vfModule.setModelCustomizationName(group.getMetadata().getValue(Constants.vfModuleModelName)); vfModule.setName(group.getMetadata().getValue(Constants.vfModuleModelName)); vfModule.setVolumeGroupAllowed(Boolean.valueOf((group.getPropertyValue(Constants.volume_group)).toString())); vfModule.setDescription(group.getDescription()); vfModule.setInvariantUuid(group.getMetadata().getValue(Constants.vfModuleModelInvariantUUID)); vfModule.setUuid(group.getMetadata().getValue(Constants.vfModuleModelUUID)); return vfModule; } private VolumeGroup populateVolumeGroupFromGroup(Group group){ VolumeGroup volumeGroup = new VolumeGroup(); volumeGroup.setDescription(group.getDescription()); volumeGroup.setInvariantUuid(group.getMetadata().getValue(Constants.vfModuleModelInvariantUUID)); volumeGroup.setName(group.getMetadata().getValue(Constants.vfModuleModelName)); volumeGroup.setModelCustomizationName(group.getMetadata().getValue(Constants.vfModuleModelName)); volumeGroup.setVersion(group.getMetadata().getValue(Constants.vfModuleModelVersion)); volumeGroup.setUuid(group.getMetadata().getValue(Constants.vfModuleModelUUID)); volumeGroup.setCustomizationUuid(group.getMetadata().getValue(Constants.vfModuleModelCustomizationUUID)); return volumeGroup; } private Map extractInputsAndCommandsForNodeTemplate(NodeTemplate nodeTemplate, ISdcCsarHelper csarHelper, Node newNode){ Map inputMap = new HashMap<>(); Map commandPropertyMap = new HashMap<>(); List inputs = csarHelper.getServiceInputs(); Map properties = csarHelper.filterNodeTemplatePropertiesByValue(nodeTemplate, FilterType.CONTAINS, Constants.getInput); for (Map.Entry property : properties.entrySet()) { String inputKey = property.getValue(); String key = extractInputValue(inputKey); for (Input input: inputs){ if(input.getName().equals(key)){ org.openecomp.vid.asdc.beans.tosca.Input localInput = new org.openecomp.vid.asdc.beans.tosca.Input(); localInput = convertInput(input, localInput); String name = property.getKey(); commandPropertyMap.put(name, extractCommands(name, key)); inputMap.put(name, localInput); } } } newNode.setCommands(commandPropertyMap); return inputMap; } private String extractInputValue(String inputKey) { return inputKey.substring(inputKey.indexOf(":") + 1); } private org.openecomp.vid.asdc.beans.tosca.Input convertInput(Input parserInput, org.openecomp.vid.asdc.beans.tosca.Input localInput){ localInput.setDefault(parserInput.getDefault()); localInput.setDescription(parserInput.getDescription()); localInput.setRequired(parserInput.isRequired()); localInput.setType(parserInput.getType()); localInput.setConstraints(parserInput.getConstraints()); // localInput.setentry_schema() return localInput; } private CommandProperty extractCommands(String displayName, String inputName){ CommandProperty commandProperty = new CommandProperty(); commandProperty.setDisplayName(displayName); commandProperty.setCommand(Constants.getInput); commandProperty.setInputName(inputName); return commandProperty; } private Map setPropertiesOfVnf(List properties) { Map propertiesMap = new HashMap(); for (Property property : properties) { propertiesMap.put(property.getName(), property.getValue().toString()); } return propertiesMap; } }