1 files changed, 23 insertions, 3 deletions
diff --git a/certService/src/main/java/org/onap/aaf/certservice/certification/configuration/validation/Cmpv2ServerConfigurationValidator.java b/certService/src/main/java/org/onap/aaf/certservice/certification/configuration/validation/Cmpv2ServersConfigurationValidator.java
index 736a65d1..3cf7fdf7 100644
--- a/certService/src/main/java/org/onap/aaf/certservice/certification/configuration/validation/Cmpv2ServerConfigurationValidator.java
+++ b/certService/src/main/java/org/onap/aaf/certservice/certification/configuration/validation/Cmpv2ServersConfigurationValidator.java
@@ -27,22 +27,42 @@ import org.springframework.stereotype.Service;
 import javax.validation.ConstraintViolation;
 import javax.validation.Validator;
 import java.security.InvalidParameterException;
+import java.util.List;
 import java.util.Set;
 
 @Service
-public class Cmpv2ServerConfigurationValidator {
+public class Cmpv2ServersConfigurationValidator {
 
     private final Validator validator;
 
     @Autowired
-    public Cmpv2ServerConfigurationValidator(Validator validator) {
+    public Cmpv2ServersConfigurationValidator(Validator validator) {
         this.validator = validator;
     }
 
-    public void validate(Cmpv2Server serverDetails) {
+    public void validate(List<Cmpv2Server> servers) {
+        servers.forEach(this::validateServer);
+        validateUniqueCaNames(servers);
+    }
+
+    private void validateServer(Cmpv2Server serverDetails) {
         Set<ConstraintViolation<Cmpv2Server>> violations = validator.validate(serverDetails);
         if (!violations.isEmpty()) {
             throw new InvalidParameterException(violations.toString());
         }
     }
+
+    private void validateUniqueCaNames(List<Cmpv2Server> servers) {
+        long distinctCAs = getNumberOfUniqueCaNames(servers);
+        if (servers.size() != distinctCAs) {
+            throw new InvalidParameterException("CA names are not unique within given CMPv2 servers");
+        }
+    }
+
+    private long getNumberOfUniqueCaNames(List<Cmpv2Server> servers) {
+        return servers.stream().map(Cmpv2Server::getCaName)
+                .distinct()
+                .count();
+    }
+
 }