Skip to content
Snippets Groups Projects
Commit e4c08445 authored by Krzysztof Witukiewicz's avatar Krzysztof Witukiewicz
Browse files

OZG-7573 OZG-7923 More tests

parent bc463db7
No related branches found
No related tags found
1 merge request!23Ozg 7573 forwarding interface
This commit is part of merge request !23. Comments created here will be created in the context of that merge request.
...@@ -34,8 +34,12 @@ import org.mockito.Mock; ...@@ -34,8 +34,12 @@ import org.mockito.Mock;
import org.mockito.Spy; import org.mockito.Spy;
import de.ozgcloud.eingang.forwarder.RouteForwardingServiceGrpc; import de.ozgcloud.eingang.forwarder.RouteForwardingServiceGrpc;
import de.ozgcloud.eingang.forwarding.GrpcRouteForwarding;
import de.ozgcloud.eingang.forwarding.GrpcRouteForwardingRequest; import de.ozgcloud.eingang.forwarding.GrpcRouteForwardingRequest;
import de.ozgcloud.vorgang.callcontext.VorgangManagerClientCallContextAttachingInterceptor; import de.ozgcloud.vorgang.callcontext.VorgangManagerClientCallContextAttachingInterceptor;
import de.ozgcloud.vorgang.vorgang.Eingang;
import de.ozgcloud.vorgang.vorgang.EingangTestFactory;
import de.ozgcloud.vorgang.vorgang.Vorgang;
import de.ozgcloud.vorgang.vorgang.VorgangService; import de.ozgcloud.vorgang.vorgang.VorgangService;
import de.ozgcloud.vorgang.vorgang.VorgangTestFactory; import de.ozgcloud.vorgang.vorgang.VorgangTestFactory;
import de.ozgcloud.vorgang.vorgang.redirect.ForwardingRemoteService.ForwardingResponseObserver; import de.ozgcloud.vorgang.vorgang.redirect.ForwardingRemoteService.ForwardingResponseObserver;
...@@ -46,7 +50,7 @@ class ForwardingRemoteServiceTest { ...@@ -46,7 +50,7 @@ class ForwardingRemoteServiceTest {
@Mock @Mock
private VorgangService vorgangService; private VorgangService vorgangService;
@Mock @Mock
private ForwardingRemoteService forwardingRemoteService; private ForwardingRequestMapper forwardingRequestMapper;
@Mock @Mock
private RouteForwardingServiceGrpc.RouteForwardingServiceStub serviceStub; private RouteForwardingServiceGrpc.RouteForwardingServiceStub serviceStub;
@Spy @Spy
...@@ -56,10 +60,13 @@ class ForwardingRemoteServiceTest { ...@@ -56,10 +60,13 @@ class ForwardingRemoteServiceTest {
@Mock @Mock
private StreamObserver<GrpcRouteForwardingRequest> requestObserver; private StreamObserver<GrpcRouteForwardingRequest> requestObserver;
private final ForwardingRequest request = ForwardingRequestTestFactory.create(); private final ForwardingRequest request = ForwardingRequestTestFactory.create();
private final Eingang eingang = EingangTestFactory.create();
private final Vorgang vorgang = VorgangTestFactory.createBuilder().clearEingangs().eingang(eingang).build();
@Nested @Nested
class TestForward { class TestForward {
} }
@Nested @Nested
...@@ -156,10 +163,12 @@ class ForwardingRemoteServiceTest { ...@@ -156,10 +163,12 @@ class ForwardingRemoteServiceTest {
@Nested @Nested
class TestSendEingang { class TestSendEingang {
private final GrpcRouteForwardingRequest routeForwardingRequest = GrpcRouteForwardingRequestTestFactory.create();
@BeforeEach @BeforeEach
void init() { void init() {
when(vorgangService.getById(any())).thenReturn(VorgangTestFactory.create()); when(vorgangService.getById(any())).thenReturn(vorgang);
doReturn(GrpcRouteForwardingRequestTestFactory.create()).when(service).buildRouteForwardingRequest(any(), any()); doReturn(routeForwardingRequest).when(service).buildRouteForwardingRequest(any(), any());
} }
@Test @Test
...@@ -169,8 +178,51 @@ class ForwardingRemoteServiceTest { ...@@ -169,8 +178,51 @@ class ForwardingRemoteServiceTest {
verify(vorgangService).getById(VorgangTestFactory.ID); verify(vorgangService).getById(VorgangTestFactory.ID);
} }
@Test
void shouldBuildRouteForwardingRequest() {
sendEingang();
verify(service).buildRouteForwardingRequest(request, eingang);
}
@Test
void shouldSendForwardingRequest() {
sendEingang();
verify(requestObserver).onNext(routeForwardingRequest);
}
private void sendEingang() { private void sendEingang() {
service.sendEingang(request, requestObserver); service.sendEingang(request, requestObserver);
} }
} }
@Nested
class TestBuildRouteForwardingRequest {
private final GrpcRouteForwarding routeForwarding = GrpcRouteForwardingTestFactory.create();
@BeforeEach
void init() {
when(forwardingRequestMapper.toGrpcRouteForwarding(any(), any())).thenReturn(routeForwarding);
}
@Test
void shouldMapToRouteForwarding() {
buildRouteForwardingRequest();
verify(forwardingRequestMapper).toGrpcRouteForwarding(request, eingang);
}
@Test
void shouldReturnRouteForwardingRequest() {
var builtRequest = buildRouteForwardingRequest();
assertThat(builtRequest).isEqualTo(GrpcRouteForwardingRequestTestFactory.create());
}
private GrpcRouteForwardingRequest buildRouteForwardingRequest() {
return service.buildRouteForwardingRequest(request, eingang);
}
}
} }
...@@ -32,6 +32,7 @@ class GrpcRouteForwardingRequestTestFactory { ...@@ -32,6 +32,7 @@ class GrpcRouteForwardingRequestTestFactory {
} }
public static GrpcRouteForwardingRequest.Builder createBuilder() { public static GrpcRouteForwardingRequest.Builder createBuilder() {
return GrpcRouteForwardingRequest.newBuilder(); return GrpcRouteForwardingRequest.newBuilder()
.setRouteForwarding(GrpcRouteForwardingTestFactory.create());
} }
} }
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment