XtaClientRemoteITCase.java

package de.ozgcloud.xta.client;

import static de.ozgcloud.xta.client.extension.XtaServerSetupExtensionTestUtil.*;
import static org.assertj.core.api.Assertions.*;

import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.Nested;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.condition.EnabledIfEnvironmentVariable;
import org.junit.jupiter.api.extension.RegisterExtension;

import de.ozgcloud.xta.client.extension.XtaMessageExampleLoader;
import de.ozgcloud.xta.client.extension.XtaRemoteServerSetupExtension;
import de.ozgcloud.xta.client.model.XtaMessage;
import de.ozgcloud.xta.client.model.XtaMessageStatus;
import genv3.de.xoev.transport.xta.x211.InvalidMessageIDException;
import lombok.SneakyThrows;

@EnabledIfEnvironmentVariable(
		named = "KOP_SH_KIEL_DEV_PATH",
		matches = ".+",
		disabledReason = "This test requires the path and password of KOP_SH_KIEL_DEV.p12. "
				+ "Additionally, the endpoint of the DEV-xta-server at li33-0005.dp.dsecurecloud.de must be reachable."
)
class XtaClientRemoteITCase {

	@RegisterExtension
	static final XtaRemoteServerSetupExtension XTA_REMOTE_SERVER_SETUP_EXTENSION = new XtaRemoteServerSetupExtension();

	private XtaClient client;

	@BeforeEach
	@SneakyThrows
	void setup() {
		client = XTA_REMOTE_SERVER_SETUP_EXTENSION.getClient();
	}

	@DisplayName("get messages metadata")
	@Nested
	class TestGetMessagesMetadata {

		@DisplayName("with no messages")
		@Nested
		class TestWithNoMessages {

			@DisplayName("should return zero pending messages")
			@Test
			@SneakyThrows
			void shouldReturnZeroPendingMessages() {
				var result = client.getMessagesMetadata(CLIENT_IDENTIFIER1.value());

				assertThat(result.pendingMessageCount()).isZero();
			}
		}

		@DisplayName("with one message")
		@Nested
		class TestWithOneMessage {

			@BeforeEach
			void setup() {
				XTA_REMOTE_SERVER_SETUP_EXTENSION.sendTestMessage();
			}

			@DisplayName("should return one pending message for client")
			@Test
			@SneakyThrows
			void shouldReturnOnePendingMessageClient() {
				var result = client.getMessagesMetadata(CLIENT_IDENTIFIER1.value());