Commit 3738fd1a authored by Vasilis Katopodis's avatar Vasilis Katopodis
Browse files

test: remove MutinyContextServiceWrapper.java

parent 945c001e
Loading
Loading
Loading
Loading
+0 −18
Original line number Diff line number Diff line
package eu.teraflow.policy;

import context.ContextOuterClass.Device;
import context.ContextOuterClass.DeviceId;
import context.MutinyContextServiceGrpc;
import io.smallrye.mutiny.Uni;

public class MutinyContextServiceWrapper {
    private final MutinyContextServiceGrpc.MutinyContextServiceStub stub;

    public MutinyContextServiceWrapper(MutinyContextServiceGrpc.MutinyContextServiceStub stub) {
        this.stub = stub;
    }

    public Uni<Device> getDevice(DeviceId deviceId) {
        return stub.getDevice(deviceId);
    }
}
+0 −17
Original line number Diff line number Diff line
@@ -62,7 +62,6 @@ import org.mockito.Mockito;
class PolicyRuleServiceValidationTest {
    @Inject Serializer serializer;

    private MutinyContextServiceWrapper mutinyContextServiceStub;
    private ContextService contextService;
    private PolicyRuleConditionValidator policyRuleConditionValidator;

@@ -70,22 +69,6 @@ class PolicyRuleServiceValidationTest {
    void setUp() {
        contextService = Mockito.mock(ContextService.class);
        policyRuleConditionValidator = new PolicyRuleConditionValidator(contextService);
        mutinyContextServiceStub = Mockito.mock(MutinyContextServiceWrapper.class);
    }

    @Test
    void testIsDeviceIdValid_grpc() {
        String deviceId = "deviceIdGrpc";
        final Device device = createDevice(deviceId);
        final var serializedDevice = serializer.serialize(device);
        final var serializedDeviceId = serializedDevice.getDeviceId();

        when(mutinyContextServiceStub.getDevice(serializedDeviceId))
                .thenReturn(Uni.createFrom().item(serializedDevice));

        Boolean result = policyRuleConditionValidator.isDeviceIdValid(deviceId).await().indefinitely();

        assertThat(result).isEqualTo(true);
    }

    @Test