KOP-3064 enaio: getTransportReport

src/test/java/de/ozgcloud/xta/client/XtaClientEnaioExampleRemoteITCase.java

@@ -3,6 +3,9 @@ package de.ozgcloud.xta.client;
 import static de.ozgcloud.xta.client.extension.XtaServerSetupExtensionTestUtil.TEST_AUTHOR_CLIENT_IDENTIFIER;
 import static org.assertj.core.api.Assertions.*;
 
+import de.ozgcloud.xta.client.core.WrappedXtaService;
+import de.ozgcloud.xta.client.core.XtaClientService;
+import de.ozgcloud.xta.client.model.*;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.DisplayName;
 import org.junit.jupiter.api.Nested;
@@ -14,14 +17,12 @@ import org.junit.jupiter.params.provider.ValueSource;
 
 import de.ozgcloud.xta.client.extension.XtaMessageExampleLoader;
 import de.ozgcloud.xta.client.extension.XtaRemoteServerSetupExtension;
-import de.ozgcloud.xta.client.model.XtaFile;
-import de.ozgcloud.xta.client.model.XtaIdentifier;
-import de.ozgcloud.xta.client.model.XtaMessage;
-import de.ozgcloud.xta.client.model.XtaMessageStatus;
 import de.ozgcloud.xta.client.xdomea.XdomeaXtaMessageCreator;
 import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
 
+import java.util.Optional;
+
 @Slf4j
 @EnabledIfEnvironmentVariable(
 		named = "KOP_SH_KIEL_DEV_PATH",
@@ -59,6 +60,8 @@ class XtaClientEnaioExampleRemoteITCase {
 
 			var result = testClient.sendMessage(xtaMessage);
 
+			log.info("result: {}", result);
+
 			assertThat(result.status()).isEqualTo(XtaMessageStatus.OPEN);
 		}
 
@@ -76,6 +79,30 @@ class XtaClientEnaioExampleRemoteITCase {
 		assertThat(result).isNotEmpty();
 	}
 
+	@DisplayName("should get message")
+	@Test
+	@SneakyThrows
+	void shouldGetMessage() {
+		var xtaService = (XtaClientService) getPrivateFieldValue(testClient, "service").get();
+		var wrappedService = (WrappedXtaService) getPrivateFieldValue(xtaService, "service").get();
+
+		var transportReport = wrappedService.getTransportReport("urn:de:xta:messageid:dataport_xta_210:497e0d26-0070-4b20-924d-8db0c25f1f60", TEST_AUTHOR_CLIENT_IDENTIFIER);
+
+		log.info("report: {}", transportReport);
+
+		assertThat(transportReport).isNotNull();
+	}
+
+	private Optional<Object> getPrivateFieldValue(Object object, String fieldName) {
+		try {
+			var field = object.getClass().getDeclaredField(fieldName);
+			field.setAccessible(true);
+			return Optional.of(field.get(object));
+		} catch (NoSuchFieldException | IllegalAccessException | RuntimeException e) {
+			return Optional.empty();
+		}
+	}
+
 	@SneakyThrows
 	private static XtaMessage createXdomeaMessage(XtaFile messageFile) {
 		return XDOMEA_XTA_MESSAGE_CREATOR.createMessage(messageFile);