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=b1bd03c25574e93ba71ac183fd229c428c77b912;hb=7a9e0f81770f2aa2793e241cee3a3c6c9bb40d9d;hp=2776c4d67d44a53cc5f604bdb2a4c50e65452829;hpb=b0c2031e8d546336685c84cfccef8d515144dfc6;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
index 2776c4d67d..b1bd03c255 100755
--- 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
@@ -23,18 +23,22 @@
 package org.onap.cps.spi.impl;
 
 import java.util.Collection;
+import java.util.List;
 import java.util.Set;
 import java.util.stream.Collectors;
 import javax.transaction.Transactional;
 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.YangResourceModuleReference;
 import org.onap.cps.spi.exceptions.AlreadyDefinedException;
+import org.onap.cps.spi.exceptions.ModuleNamesNotFoundException;
 import org.onap.cps.spi.model.Anchor;
 import org.onap.cps.spi.repository.AnchorRepository;
 import org.onap.cps.spi.repository.DataspaceRepository;
 import org.onap.cps.spi.repository.FragmentRepository;
 import org.onap.cps.spi.repository.SchemaSetRepository;
+import org.onap.cps.spi.repository.YangResourceRepository;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.dao.DataIntegrityViolationException;
 import org.springframework.stereotype.Component;
@@ -54,6 +58,9 @@ public class CpsAdminPersistenceServiceImpl implements CpsAdminPersistenceServic
     @Autowired
     private FragmentRepository fragmentRepository;
 
+    @Autowired
+    private YangResourceRepository yangResourceRepository;
+
     @Override
     public void createDataspace(final String dataspaceName) {
         try {
@@ -87,6 +94,15 @@ public class CpsAdminPersistenceServiceImpl implements CpsAdminPersistenceServic
         return anchorEntities.stream().map(CpsAdminPersistenceServiceImpl::toAnchor).collect(Collectors.toList());
     }
 
+    @Override
+    public Collection<Anchor> queryAnchors(final String dataspaceName, final Collection<String> inputModuleNames) {
+        validateDataspaceAndModuleNames(dataspaceName, inputModuleNames);
+        final DataspaceEntity dataspaceEntity = dataspaceRepository.getByName(dataspaceName);
+        final Collection<AnchorEntity> 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));
@@ -112,4 +128,23 @@ public class CpsAdminPersistenceServiceImpl implements CpsAdminPersistenceServic
             .schemaSetName(anchorEntity.getSchemaSet().getName())
             .build();
     }
+
+    private void validateDataspaceAndModuleNames(final String dataspaceName,
+        final Collection<String> inputModuleNames) {
+        final Collection<String> retrievedModuleNames =
+            yangResourceRepository.findAllModuleReferences(dataspaceName, inputModuleNames)
+                .stream().map(YangResourceModuleReference::getModuleName)
+                .collect(Collectors.toList());
+        if (retrievedModuleNames.isEmpty()) {
+            dataspaceRepository.getByName(dataspaceName);
+        }
+        if (inputModuleNames.size() > retrievedModuleNames.size()) {
+            final List<String> moduleNamesNotFound = inputModuleNames.stream()
+                .filter(moduleName -> !retrievedModuleNames.contains(moduleName))
+                .collect(Collectors.toList());
+            if (!moduleNamesNotFound.isEmpty()) {
+                throw new ModuleNamesNotFoundException(dataspaceName, moduleNamesNotFound);
+            }
+        }
+    }
 }