src/policy/src/main/java/eu/teraflow/policy/PolicyRuleConditionValidator.java

@@ -18,9 +18,12 @@ package eu.teraflow.policy;
 
 import eu.teraflow.policy.context.ContextService;
 import eu.teraflow.policy.context.model.Device;
+import eu.teraflow.policy.context.model.EndPointId;
 import eu.teraflow.policy.context.model.Service;
 import eu.teraflow.policy.context.model.ServiceId;
 import io.smallrye.mutiny.Uni;
+import java.util.ArrayList;
+import java.util.List;
 import javax.enterprise.context.ApplicationScoped;
 import javax.inject.Inject;
 import org.jboss.logging.Logger;
@@ -114,6 +117,22 @@ public class PolicyRuleConditionValidator {
                 && serviceServiceIdId.equals(serviceId.getId());
     }
 
+    public Uni<Boolean> isServicesDeviceIdsValid(ServiceId serviceId, List<String> deviceIds) {
+        return contextService
+                .getService(serviceId)
+                .onItem()
+                .transform(service -> checkIfServicesDeviceIdsExist(service, deviceIds));
+    }
+
+    private boolean checkIfServicesDeviceIdsExist(Service service, List<String> deviceIds) {
+        List<String> serviceDeviceIds = new ArrayList<>();
+        for (EndPointId serviceEndPointId : service.getServiceEndPointIds()) {
+            serviceDeviceIds.add(serviceEndPointId.getDeviceId());
+        }
+
+        return deviceIds.containsAll(serviceDeviceIds);
+    }
+
     private Uni<Boolean> isUpdatedPolicyRuleIdValid(String updatedPolicyRuleId) {
         return contextService
                 .getPolicyRule(updatedPolicyRuleId)