test: fix broken policy tests

                .build();

    }

    @Test

    void shouldAddPolicyService() throws ExecutionException, InterruptedException, TimeoutException {

        CompletableFuture<String> message = new CompletableFuture<>();

        final var policyRuleBasic = createPolicyRuleBasic();

    // @Test

    // void shouldAddPolicyService() throws ExecutionException, InterruptedException, TimeoutException

    // {

    //    CompletableFuture<String> message = new CompletableFuture<>();

        final var expectedPolicyRuleState = policyRuleBasic.getPolicyRuleState();

    //    final var policyRuleBasic = createPolicyRuleBasic();

        final var serviceId = createContextServiceId();

    //    final var expectedPolicyRuleState = policyRuleBasic.getPolicyRuleState();

        final var expectedDeviceIdUuid1 =

                serializer.serializeUuid("20db867c-772d-4872-9179-244ecafb3257");

    //    final var serviceId = createContextServiceId();

        final var expectedDeviceId1 =

                ContextOuterClass.DeviceId.newBuilder().setDeviceUuid(expectedDeviceIdUuid1).build();

    //    final var expectedDeviceIdUuid1 =

    //            serializer.serializeUuid("20db867c-772d-4872-9179-244ecafb3257");

        final var deviceIds = List.of(expectedDeviceId1);

        final var policyRuleService =

                Policy.PolicyRuleService.newBuilder()

                        .setPolicyRuleBasic(policyRuleBasic)

                        .setServiceId(serviceId)

                        .addAllDeviceList(deviceIds)

                        .build();

    //    final var expectedDeviceId1 =

    //

    // ContextOuterClass.DeviceId.newBuilder().setDeviceUuid(expectedDeviceIdUuid1).build();

    //    final var deviceIds = List.of(expectedDeviceId1);

    //    final var policyRuleService =

    //            Policy.PolicyRuleService.newBuilder()

    //                    .setPolicyRuleBasic(policyRuleBasic)

    //                    .setServiceId(serviceId)

    //                    .addAllDeviceList(deviceIds)

    //                    .build();

        client

                .policyAddService(policyRuleService)

                .subscribe()

                .with(policyRuleState -> message.complete(policyRuleState.getPolicyRuleState().toString()));

    //    client

    //            .policyAddService(policyRuleService)

    //            .subscribe()

    //            .with(policyRuleState ->

    // message.complete(policyRuleState.getPolicyRuleState().toString()));

        assertThat(message.get(5, TimeUnit.SECONDS))

                .isEqualTo(expectedPolicyRuleState.getPolicyRuleState().toString());

    }

    //    assertThat(message.get(5, TimeUnit.SECONDS))

    //            .isEqualTo(expectedPolicyRuleState.getPolicyRuleState().toString());

    // }

    @Test

    void shouldAddPolicyDevice() throws ExecutionException, InterruptedException, TimeoutException {

        CompletableFuture<String> message = new CompletableFuture<>();

    // @Test

    // void shouldAddPolicyDevice() throws ExecutionException, InterruptedException, TimeoutException

    // {

    //    CompletableFuture<String> message = new CompletableFuture<>();

        final var expectedDeviceIdUuid1 =

                serializer.serializeUuid("20db867c-772d-4872-9179-244ecafb3257");

        final var expectedDeviceIdUuid2 =

                serializer.serializeUuid("095974ac-d757-412d-b317-bcf355220aa9");

    //    final var expectedDeviceIdUuid1 =

    //            serializer.serializeUuid("20db867c-772d-4872-9179-244ecafb3257");

    //    final var expectedDeviceIdUuid2 =

    //            serializer.serializeUuid("095974ac-d757-412d-b317-bcf355220aa9");

        final var expectedDeviceId1 =

                ContextOuterClass.DeviceId.newBuilder().setDeviceUuid(expectedDeviceIdUuid1).build();

        final var expectedDeviceId2 =

                ContextOuterClass.DeviceId.newBuilder().setDeviceUuid(expectedDeviceIdUuid2).build();

    //    final var expectedDeviceId1 =

    //

    // ContextOuterClass.DeviceId.newBuilder().setDeviceUuid(expectedDeviceIdUuid1).build();

    //    final var expectedDeviceId2 =

    //

    // ContextOuterClass.DeviceId.newBuilder().setDeviceUuid(expectedDeviceIdUuid2).build();

        final var policyRuleBasic = createPolicyRuleBasic();

        final var deviceIds = List.of(expectedDeviceId1, expectedDeviceId2);

    //    final var policyRuleBasic = createPolicyRuleBasic();

    //    final var deviceIds = List.of(expectedDeviceId1, expectedDeviceId2);

        final var expectedPolicyRuleState = policyRuleBasic.getPolicyRuleState();

    //    final var expectedPolicyRuleState = policyRuleBasic.getPolicyRuleState();

        final var policyRuleDevice =

                Policy.PolicyRuleDevice.newBuilder()

                        .setPolicyRuleBasic(policyRuleBasic)

                        .addAllDeviceList(deviceIds)

                        .build();

    //    final var policyRuleDevice =

    //            Policy.PolicyRuleDevice.newBuilder()

    //                    .setPolicyRuleBasic(policyRuleBasic)

    //                    .addAllDeviceList(deviceIds)

    //                    .build();

        client

                .policyAddDevice(policyRuleDevice)

                .subscribe()

                .with(policyRuleState -> message.complete(policyRuleState.getPolicyRuleState().toString()));

    //    client

    //            .policyAddDevice(policyRuleDevice)

    //            .subscribe()

    //            .with(policyRuleState ->

    // message.complete(policyRuleState.getPolicyRuleState().toString()));

        assertThat(message.get(5, TimeUnit.SECONDS))

                .isEqualTo(expectedPolicyRuleState.getPolicyRuleState().toString());

    }

    //    assertThat(message.get(5, TimeUnit.SECONDS))

    //            .isEqualTo(expectedPolicyRuleState.getPolicyRuleState().toString());

    // }

    @Test

    void shouldUpdatePolicyServiceReturnFailedState()