X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=cps-ri%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fcps%2Fspi%2Fimpl%2FCpsAdminPersistenceServiceImpl.java;h=56a046496e3983627903c672a91dccbe820f87d1;hb=refs%2Fheads%2Fmaster;hp=847a4a32fe621eb83e804524b31b0b66b69f8b56;hpb=9f8ddd047943525bebf8a49599f22dbe530b4361;p=cps.git diff --git a/cps-ri/src/main/java/org/onap/cps/spi/impl/CpsAdminPersistenceServiceImpl.java b/cps-ri/src/main/java/org/onap/cps/spi/impl/CpsAdminPersistenceServiceImpl.java deleted file mode 100755 index 847a4a32fe..0000000000 --- a/cps-ri/src/main/java/org/onap/cps/spi/impl/CpsAdminPersistenceServiceImpl.java +++ /dev/null @@ -1,223 +0,0 @@ -/* - * ============LICENSE_START======================================================= - * Copyright (C) 2020-2023 Nordix Foundation. - * Modifications Copyright (C) 2020-2022 Bell Canada. - * Modifications Copyright (C) 2021 Pantheon.tech - * Modifications Copyright (C) 2022 TechMahindra Ltd. - * ================================================================================ - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - * - * SPDX-License-Identifier: Apache-2.0 - * ============LICENSE_END========================================================= - */ - -package org.onap.cps.spi.impl; - -import java.util.Collection; -import java.util.Collections; -import java.util.List; -import java.util.stream.Collectors; -import javax.transaction.Transactional; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.onap.cps.spi.CpsAdminPersistenceService; -import org.onap.cps.spi.entities.AnchorEntity; -import org.onap.cps.spi.entities.DataspaceEntity; -import org.onap.cps.spi.entities.SchemaSetEntity; -import org.onap.cps.spi.entities.YangResourceModuleReference; -import org.onap.cps.spi.exceptions.AlreadyDefinedException; -import org.onap.cps.spi.exceptions.DataspaceInUseException; -import org.onap.cps.spi.exceptions.DataspaceNotFoundException; -import org.onap.cps.spi.exceptions.ModuleNamesNotFoundException; -import org.onap.cps.spi.model.Anchor; -import org.onap.cps.spi.model.Dataspace; -import org.onap.cps.spi.repository.AnchorRepository; -import org.onap.cps.spi.repository.DataspaceRepository; -import org.onap.cps.spi.repository.SchemaSetRepository; -import org.onap.cps.spi.repository.YangResourceRepository; -import org.springframework.dao.DataIntegrityViolationException; -import org.springframework.stereotype.Component; - -@Slf4j -@Component -@RequiredArgsConstructor -public class CpsAdminPersistenceServiceImpl implements CpsAdminPersistenceService { - - private final DataspaceRepository dataspaceRepository; - private final AnchorRepository anchorRepository; - private final SchemaSetRepository schemaSetRepository; - private final YangResourceRepository yangResourceRepository; - - @Override - public void createDataspace(final String dataspaceName) { - try { - dataspaceRepository.save(new DataspaceEntity(dataspaceName)); - } catch (final DataIntegrityViolationException e) { - throw AlreadyDefinedException.forDataspace(dataspaceName, e); - } - } - - @Override - public void deleteDataspace(final String dataspaceName) { - final DataspaceEntity dataspaceEntity = dataspaceRepository.getByName(dataspaceName); - final int numberOfAssociatedAnchors = anchorRepository.countByDataspace(dataspaceEntity); - if (numberOfAssociatedAnchors != 0) { - throw new DataspaceInUseException(dataspaceName, - String.format("Dataspace contains %d anchor(s)", numberOfAssociatedAnchors)); - } - final int numberOfAssociatedSchemaSets = schemaSetRepository.countByDataspace(dataspaceEntity); - if (numberOfAssociatedSchemaSets != 0) { - throw new DataspaceInUseException(dataspaceName, - String.format("Dataspace contains %d schemaset(s)", numberOfAssociatedSchemaSets)); - } - dataspaceRepository.delete(dataspaceEntity); - } - - @Override - public Dataspace getDataspace(final String dataspaceName) { - final DataspaceEntity dataspaceEntity = dataspaceRepository.getByName(dataspaceName); - return toDataspace(dataspaceEntity); - } - - @Override - public Collection getAllDataspaces() { - final Collection dataspaceEntities = dataspaceRepository.findAll(); - return dataspaceEntities.stream().map(CpsAdminPersistenceServiceImpl::toDataspace) - .collect(Collectors.toSet()); - } - - @Override - public void createAnchor(final String dataspaceName, final String schemaSetName, final String anchorName) { - final var dataspaceEntity = dataspaceRepository.getByName(dataspaceName); - final var schemaSetEntity = - schemaSetRepository.getByDataspaceAndName(dataspaceEntity, schemaSetName); - final var anchorEntity = AnchorEntity.builder() - .name(anchorName) - .dataspace(dataspaceEntity) - .schemaSet(schemaSetEntity) - .build(); - try { - anchorRepository.save(anchorEntity); - } catch (final DataIntegrityViolationException e) { - throw AlreadyDefinedException.forAnchor(anchorName, dataspaceName, e); - } - } - - @Override - public Collection getAnchors(final String dataspaceName) { - final var dataspaceEntity = dataspaceRepository.getByName(dataspaceName); - final Collection anchorEntities = anchorRepository.findAllByDataspace(dataspaceEntity); - return anchorEntities.stream().map(CpsAdminPersistenceServiceImpl::toAnchor).collect(Collectors.toSet()); - } - - @Override - public Collection getAnchors(final String dataspaceName, final String schemaSetName) { - final DataspaceEntity dataspaceEntity = dataspaceRepository.getByName(dataspaceName); - final SchemaSetEntity schemaSetEntity = schemaSetRepository.getByDataspaceAndName( - dataspaceEntity, schemaSetName); - return anchorRepository.findAllBySchemaSet(schemaSetEntity) - .stream().map(CpsAdminPersistenceServiceImpl::toAnchor) - .collect(Collectors.toSet()); - } - - @Override - public Collection getAnchors(final String dataspaceName, final Collection schemaSetNames) { - final DataspaceEntity dataspaceEntity = dataspaceRepository.getByName(dataspaceName); - return anchorRepository.findAllByDataspaceAndSchemaSetNameIn(dataspaceEntity, schemaSetNames) - .stream().map(CpsAdminPersistenceServiceImpl::toAnchor).collect(Collectors.toSet()); - } - - @Override - public Collection queryAnchors(final String dataspaceName, final Collection inputModuleNames) { - try { - validateDataspaceAndModuleNames(dataspaceName, inputModuleNames); - } catch (DataspaceNotFoundException | ModuleNamesNotFoundException e) { - log.info("Module search encountered unknown dataspace or modulename, treating this as nothing found"); - return Collections.emptySet(); - } - - final DataspaceEntity dataspaceEntity = dataspaceRepository.getByName(dataspaceName); - final Collection anchorEntities = anchorRepository - .getAnchorsByDataspaceIdAndModuleNames(dataspaceEntity.getId(), inputModuleNames, inputModuleNames.size()); - return anchorEntities.stream().map(CpsAdminPersistenceServiceImpl::toAnchor).collect(Collectors.toSet()); - } - - @Override - public Anchor getAnchor(final String dataspaceName, final String anchorName) { - return toAnchor(getAnchorEntity(dataspaceName, anchorName)); - } - - @Transactional - @Override - public void deleteAnchor(final String dataspaceName, final String anchorName) { - final var anchorEntity = getAnchorEntity(dataspaceName, anchorName); - anchorRepository.delete(anchorEntity); - } - - @Transactional - @Override - public void deleteAnchors(final String dataspaceName, final Collection anchorNames) { - final var dataspaceEntity = dataspaceRepository.getByName(dataspaceName); - anchorRepository.deleteAllByDataspaceAndNameIn(dataspaceEntity, anchorNames); - } - - @Transactional - @Override - public void updateAnchorSchemaSet(final String dataspaceName, - final String anchorName, - final String schemaSetName) { - final DataspaceEntity dataspaceEntity = dataspaceRepository.getByName(dataspaceName); - final AnchorEntity anchorEntity = anchorRepository.getByDataspaceAndName(dataspaceEntity, anchorName); - final SchemaSetEntity schemaSetEntity = schemaSetRepository - .getByDataspaceAndName(dataspaceEntity, schemaSetName); - anchorRepository.updateAnchorSchemaSetId(schemaSetEntity.getId(), anchorEntity.getId()); - } - - private AnchorEntity getAnchorEntity(final String dataspaceName, final String anchorName) { - final var dataspaceEntity = dataspaceRepository.getByName(dataspaceName); - return anchorRepository.getByDataspaceAndName(dataspaceEntity, anchorName); - } - - private static Anchor toAnchor(final AnchorEntity anchorEntity) { - return Anchor.builder() - .name(anchorEntity.getName()) - .dataspaceName(anchorEntity.getDataspace().getName()) - .schemaSetName(anchorEntity.getSchemaSet().getName()) - .build(); - } - - private static Dataspace toDataspace(final DataspaceEntity dataspaceEntity) { - return Dataspace.builder().name(dataspaceEntity.getName()).build(); - } - - private void validateDataspaceAndModuleNames(final String dataspaceName, - final Collection inputModuleNames) { - final Collection retrievedModuleReferences = - yangResourceRepository.findAllModuleReferencesByDataspaceAndModuleNames(dataspaceName, inputModuleNames) - .stream().map(YangResourceModuleReference::getModuleName) - .collect(Collectors.toList()); - if (retrievedModuleReferences.isEmpty()) { - verifyDataspaceName(dataspaceName); - } - if (inputModuleNames.size() > retrievedModuleReferences.size()) { - final List unknownModules = inputModuleNames.stream() - .filter(moduleName -> !retrievedModuleReferences.contains(moduleName)) - .collect(Collectors.toList()); - throw new ModuleNamesNotFoundException(dataspaceName, unknownModules); - } - } - - private void verifyDataspaceName(final String dataspaceName) { - dataspaceRepository.getByName(dataspaceName); - } -}