From fa56d71bb94d88f657a9d73fb91c3036220f32ab Mon Sep 17 00:00:00 2001 From: Claudio David Gasparini Date: Thu, 7 Jan 2021 12:21:38 +0100 Subject: Rework CpsModulePersistenceService - remove getModuleReferences - provide service returning YangTextSchemaSourceSet Issue-ID: CPS-21 Signed-off-by: Claudio David Gasparini Change-Id: I61cf6450c8ed8a5154990ea19467e016dc1155b4 --- .../java/org/onap/cps/api/CpsAdminService.java | 2 +- .../java/org/onap/cps/api/CpsModuleService.java | 12 +++++-- .../onap/cps/api/impl/CpsModuleServiceImpl.java | 15 ++++++++- .../onap/cps/spi/CpsAdminPersistenceService.java | 1 - .../onap/cps/spi/CpsModulePersistenceService.java | 13 ++++---- .../org/onap/cps/spi/model/ModuleReference.java | 1 + .../java/org/onap/cps/spi/model/SchemaSet.java | 39 ++++++++++++++++++++++ .../cps/yang/YangTextSchemaSourceSetBuilder.java | 6 +--- .../cps/api/impl/CpsModuleServiceImplSpec.groovy | 17 +++++++--- 9 files changed, 85 insertions(+), 21 deletions(-) create mode 100644 cps-service/src/main/java/org/onap/cps/spi/model/SchemaSet.java (limited to 'cps-service') diff --git a/cps-service/src/main/java/org/onap/cps/api/CpsAdminService.java b/cps-service/src/main/java/org/onap/cps/api/CpsAdminService.java index 581550fb5..853bd958f 100644 --- a/cps-service/src/main/java/org/onap/cps/api/CpsAdminService.java +++ b/cps-service/src/main/java/org/onap/cps/api/CpsAdminService.java @@ -50,7 +50,7 @@ public interface CpsAdminService { void createAnchor(@NonNull String dataspaceName, @NonNull String schemaSetName, @NonNull String anchorName); /** - * Read all anchors in the given a dataspace. + * Read all anchors in the given dataspace. * * @param dataspaceName dataspace name * @return a collection of anchors diff --git a/cps-service/src/main/java/org/onap/cps/api/CpsModuleService.java b/cps-service/src/main/java/org/onap/cps/api/CpsModuleService.java index e7b02fbad..5f63f97f1 100644 --- a/cps-service/src/main/java/org/onap/cps/api/CpsModuleService.java +++ b/cps-service/src/main/java/org/onap/cps/api/CpsModuleService.java @@ -21,8 +21,7 @@ package org.onap.cps.api; import java.util.Map; import org.checkerframework.checker.nullness.qual.NonNull; -import org.onap.cps.spi.exceptions.CpsException; -import org.opendaylight.yangtools.yang.model.api.SchemaContext; +import org.onap.cps.spi.model.SchemaSet; /** * Responsible for managing module sets. @@ -40,5 +39,12 @@ public interface CpsModuleService { void createSchemaSet(@NonNull String dataspaceName, @NonNull String schemaSetName, @NonNull Map yangResourcesNameToContentMap); - + /** + * Read schema set in the given dataspace. + * + * @param dataspaceName dataspace name + * @param schemaSetName schema set name + * @return a SchemaSet + */ + SchemaSet getSchemaSet(@NonNull String dataspaceName, @NonNull String schemaSetName); } diff --git a/cps-service/src/main/java/org/onap/cps/api/impl/CpsModuleServiceImpl.java b/cps-service/src/main/java/org/onap/cps/api/impl/CpsModuleServiceImpl.java index 8a437dbde..04a6fe1ce 100644 --- a/cps-service/src/main/java/org/onap/cps/api/impl/CpsModuleServiceImpl.java +++ b/cps-service/src/main/java/org/onap/cps/api/impl/CpsModuleServiceImpl.java @@ -19,10 +19,11 @@ package org.onap.cps.api.impl; - import java.util.Map; import org.onap.cps.api.CpsModuleService; import org.onap.cps.spi.CpsModulePersistenceService; +import org.onap.cps.spi.model.SchemaSet; +import org.onap.cps.yang.YangTextSchemaSourceSet; import org.onap.cps.yang.YangTextSchemaSourceSetBuilder; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; @@ -42,4 +43,16 @@ public class CpsModuleServiceImpl implements CpsModuleService { .storeSchemaSet(dataspaceName, schemaSetName, yangResourcesNameToContentMap); } + @Override + public SchemaSet getSchemaSet(final String dataspaceName, final String schemaSetName) { + final Map yangResourceNameToContent = + cpsModulePersistenceService.getYangSchemaResources(dataspaceName, schemaSetName); + final YangTextSchemaSourceSet yangTextSchemaSourceSet = YangTextSchemaSourceSetBuilder + .of(yangResourceNameToContent); + return SchemaSet.builder() + .name(schemaSetName) + .dataspaceName(dataspaceName) + .moduleReferences(yangTextSchemaSourceSet.getModuleReferences()) + .build(); + } } diff --git a/cps-service/src/main/java/org/onap/cps/spi/CpsAdminPersistenceService.java b/cps-service/src/main/java/org/onap/cps/spi/CpsAdminPersistenceService.java index ba53003ac..5643aedb7 100644 --- a/cps-service/src/main/java/org/onap/cps/spi/CpsAdminPersistenceService.java +++ b/cps-service/src/main/java/org/onap/cps/spi/CpsAdminPersistenceService.java @@ -57,5 +57,4 @@ public interface CpsAdminPersistenceService { */ @NonNull Collection getAnchors(@NonNull String dataspaceName); - } diff --git a/cps-service/src/main/java/org/onap/cps/spi/CpsModulePersistenceService.java b/cps-service/src/main/java/org/onap/cps/spi/CpsModulePersistenceService.java index 63f1f36c7..a82d69acb 100644 --- a/cps-service/src/main/java/org/onap/cps/spi/CpsModulePersistenceService.java +++ b/cps-service/src/main/java/org/onap/cps/spi/CpsModulePersistenceService.java @@ -20,9 +20,8 @@ package org.onap.cps.spi; -import java.util.Collection; import java.util.Map; -import org.onap.cps.spi.model.ModuleReference; +import org.checkerframework.checker.nullness.qual.NonNull; /** * Service to manage modules. @@ -36,14 +35,16 @@ public interface CpsModulePersistenceService { * @param schemaSetName schema set name * @param yangResourcesNameToContentMap YANG resources (files) map where key is a name and value is content */ - void storeSchemaSet(String dataspaceName, String schemaSetName, Map yangResourcesNameToContentMap); + void storeSchemaSet(@NonNull String dataspaceName, @NonNull String schemaSetName, + @NonNull Map yangResourcesNameToContentMap); /** - * Returns Modules references per specific namespace / schemaSetName. + * Returns YANG resources per specific namespace / schemaSetName. * * @param namespace module namespace * @param schemaSetName schema set name - * @return collection of ModuleRef + * @return YANG resources (files) map where key is a name and value is content */ - Collection getModuleReferences(String namespace, String schemaSetName); + @NonNull + Map getYangSchemaResources(@NonNull String namespace, @NonNull String schemaSetName); } diff --git a/cps-service/src/main/java/org/onap/cps/spi/model/ModuleReference.java b/cps-service/src/main/java/org/onap/cps/spi/model/ModuleReference.java index 5af355dcd..aa198a9c7 100644 --- a/cps-service/src/main/java/org/onap/cps/spi/model/ModuleReference.java +++ b/cps-service/src/main/java/org/onap/cps/spi/model/ModuleReference.java @@ -31,6 +31,7 @@ import lombok.NoArgsConstructor; @AllArgsConstructor public class ModuleReference { + private String name; private String namespace; private String revision; } diff --git a/cps-service/src/main/java/org/onap/cps/spi/model/SchemaSet.java b/cps-service/src/main/java/org/onap/cps/spi/model/SchemaSet.java new file mode 100644 index 000000000..caf7800d9 --- /dev/null +++ b/cps-service/src/main/java/org/onap/cps/spi/model/SchemaSet.java @@ -0,0 +1,39 @@ +/* + * ============LICENSE_START======================================================= + * Copyright (C) 2020 Pantheon.tech + * ================================================================================ + * 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.model; + +import java.io.Serializable; +import java.util.List; +import lombok.AllArgsConstructor; +import lombok.Builder; +import lombok.Data; +import lombok.NoArgsConstructor; + +@Data +@Builder +@NoArgsConstructor +@AllArgsConstructor +public class SchemaSet implements Serializable { + + private static final long serialVersionUID = 1464791260718603291L; + private String name; + private String dataspaceName; + private List moduleReferences; +} diff --git a/cps-service/src/main/java/org/onap/cps/yang/YangTextSchemaSourceSetBuilder.java b/cps-service/src/main/java/org/onap/cps/yang/YangTextSchemaSourceSetBuilder.java index 6d825445c..ae0f2cd3e 100644 --- a/cps-service/src/main/java/org/onap/cps/yang/YangTextSchemaSourceSetBuilder.java +++ b/cps-service/src/main/java/org/onap/cps/yang/YangTextSchemaSourceSetBuilder.java @@ -49,11 +49,6 @@ public final class YangTextSchemaSourceSetBuilder { private final ImmutableMap.Builder yangModelMap = new ImmutableMap.Builder<>(); - public YangTextSchemaSourceSetBuilder put(final String fileName, final String content) { - this.yangModelMap.put(fileName, content); - return this; - } - public YangTextSchemaSourceSetBuilder putAll(final Map yangResourceNameToContent) { this.yangModelMap.putAll(yangResourceNameToContent); return this; @@ -95,6 +90,7 @@ public final class YangTextSchemaSourceSetBuilder { private static ModuleReference toModuleReference(final Module module) { return ModuleReference.builder() + .name(module.getName()) .namespace(module.getNamespace().toString()) .revision(module.getRevision().map(Revision::toString).orElse(null)) .build(); diff --git a/cps-service/src/test/groovy/org/onap/cps/api/impl/CpsModuleServiceImplSpec.groovy b/cps-service/src/test/groovy/org/onap/cps/api/impl/CpsModuleServiceImplSpec.groovy index a93411bfe..ebe4fe7bc 100644 --- a/cps-service/src/test/groovy/org/onap/cps/api/impl/CpsModuleServiceImplSpec.groovy +++ b/cps-service/src/test/groovy/org/onap/cps/api/impl/CpsModuleServiceImplSpec.groovy @@ -21,11 +21,9 @@ package org.onap.cps.api.impl import org.onap.cps.TestUtils -import org.onap.cps.spi.CpsModulePersistenceService +import org.onap.cps.spi.CpsModulePersistenceService; import org.onap.cps.spi.exceptions.ModelValidationException -import org.onap.cps.utils.YangUtils -import org.opendaylight.yangtools.yang.common.Revision -import org.opendaylight.yangtools.yang.model.api.SchemaContext +import org.onap.cps.spi.model.ModuleReference import spock.lang.Specification class CpsModuleServiceImplSpec extends Specification { @@ -54,4 +52,15 @@ class CpsModuleServiceImplSpec extends Specification { thrown(ModelValidationException.class) } + def 'Get schema set by name and namespace.'() { + given: 'an already present schema set' + def yangResourcesNameToContentMap = TestUtils.getYangResourcesAsMap('bookstore.yang') + mockModuleStoreService.getYangSchemaResources('someDataspace', 'someSchemaSet') >> yangResourcesNameToContentMap + when: 'get schema set method is invoked' + def result = objectUnderTest.getSchemaSet('someDataspace', 'someSchemaSet') + then: 'the correct schema set is returned' + result.getName().contains('someSchemaSet') + result.getDataspaceName().contains('someDataspace') + result.getModuleReferences().contains(new ModuleReference('stores', 'org:onap:ccsdk:sample', '2020-09-15')) + } } -- cgit 1.2.3-korg