OZG-5415 XtaRemoteITCase: Fix capturing all eingangs

xta-adapter/src/test/java/de/ozgcloud/eingang/xta/XtaRemoteITCase.java

@@ -3,8 +3,10 @@ package de.ozgcloud.eingang.xta;
 import static org.assertj.core.api.Assertions.*;
 import static org.grpcmock.GrpcMock.*;
 
+import java.util.Collection;
 import java.util.List;
 
+import org.grpcmock.interceptors.CapturedRequest;
 import org.grpcmock.springboot.AutoConfigureGrpcMock;
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
@@ -18,7 +20,6 @@ import org.springframework.context.annotation.Bean;
 import org.springframework.test.context.ActiveProfiles;
 
 import de.ozgcloud.eingang.Application;
-import de.ozgcloud.eingang.semantik.SemantikAdapter;
 import de.ozgcloud.vorgang.grpc.binaryFile.BinaryFileServiceGrpc;
 import de.ozgcloud.vorgang.grpc.binaryFile.GrpcUploadBinaryFileResponse;
 import de.ozgcloud.vorgang.vorgang.GrpcCreateVorgangRequest;
@@ -26,13 +27,11 @@ import de.ozgcloud.vorgang.vorgang.GrpcCreateVorgangResponse;
 import de.ozgcloud.vorgang.vorgang.GrpcEingang;
 import de.ozgcloud.vorgang.vorgang.GrpcFinishCreationResponse;
 import de.ozgcloud.vorgang.vorgang.VorgangServiceGrpc;
-import lombok.RequiredArgsConstructor;
 
 @Disabled("real live test - do only activate for manual testing (will empty XTA-E mailbox)")
 @SpringBootTest(classes = {
 		Application.class,
 		XtaRemoteITCase.ActivateXTARunnerConfig.class,
-		XtaRemoteITCase.ActivateXTARunnerConfig.class
 }, properties = { "ozgcloud.xta.server.name=LI33-0005",
 		"ozgcloud.xta.server.address=LI33-0005:3000",
 		"ozgcloud.xta.server.protocol=https",
@@ -50,19 +49,29 @@ class XtaRemoteITCase {
 	@DisplayName("run get xta messages")
 	@Nested
 	class TestRunGetXtaMessages {
+
 		@BeforeEach
 		void setup() {
-			// Mock 'start vorgang creation'
+			mockStartVorgangCreation();
+			mockUploadBinaryFiles();
+			mockFinishVorgangCreation();
+		}
+
+		private void mockStartVorgangCreation() {
 			stubFor(
 					unaryMethod(VorgangServiceGrpc.getStartCreationMethod())
 							.willReturn(GrpcCreateVorgangResponse.getDefaultInstance())
 			);
-			// Mock 'upload binary files'
+		}
+
+		private void mockUploadBinaryFiles() {
 			stubFor(
 					clientStreamingMethod(BinaryFileServiceGrpc.getUploadBinaryFileAsStreamMethod())
 							.willReturn(GrpcUploadBinaryFileResponse.getDefaultInstance())
 			);
-			// Mock 'finish vorgang creation'
+		}
+
+		private void mockFinishVorgangCreation() {
 			stubFor(
 					unaryMethod(VorgangServiceGrpc.getFinishCreationMethod())
 							.willReturn(GrpcFinishCreationResponse.getDefaultInstance())
@@ -87,6 +96,7 @@ class XtaRemoteITCase {
 
 		}
 
+		@Disabled
 		@DisplayName("should have postfach id")
 		@Test
 		void shouldHavePostfachId() {
@@ -109,6 +119,7 @@ class XtaRemoteITCase {
 			);
 		}
 
+		@Disabled
 		@DisplayName("should have organistationseinheit ID")
 		@Test
 		void shouldHaveOrganistationseinheitId() {
@@ -124,6 +135,7 @@ class XtaRemoteITCase {
 
 		}
 
+		@Disabled
 		@DisplayName("should have vorgang nummer")
 		@Test
 		void shouldHaveVorgangNummer() {
@@ -143,21 +155,18 @@ class XtaRemoteITCase {
 			return capturedRequestsFor(
 					calledMethod(VorgangServiceGrpc.getStartCreationMethod())
 			)
-					.getFirst()
-					.requests()
-					.stream().map(GrpcCreateVorgangRequest::getEingang)
+					.stream()
+					.map(CapturedRequest::requests)
+					.flatMap(Collection::stream)
+					.map(GrpcCreateVorgangRequest::getEingang)
 					.toList();
 		}
 	}
 
-	@RequiredArgsConstructor
 	static class ActivateXTARunnerConfig {
-		private final XtaService service;
-		private final SemantikAdapter semantikAdapter;
-
 		@Bean
-		XtaRunner xtaRunner() {
-			return new XtaRunner(service, semantikAdapter);
+		XtaRunner testXtaRunner() {
+			return new XtaRunner();
 		}
 	}
 

xta-adapter/src/test/resources/application-itcase.yml

 ozgcloud:
   xta:
-    identifier: afmsh:010600000000_Online-Dienste
+    identifier: afmsh:ozg-cloud-dev001
     server:
       address: localhost:3000
       name: LI33-0005