openecomp-be/backend/openecomp-sdc-vendor-software-product-manager/src/main/java/org/openecomp/sdc/vendorsoftwareproduct/impl/NetworkManagerImpl.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * SDC
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
   6  * ================================================================================
   7  * Licensed under the Apache License, Version 2.0 (the "License");
   8  * you may not use this file except in compliance with the License.
   9  * You may obtain a copy of the License at
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  * Unless required by applicable law or agreed to in writing, software
  14  * distributed under the License is distributed on an "AS IS" BASIS,
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16  * See the License for the specific language governing permissions and
  17  * limitations under the License.
  18  * ============LICENSE_END=========================================================
  19  */
  20
  21 package org.openecomp.sdc.vendorsoftwareproduct.impl;
  22
  23 import org.apache.commons.collections4.CollectionUtils;
  24 import org.openecomp.sdc.common.errors.CoreException;
  25 import org.openecomp.sdc.datatypes.error.ErrorLevel;
  26 import org.openecomp.sdc.logging.context.impl.MdcDataDebugMessage;
  27 import org.openecomp.sdc.logging.context.impl.MdcDataErrorMessage;
  28 import org.openecomp.sdc.logging.types.LoggerConstants;
  29 import org.openecomp.sdc.logging.types.LoggerErrorCode;
  30 import org.openecomp.sdc.logging.types.LoggerTragetServiceName;
  31 import org.openecomp.sdc.vendorsoftwareproduct.NetworkManager;
  32 import org.openecomp.sdc.vendorsoftwareproduct.dao.NetworkDao;
  33 import org.openecomp.sdc.vendorsoftwareproduct.dao.type.NetworkEntity;
  34 import org.openecomp.sdc.vendorsoftwareproduct.dao.type.VspDetails;
  35 import org.openecomp.sdc.vendorsoftwareproduct.errors.CompositionEditNotAllowedErrorBuilder;
  36 import org.openecomp.sdc.vendorsoftwareproduct.services.composition.CompositionEntityDataManager;
  37 import org.openecomp.sdc.vendorsoftwareproduct.services.schemagenerator.SchemaGenerator;
  38 import org.openecomp.sdc.vendorsoftwareproduct.types.CompositionEntityResponse;
  39 import org.openecomp.sdc.vendorsoftwareproduct.types.composition.CompositionEntityType;
  40 import org.openecomp.sdc.vendorsoftwareproduct.types.composition.CompositionEntityValidationData;
  41 import org.openecomp.sdc.vendorsoftwareproduct.types.composition.Network;
  42 import org.openecomp.sdc.vendorsoftwareproduct.types.schemagenerator.NetworkCompositionSchemaInput;
  43 import org.openecomp.sdc.vendorsoftwareproduct.types.schemagenerator.SchemaTemplateContext;
  44 import org.openecomp.sdc.versioning.VersioningUtil;
  45 import org.openecomp.sdc.versioning.dao.types.Version;
  46
  47 import java.util.Collection;
  48
  49 public class NetworkManagerImpl implements NetworkManager {
  50   private static MdcDataDebugMessage mdcDataDebugMessage = new MdcDataDebugMessage();
  51
  52   private NetworkDao networkDao;
  53   private CompositionEntityDataManager compositionEntityDataManager;
  54
  55   public NetworkManagerImpl(NetworkDao networkDao,
  56                             CompositionEntityDataManager compositionEntityDataManager) {
  57     this.networkDao = networkDao;
  58     this.compositionEntityDataManager = compositionEntityDataManager;
  59   }
  60
  61   @Override
  62   public Collection<NetworkEntity> listNetworks(String vspId, Version version, String user) {
  63     mdcDataDebugMessage.debugEntryMessage("VSP id", vspId);
  64     mdcDataDebugMessage.debugExitMessage("VSP id", vspId);
  65
  66     return networkDao.list(new NetworkEntity(vspId, version, null));
  67   }
  68
  69   @Override
  70   public NetworkEntity createNetwork(NetworkEntity network, String user) {
  71     mdcDataDebugMessage.debugEntryMessage("VSP id", network.getVspId());
  72
  73     if (!isManual(network.getVspId(), network.getVersion())) {
  74       MdcDataErrorMessage.createErrorMessageAndUpdateMdc(LoggerConstants.TARGET_ENTITY_DB,
  75           LoggerTragetServiceName.CREATE_NETWORK, ErrorLevel.ERROR.name(),
  76           LoggerErrorCode.PERMISSION_ERROR.getErrorCode(), "Can't create network");
  77       throw new CoreException(
  78           new CompositionEditNotAllowedErrorBuilder(network.getVspId(), network.getVersion())
  79               .build());
  80     }
  81
  82 /*    networkDao
  83         .updateVspLatestModificationTime(network.getVspId(), network.getVersion());*/
  84
  85     mdcDataDebugMessage.debugExitMessage("VSP id", network.getVspId());
  86
  87     return null;
  88   }
  89
  90   private NetworkEntity createNetwork(NetworkEntity network) {
  91     return compositionEntityDataManager.createNetwork(network);
  92   }
  93
  94   @Override
  95   public CompositionEntityValidationData updateNetwork(NetworkEntity network, String user) {
  96     mdcDataDebugMessage
  97         .debugEntryMessage("VSP id, network id", network.getVspId(), network.getId());
  98
  99     NetworkEntity retrieved = getNetwork(network.getVspId(), network.getVersion(), network.getId());
 100
 101     NetworkCompositionSchemaInput schemaInput = new NetworkCompositionSchemaInput();
 102     schemaInput.setManual(isManual(network.getVspId(), network.getVersion()));
 103     schemaInput.setNetwork(retrieved.getNetworkCompositionData());
 104
 105     CompositionEntityValidationData validationData = compositionEntityDataManager
 106         .validateEntity(network, SchemaTemplateContext.composition, schemaInput);
 107     if (CollectionUtils.isEmpty(validationData.getErrors())) {
 108       networkDao.update(network);
 109     }
 110
 111 /*    networkDao
 112         .updateVspLatestModificationTime(network.getVspId(), network.getVersion());*/
 113
 114     mdcDataDebugMessage
 115         .debugExitMessage("VSP id, network id", network.getVspId(), network.getId());
 116
 117     return validationData;
 118   }
 119
 120   @Override
 121   public CompositionEntityResponse<Network> getNetwork(String vspId, Version version,
 122                                                        String networkId, String user) {
 123     mdcDataDebugMessage.debugEntryMessage("VSP id, network id", vspId, networkId);
 124
 125     NetworkEntity networkEntity = getNetwork(vspId, version, networkId);
 126     Network network = networkEntity.getNetworkCompositionData();
 127
 128     NetworkCompositionSchemaInput schemaInput = new NetworkCompositionSchemaInput();
 129     schemaInput.setManual(isManual(vspId, version));
 130     schemaInput.setNetwork(network);
 131
 132     CompositionEntityResponse<Network> response = new CompositionEntityResponse<>();
 133     response.setId(networkId);
 134     response.setData(network);
 135     response.setSchema(getCompositionSchema(schemaInput));
 136
 137     mdcDataDebugMessage.debugExitMessage("VSP id, network id", vspId, networkId);
 138
 139     return response;
 140   }
 141
 142
 143   private NetworkEntity getNetwork(String vspId, Version version, String networkId) {
 144     NetworkEntity retrieved = networkDao.get(new NetworkEntity(vspId, version, networkId));
 145     VersioningUtil.validateEntityExistence(retrieved, new NetworkEntity(vspId, version, networkId),
 146         VspDetails.ENTITY_TYPE);
 147     return retrieved;
 148   }
 149
 150   @Override
 151   public void deleteNetwork(String vspId, Version version, String networkId, String user) {
 152     mdcDataDebugMessage.debugEntryMessage("VSP id, network id", vspId, networkId);
 153
 154     if (!isManual(vspId, version)) {
 155       MdcDataErrorMessage.createErrorMessageAndUpdateMdc(LoggerConstants.TARGET_ENTITY_DB,
 156           LoggerTragetServiceName.DELETE_NETWORK, ErrorLevel.ERROR.name(),
 157           LoggerErrorCode.PERMISSION_ERROR.getErrorCode(), "Can't delete network");
 158       throw new CoreException(
 159           new CompositionEditNotAllowedErrorBuilder(vspId, version).build());
 160     }
 161
 162     //networkDao.updateVspLatestModificationTime(vspId, version);
 163
 164     mdcDataDebugMessage.debugExitMessage("VSP id, network id", vspId, networkId);
 165   }
 166
 167   // todo *************************** move to reusable place! *************************
 168
 169   private boolean isManual(String vspId, Version version) {
 170     return false;
 171   }
 172
 173   protected String getCompositionSchema(NetworkCompositionSchemaInput schemaInput) {
 174     return SchemaGenerator
 175         .generate(SchemaTemplateContext.composition, CompositionEntityType.network, schemaInput);
 176   }
 177 }