Commit 81bb7290 authored by Vasilis Katopodis's avatar Vasilis Katopodis
Browse files

Add setPolicyRule in addPolicyService

parent f835b3da

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

+11 −7
Original line number Diff line number Diff line
@@ -168,17 +168,21 @@ public class PolicyServiceImpl implements PolicyService { 


        final var serviceId = policyRuleService.getServiceId();

        final var deviceIds = policyRuleService.getDeviceIds();

        final var isServiceValid = policyRuleConditionValidator.isServiceIdValid(serviceId, deviceIds);



        return policyRuleConditionValidator

                .isServiceIdValid(serviceId, deviceIds)

        isServiceValid

                .subscribe()

                .with(

                        id -> {

                            LOGGER.info("OK 1");

                            var policyRuleTypeService = new PolicyRuleTypeService(policyRuleService);

                            contextService.setPolicyRule(new PolicyRule(policyRuleTypeService));

                        });



        return isServiceValid

                .onItem()

                .transform(

                        isService -> {

                            if (!isService) {

                                return new PolicyRuleState(

                                        PolicyRuleStateEnum.POLICY_FAILED,

                                        String.format(INVALID_MESSAGE, "Service with id: " + serviceId.getId()));

                            }

                            return VALIDATED_POLICYRULE_STATE;

                        });

    }