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) {
  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) {
  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   @Override
  91   public CompositionEntityValidationData updateNetwork(NetworkEntity network) {
  92     mdcDataDebugMessage
  93         .debugEntryMessage("VSP id, network id", network.getVspId(), network.getId());
  94
  95     NetworkEntity retrieved = getValidatedNetwork(network.getVspId(), network.getVersion(), network.getId());
  96
  97     NetworkCompositionSchemaInput schemaInput = new NetworkCompositionSchemaInput();
  98     schemaInput.setManual(isManual(network.getVspId(), network.getVersion()));
  99     schemaInput.setNetwork(retrieved.getNetworkCompositionData());
 100
 101     CompositionEntityValidationData validationData = compositionEntityDataManager
 102         .validateEntity(network, SchemaTemplateContext.composition, schemaInput);
 103     if (CollectionUtils.isEmpty(validationData.getErrors())) {
 104       networkDao.update(network);
 105     }
 106
 107 /*    networkDao
 108         .updateVspLatestModificationTime(network.getVspId(), network.getVersion());*/
 109
 110     mdcDataDebugMessage
 111         .debugExitMessage("VSP id, network id", network.getVspId(), network.getId());
 112
 113     return validationData;
 114   }
 115
 116   @Override
 117   public CompositionEntityResponse<Network> getNetwork(String vspId, Version version,
 118                                                        String networkId) {
 119     mdcDataDebugMessage.debugEntryMessage("VSP id, network id", vspId, networkId);
 120
 121     NetworkEntity networkEntity = getValidatedNetwork(vspId, version, networkId);
 122     Network network = networkEntity.getNetworkCompositionData();
 123
 124     NetworkCompositionSchemaInput schemaInput = new NetworkCompositionSchemaInput();
 125     schemaInput.setManual(isManual(vspId, version));
 126     schemaInput.setNetwork(network);
 127
 128     CompositionEntityResponse<Network> response = new CompositionEntityResponse<>();
 129     response.setId(networkId);
 130     response.setData(network);
 131     response.setSchema(getCompositionSchema(schemaInput));
 132
 133     mdcDataDebugMessage.debugExitMessage("VSP id, network id", vspId, networkId);
 134
 135     return response;
 136   }
 137
 138
 139   private NetworkEntity getValidatedNetwork(String vspId, Version version, String networkId) {
 140     NetworkEntity retrieved = networkDao.get(new NetworkEntity(vspId, version, networkId));
 141     VersioningUtil.validateEntityExistence(retrieved, new NetworkEntity(vspId, version, networkId),
 142         VspDetails.ENTITY_TYPE);
 143     return retrieved;
 144   }
 145
 146   @Override
 147   public void deleteNetwork(String vspId, Version version, String networkId) {
 148     mdcDataDebugMessage.debugEntryMessage("VSP id, network id", vspId, networkId);
 149
 150     if (!isManual(vspId, version)) {
 151       MdcDataErrorMessage.createErrorMessageAndUpdateMdc(LoggerConstants.TARGET_ENTITY_DB,
 152           LoggerTragetServiceName.DELETE_NETWORK, ErrorLevel.ERROR.name(),
 153           LoggerErrorCode.PERMISSION_ERROR.getErrorCode(), "Can't delete network");
 154       throw new CoreException(
 155           new CompositionEditNotAllowedErrorBuilder(vspId, version).build());
 156     }
 157
 158     //networkDao.updateVspLatestModificationTime(vspId, version);
 159
 160     mdcDataDebugMessage.debugExitMessage("VSP id, network id", vspId, networkId);
 161   }
 162
 163   // todo *************************** move to reusable place! *************************
 164
 165   private boolean isManual(String vspId, Version version) {
 166     return false;
 167   }
 168
 169   protected String getCompositionSchema(NetworkCompositionSchemaInput schemaInput) {
 170     return SchemaGenerator
 171         .generate(SchemaTemplateContext.composition, CompositionEntityType.network, schemaInput);
 172   }
 173 }