diff --git a/src/test/java/de/ozgcloud/xta/client/XtaClientEnaioExampleRemoteITCase.java b/src/test/java/de/ozgcloud/xta/client/XtaClientEnaioExampleRemoteITCase.java index c96a89aeb9cc6b1d5a4eee7d3c59eac7a402194e..b0736e1edc3156fe8f35d4ff3ec246656230fdab 100644 --- a/src/test/java/de/ozgcloud/xta/client/XtaClientEnaioExampleRemoteITCase.java +++ b/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);