From 6a11e2d35a300278b41e38ad1f315760cd3db79e Mon Sep 17 00:00:00 2001
From: Krzysztof <krzysztof.witukiewicz@mgm-tp.com>
Date: Mon, 7 Apr 2025 18:04:36 +0200
Subject: [PATCH] OZG-7573 OZG-7991 Complete request
---
.../vorgang/vorgang/redirect/EingangForwarder.java | 1 +
.../vorgang/vorgang/redirect/EingangForwarderTest.java | 10 ++++++++++
2 files changed, 11 insertions(+)
diff --git a/vorgang-manager-server/src/main/java/de/ozgcloud/vorgang/vorgang/redirect/EingangForwarder.java b/vorgang-manager-server/src/main/java/de/ozgcloud/vorgang/vorgang/redirect/EingangForwarder.java
index 655df82a5..1e12a3b6c 100644
--- a/vorgang-manager-server/src/main/java/de/ozgcloud/vorgang/vorgang/redirect/EingangForwarder.java
+++ b/vorgang-manager-server/src/main/java/de/ozgcloud/vorgang/vorgang/redirect/EingangForwarder.java
@@ -83,6 +83,7 @@ class EingangForwarder {
sendRouteForwarding(grpcRouteForwarding);
sendAttachments(attachments);
sendRepresentations(representations);
+ requestObserver.onCompleted();
waitForCompletion(future);
}
diff --git a/vorgang-manager-server/src/test/java/de/ozgcloud/vorgang/vorgang/redirect/EingangForwarderTest.java b/vorgang-manager-server/src/test/java/de/ozgcloud/vorgang/vorgang/redirect/EingangForwarderTest.java
index 3c58b837e..49798fe14 100644
--- a/vorgang-manager-server/src/test/java/de/ozgcloud/vorgang/vorgang/redirect/EingangForwarderTest.java
+++ b/vorgang-manager-server/src/test/java/de/ozgcloud/vorgang/vorgang/redirect/EingangForwarderTest.java
@@ -95,6 +95,8 @@ class EingangForwarderTest {
@Mock
private GrpcRouteForwarding grpcRouteForwarding;
+ @Mock
+ private ClientCallStreamObserver<GrpcRouteForwardingRequest> requestObserver;
private final List<IncomingFileGroup> attachments = List.of(IncomingFileGroupTestFactory.create());
private final List<IncomingFile> representations = List.of(IncomingFileTestFactory.create());
@Mock
@@ -107,6 +109,7 @@ class EingangForwarderTest {
doNothing().when(forwarder).sendAttachments(any());
doNothing().when(forwarder).sendRepresentations(any());
doNothing().when(forwarder).waitForCompletion(any());
+ setRequestObserverInForwarder(requestObserver);
}
@Test
@@ -137,6 +140,13 @@ class EingangForwarderTest {
verify(forwarder).sendRepresentations(representations);
}
+ @Test
+ void shouldCompleteRequest() {
+ forwarder.forward(grpcRouteForwarding, attachments, representations);
+
+ verify(requestObserver).onCompleted();
+ }
+
@Test
void shouldWaitForCompletion() {
forwarder.forward(grpcRouteForwarding, attachments, representations);
--
GitLab