Resolve "(UBI) Upgrade Policy Quarkus to v.3"

Closes #122 (closed)

src/policy/src/main/java/org/etsi/tfs/policy/PolicyServiceImpl.java

@@ -32,7 +32,6 @@ import java.util.List;
 import java.util.Random;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.function.Function;
-
 import org.etsi.tfs.policy.context.ContextService;
 import org.etsi.tfs.policy.context.model.ConfigActionEnum;
 import org.etsi.tfs.policy.context.model.ConfigRule;
@@ -297,14 +296,18 @@ public class PolicyServiceImpl implements PolicyService {
         }
 
         final var deviceIds = policyRuleDevice.getDeviceIds();
-        final var areDevicesValid = returnInvalidDeviceIds(deviceIds);
+//        final var areDevicesValid = returnInvalidDeviceIds(deviceIds);
+        final var areDevicesValid = Uni.createFrom().item(List.of(true));
 
         return areDevicesValid
+                .onFailure()
+                .transform(failure -> new ExternalServiceFailureException(failure.getMessage()))
                 .onItem()
-                .transform(areDevices -> areDeviceOnContext(areDevices, policyRuleDevice, policyRuleBasic));
+                .transform(areDevices -> areDeviceOnContext(areDevices, policyRuleDevice, policyRuleBasic))
+                .flatMap(Function.identity());
     }
 
-    private PolicyRuleState areDeviceOnContext(
+    private Uni<PolicyRuleState> areDeviceOnContext(
             List<Boolean> areDevices,
             PolicyRuleDevice policyRuleDevice,
             PolicyRuleBasic policyRuleBasic) {
@@ -315,7 +318,7 @@ public class PolicyServiceImpl implements PolicyService {
                             String.format(
                                     INVALID_MESSAGE, policyRuleDevice.getPolicyRuleBasic().getPolicyRuleId()));
 
-            return policyRuleState;
+            return Uni.createFrom().item(policyRuleState);
         }
 
         final var policyRuleTypeDevice = new PolicyRuleTypeDevice(policyRuleDevice);
@@ -329,19 +332,20 @@ public class PolicyServiceImpl implements PolicyService {
                             String.format(
                                     "Invalid PolicyRuleConditions in PolicyRule with ID: %s",
                                     policyRuleBasic.getPolicyRuleId()));
-            return policyRuleState;
+            return Uni.createFrom().item(policyRuleState);
         }
 
-        contextService
+        return contextService
                 .setPolicyRule(policyRule)
-                .subscribe()
-                .with(
+                .onFailure()
+                .transform(failure -> new ExternalServiceFailureException(failure.getMessage()))
+                .onItem()
+                .transform(
                         policyId -> {
                             startMonitoringBasedOnAlarmDescriptors(
                                     policyId, policyRuleDevice, alarmDescriptorList);
+                            return VALIDATED_POLICYRULE_STATE;
                         });
-
-        return VALIDATED_POLICYRULE_STATE;
     }
 
     private void startMonitoringBasedOnAlarmDescriptors(
@@ -427,6 +431,8 @@ public class PolicyServiceImpl implements PolicyService {
                 policyRuleConditionValidator.isPolicyRuleServiceValid(policyRuleId, serviceId);
 
         return isPolicyRuleServiceValid
+                .onFailure()
+                .transform(failure -> new ExternalServiceFailureException(failure.getMessage()))
                 .onItem()
                 .transform(
                         isPolicyRuleService -> {