summaryrefslogtreecommitdiffstats
path: root/openecomp-be/backend/openecomp-sdc-vendor-software-product-manager/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/impl/NicManagerImpl.java
diff options
context:
space:
mode:
Diffstat (limited to 'openecomp-be/backend/openecomp-sdc-vendor-software-product-manager/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/impl/NicManagerImpl.java')
-rw-r--r--openecomp-be/backend/openecomp-sdc-vendor-software-product-manager/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/impl/NicManagerImpl.java331
1 files changed, 149 insertions, 182 deletions
diff --git a/openecomp-be/backend/openecomp-sdc-vendor-software-product-manager/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/impl/NicManagerImpl.java b/openecomp-be/backend/openecomp-sdc-vendor-software-product-manager/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/impl/NicManagerImpl.java
index 0ed58a7703..0cf85d3acd 100644
--- a/openecomp-be/backend/openecomp-sdc-vendor-software-product-manager/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/impl/NicManagerImpl.java
+++ b/openecomp-be/backend/openecomp-sdc-vendor-software-product-manager/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/impl/NicManagerImpl.java
@@ -13,9 +13,11 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-
package org.openecomp.sdc.vendorsoftwareproduct.impl;
+import java.util.Collection;
+import java.util.Map;
+import java.util.stream.Collectors;
import org.apache.commons.collections4.CollectionUtils;
import org.openecomp.sdc.common.errors.CoreException;
import org.openecomp.sdc.common.errors.ErrorCode;
@@ -28,7 +30,12 @@ import org.openecomp.sdc.vendorsoftwareproduct.dao.VendorSoftwareProductInfoDao;
import org.openecomp.sdc.vendorsoftwareproduct.dao.type.NetworkEntity;
import org.openecomp.sdc.vendorsoftwareproduct.dao.type.NicEntity;
import org.openecomp.sdc.vendorsoftwareproduct.dao.type.VspDetails;
-import org.openecomp.sdc.vendorsoftwareproduct.errors.*;
+import org.openecomp.sdc.vendorsoftwareproduct.errors.DeleteNicErrorBuilder;
+import org.openecomp.sdc.vendorsoftwareproduct.errors.DuplicateNicInComponentErrorBuilder;
+import org.openecomp.sdc.vendorsoftwareproduct.errors.NicErrorBuilder;
+import org.openecomp.sdc.vendorsoftwareproduct.errors.NicInternalNetworkErrorBuilder;
+import org.openecomp.sdc.vendorsoftwareproduct.errors.NicNetworkIdNotAllowedExternalNetworkErrorBuilder;
+import org.openecomp.sdc.vendorsoftwareproduct.errors.NotSupportedHeatOnboardMethodErrorBuilder;
import org.openecomp.sdc.vendorsoftwareproduct.services.schemagenerator.SchemaGenerator;
import org.openecomp.sdc.vendorsoftwareproduct.types.CompositionEntityResponse;
import org.openecomp.sdc.vendorsoftwareproduct.types.QuestionnaireResponse;
@@ -42,202 +49,162 @@ import org.openecomp.sdc.vendorsoftwareproduct.types.schemagenerator.SchemaTempl
import org.openecomp.sdc.versioning.VersioningUtil;
import org.openecomp.sdc.versioning.dao.types.Version;
-import java.util.Collection;
-import java.util.Map;
-import java.util.stream.Collectors;
-
public class NicManagerImpl implements NicManager {
- private final NicDao nicDao;
- private final CompositionEntityDataManager compositionEntityDataManager;
- private final NetworkManager networkManager;
- private final VendorSoftwareProductInfoDao vspInfoDao;
-
- public NicManagerImpl(NicDao nicDao,
- CompositionEntityDataManager compositionEntityDataManager,
- NetworkManager networkManager,
- VendorSoftwareProductInfoDao vspInfoDao) {
- this.nicDao = nicDao;
- this.compositionEntityDataManager = compositionEntityDataManager;
- this.networkManager = networkManager;
- this.vspInfoDao = vspInfoDao;
- }
-
- @Override
- public Collection<NicEntity> listNics(String vspId, Version version, String componentId) {
- Collection<NicEntity> nics = nicDao.list(new NicEntity(vspId, version, componentId, null));
-
- if (!nics.isEmpty()) {
- Map<String, String> networksNameById = listNetworksNameById(vspId, version);
- nics.forEach(nicEntity -> {
- Nic nic = nicEntity.getNicCompositionData();
- nic.setNetworkName(networksNameById.get(nic.getNetworkId()));
- nicEntity.setNicCompositionData(nic);
- });
+
+ private final NicDao nicDao;
+ private final CompositionEntityDataManager compositionEntityDataManager;
+ private final NetworkManager networkManager;
+ private final VendorSoftwareProductInfoDao vspInfoDao;
+
+ public NicManagerImpl(NicDao nicDao, CompositionEntityDataManager compositionEntityDataManager, NetworkManager networkManager,
+ VendorSoftwareProductInfoDao vspInfoDao) {
+ this.nicDao = nicDao;
+ this.compositionEntityDataManager = compositionEntityDataManager;
+ this.networkManager = networkManager;
+ this.vspInfoDao = vspInfoDao;
}
- return nics;
- }
-
- private Map<String, String> listNetworksNameById(String vspId, Version version) {
- Collection<NetworkEntity> networks = networkManager.listNetworks(vspId, version);
- return networks.stream().collect(Collectors.toMap(NetworkEntity::getId,
- networkEntity -> networkEntity.getNetworkCompositionData().getName()));
- }
-
- @Override
- public NicEntity createNic(NicEntity nic) {
- NicEntity createdNic;
- if (!vspInfoDao.isManual(nic.getVspId(), nic.getVersion())) {
- ErrorCode onboardingMethodUpdateErrorCode = NotSupportedHeatOnboardMethodErrorBuilder
- .getAddNicNotSupportedHeatOnboardMethodErrorBuilder();
- throw new CoreException(onboardingMethodUpdateErrorCode);
- } else {
- validateNic(nic);
- createdNic = compositionEntityDataManager.createNic(nic);
+
+ @Override
+ public Collection<NicEntity> listNics(String vspId, Version version, String componentId) {
+ Collection<NicEntity> nics = nicDao.list(new NicEntity(vspId, version, componentId, null));
+ if (!nics.isEmpty()) {
+ Map<String, String> networksNameById = listNetworksNameById(vspId, version);
+ nics.forEach(nicEntity -> {
+ Nic nic = nicEntity.getNicCompositionData();
+ nic.setNetworkName(networksNameById.get(nic.getNetworkId()));
+ nicEntity.setNicCompositionData(nic);
+ });
+ }
+ return nics;
}
- return createdNic;
- }
-
-
- private void validateNic(NicEntity nic) {
- Collection<NicEntity> listNics = listNics(nic.getVspId(), nic.getVersion(), nic
- .getComponentId());
- String networkId = nic.getNicCompositionData().getNetworkId();
- NetworkType networkType = nic.getNicCompositionData().getNetworkType();
- String networkDescription = nic.getNicCompositionData().getNetworkDescription();
-
- if (!nic.getNicCompositionData().getName()
- .matches(VendorSoftwareProductConstants.NAME_PATTERN)) {
- ErrorCode errorCode = NicErrorBuilder
- .getNicNameFormatErrorBuilder(VendorSoftwareProductConstants.NAME_PATTERN);
- throw new CoreException(errorCode);
+
+ private Map<String, String> listNetworksNameById(String vspId, Version version) {
+ Collection<NetworkEntity> networks = networkManager.listNetworks(vspId, version);
+ return networks.stream()
+ .collect(Collectors.toMap(NetworkEntity::getId, networkEntity -> networkEntity.getNetworkCompositionData().getName()));
}
- validateNics(nic, listNics);
+ @Override
+ public NicEntity createNic(NicEntity nic) {
+ NicEntity createdNic;
+ if (!vspInfoDao.isManual(nic.getVspId(), nic.getVersion())) {
+ ErrorCode onboardingMethodUpdateErrorCode = NotSupportedHeatOnboardMethodErrorBuilder
+ .getAddNicNotSupportedHeatOnboardMethodErrorBuilder();
+ throw new CoreException(onboardingMethodUpdateErrorCode);
+ } else {
+ validateNic(nic);
+ createdNic = compositionEntityDataManager.createNic(nic);
+ }
+ return createdNic;
+ }
+
+ private void validateNic(NicEntity nic) {
+ Collection<NicEntity> listNics = listNics(nic.getVspId(), nic.getVersion(), nic.getComponentId());
+ String networkId = nic.getNicCompositionData().getNetworkId();
+ NetworkType networkType = nic.getNicCompositionData().getNetworkType();
+ String networkDescription = nic.getNicCompositionData().getNetworkDescription();
+ if (!nic.getNicCompositionData().getName().matches(VendorSoftwareProductConstants.NAME_PATTERN)) {
+ ErrorCode errorCode = NicErrorBuilder.getNicNameFormatErrorBuilder(VendorSoftwareProductConstants.NAME_PATTERN);
+ throw new CoreException(errorCode);
+ }
+ validateNics(nic, listNics);
+ if (networkType.equals(NetworkType.Internal)) {
+ validateInternalNetworkType(nic, networkId, networkDescription);
+ } else if (networkType.equals(NetworkType.External) && !(networkId == null || networkId.isEmpty())) {
+ final ErrorCode nicNetworkIdNotAllowedExternalNetworkErrorBuilder = new NicNetworkIdNotAllowedExternalNetworkErrorBuilder().build();
+ throw new CoreException(nicNetworkIdNotAllowedExternalNetworkErrorBuilder);
+ }
+ }
- if (networkType.equals(NetworkType.Internal)) {
- validateInternalNetworkType(nic, networkId, networkDescription);
+ private void validateInternalNetworkType(NicEntity nic, String networkId, String networkDescription) {
+ if (!(networkId == null || networkId.isEmpty())) {
+ networkManager.getNetwork(nic.getVspId(), nic.getVersion(), networkId);
+ }
+ if (!(networkDescription == null || networkDescription.isEmpty())) {
+ final ErrorCode nicNetworkDescriptionErrorBuilder = NicInternalNetworkErrorBuilder.getNetworkDescriptionInternalNetworkErrorBuilder();
+ throw new CoreException(nicNetworkDescriptionErrorBuilder);
+ }
+ }
+
+ private void validateNics(NicEntity nic, Collection<NicEntity> listNics) {
+ listNics.forEach(nicEntity -> {
+ Nic nicdata = nicEntity.getNicCompositionData();
+ if (nic.getNicCompositionData().getName().equalsIgnoreCase(nicdata.getName())) {
+ final ErrorCode duplicateNicInComponentErrorBuilder = new DuplicateNicInComponentErrorBuilder(nic.getNicCompositionData().getName(),
+ nic.getComponentId()).build();
+ throw new CoreException(duplicateNicInComponentErrorBuilder);
+ }
+ });
+ }
- } else if (networkType.equals(NetworkType.External)
- && !(networkId == null || networkId.isEmpty())) {
- final ErrorCode nicNetworkIdNotAllowedExternalNetworkErrorBuilder =
- new NicNetworkIdNotAllowedExternalNetworkErrorBuilder().build();
- throw new CoreException(nicNetworkIdNotAllowedExternalNetworkErrorBuilder);
+ @Override
+ public CompositionEntityResponse<Nic> getNic(String vspId, Version version, String componentId, String nicId) {
+ NicEntity nicEntity = getValidatedNic(vspId, version, componentId, nicId);
+ Nic nic = nicEntity.getNicCompositionData();
+ NicCompositionSchemaInput schemaInput = new NicCompositionSchemaInput();
+ schemaInput.setManual(vspInfoDao.isManual(vspId, version));
+ schemaInput.setNic(nic);
+ Map<String, String> networksNameById = listNetworksNameById(vspId, version);
+ nic.setNetworkName(networksNameById.get(nic.getNetworkId()));
+ schemaInput.setNetworkIds(networksNameById.keySet());
+ CompositionEntityResponse<Nic> response = new CompositionEntityResponse<>();
+ response.setId(nicId);
+ response.setData(nic);
+ response.setSchema(getNicCompositionSchema(schemaInput));
+ return response;
}
- }
- private void validateInternalNetworkType(NicEntity nic, String networkId,
- String networkDescription) {
- if (!(networkId == null || networkId.isEmpty())) {
- networkManager.getNetwork(nic.getVspId(), nic.getVersion(), networkId);
+ private NicEntity getValidatedNic(String vspId, Version version, String componentId, String nicId) {
+ NicEntity retrieved = nicDao.get(new NicEntity(vspId, version, componentId, nicId));
+ VersioningUtil.validateEntityExistence(retrieved, new NicEntity(vspId, version, componentId, nicId), VspDetails.ENTITY_TYPE);
+ return retrieved;
}
- if (!(networkDescription == null || networkDescription.isEmpty())) {
- final ErrorCode nicNetworkDescriptionErrorBuilder =
- NicInternalNetworkErrorBuilder.getNetworkDescriptionInternalNetworkErrorBuilder();
- throw new CoreException(nicNetworkDescriptionErrorBuilder);
+ @Override
+ public void deleteNic(String vspId, Version version, String componentId, String nicId) {
+ if (!vspInfoDao.isManual(vspId, version)) {
+ final ErrorCode deleteNicErrorBuilder = DeleteNicErrorBuilder.getDeleteNicForHeatOnboardedVspErrorBuilder();
+ throw new CoreException(deleteNicErrorBuilder);
+ }
+ NicEntity nicEntity = getValidatedNic(vspId, version, componentId, nicId);
+ nicDao.delete(nicEntity);
}
- }
-
- private void validateNics(NicEntity nic, Collection<NicEntity> listNics) {
- listNics.forEach(nicEntity -> {
- Nic nicdata = nicEntity.getNicCompositionData();
- if (nic.getNicCompositionData().getName().equalsIgnoreCase(nicdata.getName())) {
- final ErrorCode duplicateNicInComponentErrorBuilder =
- new DuplicateNicInComponentErrorBuilder(nic.getNicCompositionData().getName(),
- nic.getComponentId()).build();
- throw new CoreException(duplicateNicInComponentErrorBuilder);
- }
-
- });
- }
-
- @Override
- public CompositionEntityResponse<Nic> getNic(String vspId, Version version, String componentId,
- String nicId) {
- NicEntity nicEntity = getValidatedNic(vspId, version, componentId, nicId);
- Nic nic = nicEntity.getNicCompositionData();
-
- NicCompositionSchemaInput schemaInput = new NicCompositionSchemaInput();
- schemaInput.setManual(vspInfoDao.isManual(vspId, version));
- schemaInput.setNic(nic);
- Map<String, String> networksNameById = listNetworksNameById(vspId, version);
- nic.setNetworkName(networksNameById.get(nic.getNetworkId()));
- schemaInput.setNetworkIds(networksNameById.keySet());
-
- CompositionEntityResponse<Nic> response = new CompositionEntityResponse<>();
- response.setId(nicId);
- response.setData(nic);
- response.setSchema(getNicCompositionSchema(schemaInput));
- return response;
- }
-
-
- private NicEntity getValidatedNic(String vspId, Version version, String componentId,
- String nicId) {
- NicEntity retrieved = nicDao.get(new NicEntity(vspId, version, componentId, nicId));
- VersioningUtil
- .validateEntityExistence(retrieved, new NicEntity(vspId, version, componentId, nicId),
- VspDetails.ENTITY_TYPE);
- return retrieved;
- }
-
- @Override
- public void deleteNic(String vspId, Version version, String componentId, String nicId) {
- if (!vspInfoDao.isManual(vspId, version)) {
- final ErrorCode deleteNicErrorBuilder =
- DeleteNicErrorBuilder.getDeleteNicForHeatOnboardedVspErrorBuilder();
- throw new CoreException(deleteNicErrorBuilder);
+
+ @Override
+ public CompositionEntityValidationData updateNic(NicEntity nic) {
+ NicEntity retrieved = getValidatedNic(nic.getVspId(), nic.getVersion(), nic.getComponentId(), nic.getId());
+ NicCompositionSchemaInput schemaInput = new NicCompositionSchemaInput();
+ schemaInput.setManual(vspInfoDao.isManual(nic.getVspId(), nic.getVersion()));
+ schemaInput.setNic(retrieved.getNicCompositionData());
+ CompositionEntityValidationData validationData = compositionEntityDataManager
+ .validateEntity(nic, SchemaTemplateContext.composition, schemaInput);
+ if (CollectionUtils.isEmpty(validationData.getErrors())) {
+ nicDao.update(nic);
+ }
+ return validationData;
}
- NicEntity nicEntity = getValidatedNic(vspId, version, componentId, nicId);
- nicDao.delete(nicEntity);
- }
+ @Override
+ public QuestionnaireResponse getNicQuestionnaire(String vspId, Version version, String componentId, String nicId) {
+ QuestionnaireResponse questionnaireResponse = new QuestionnaireResponse();
+ NicEntity nicQuestionnaire = nicDao.getQuestionnaireData(vspId, version, componentId, nicId);
+ VersioningUtil.validateEntityExistence(nicQuestionnaire, new NicEntity(vspId, version, componentId, nicId), VspDetails.ENTITY_TYPE);
+ questionnaireResponse.setData(nicQuestionnaire.getQuestionnaireData());
+ questionnaireResponse.setSchema(getNicQuestionnaireSchema(null));
+ return questionnaireResponse;
+ }
- @Override
- public CompositionEntityValidationData updateNic(NicEntity nic) {
- NicEntity retrieved =
- getValidatedNic(nic.getVspId(), nic.getVersion(), nic.getComponentId(), nic.getId());
+ @Override
+ public void updateNicQuestionnaire(String vspId, Version version, String componentId, String nicId, String questionnaireData) {
+ getNic(vspId, version, componentId, nicId);
+ nicDao.updateQuestionnaireData(vspId, version, componentId, nicId, questionnaireData);
+ }
- NicCompositionSchemaInput schemaInput = new NicCompositionSchemaInput();
- schemaInput.setManual(vspInfoDao.isManual(nic.getVspId(), nic.getVersion()));
- schemaInput.setNic(retrieved.getNicCompositionData());
+ protected String getNicQuestionnaireSchema(SchemaTemplateInput schemaInput) {
+ return SchemaGenerator.generate(SchemaTemplateContext.questionnaire, CompositionEntityType.nic, schemaInput);
+ }
- CompositionEntityValidationData validationData = compositionEntityDataManager
- .validateEntity(nic, SchemaTemplateContext.composition, schemaInput);
- if (CollectionUtils.isEmpty(validationData.getErrors())) {
- nicDao.update(nic);
+ protected String getNicCompositionSchema(NicCompositionSchemaInput schemaInput) {
+ return SchemaGenerator.generate(SchemaTemplateContext.composition, CompositionEntityType.nic, schemaInput);
}
- return validationData;
- }
-
- @Override
- public QuestionnaireResponse getNicQuestionnaire(String vspId, Version version,
- String componentId, String nicId) {
- QuestionnaireResponse questionnaireResponse = new QuestionnaireResponse();
- NicEntity nicQuestionnaire = nicDao.getQuestionnaireData(vspId, version, componentId, nicId);
- VersioningUtil.validateEntityExistence(nicQuestionnaire,
- new NicEntity(vspId, version, componentId, nicId), VspDetails.ENTITY_TYPE);
-
- questionnaireResponse.setData(nicQuestionnaire.getQuestionnaireData());
- questionnaireResponse.setSchema(getNicQuestionnaireSchema(null));
- return questionnaireResponse;
- }
-
- @Override
- public void updateNicQuestionnaire(String vspId, Version version, String componentId,
- String nicId, String questionnaireData) {
- getNic(vspId, version, componentId, nicId);
-
- nicDao.updateQuestionnaireData(vspId, version, componentId, nicId, questionnaireData);
- }
-
- protected String getNicQuestionnaireSchema(SchemaTemplateInput schemaInput) {
- return SchemaGenerator
- .generate(SchemaTemplateContext.questionnaire, CompositionEntityType.nic, schemaInput);
- }
-
- protected String getNicCompositionSchema(NicCompositionSchemaInput schemaInput) {
- return SchemaGenerator
- .generate(SchemaTemplateContext.composition, CompositionEntityType.nic, schemaInput);
- }
}