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());

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

			@DisplayName("should return no pending message for another client")
			@Test
			@SneakyThrows
			void shouldReturnNoPendingMessageForAnotherClient() {
				var result = client.getMessagesMetadata(CLIENT_IDENTIFIER2.value());

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

	}

	@DisplayName("get message")
	@Nested
	class TestGetMessage {

		private String messageId;

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

		@DisplayName("should return message with green status")
		@Test
		@SneakyThrows
		void shouldReturnMessageWithGreenStatus() {
			var result = client.getMessage(CLIENT_IDENTIFIER1.value(), messageId);

			assertThat(result.message().metaData().messageId()).isEqualTo(messageId);
			assertThat(result.transportReport().metaData().messageId()).isEqualTo(messageId);
			assertThat(result.transportReport().status()).isEqualTo(XtaMessageStatus.GREEN);
		}

		@DisplayName("should throw invalid message id exception for modified message id")
		@Test
		void shouldThrowInvalidMessageIdExceptionForModifiedMessageId() {
			assertThatThrownBy(() -> client.getMessage(CLIENT_IDENTIFIER1.value(), messageId + "1"))
					.isInstanceOf(InvalidMessageIDException.class);
		}

		@DisplayName("should throw invalid message id exception for other client")
		@Test
		void shouldThrowInvalidMessageIdExceptionForOtherClient() {
			assertThatThrownBy(() -> client.getMessage(CLIENT_IDENTIFIER2.value(), messageId))
					.isInstanceOf(InvalidMessageIDException.class);
		}

	}

	@DisplayName("send message")
	@Nested
	class TestSendMessage {

		private final XtaMessage xtaMessage = XtaMessageExampleLoader.load(
				XtaMessageExampleLoader.MessageExampleConfig.builder()
						.messageLabel("dfoerdermittel")
						.messageId(null)
						.author(CLIENT_IDENTIFIER1)
						.reader(CLIENT_IDENTIFIER1)
						.build());

		@DisplayName("should return with open status")
		@Test
		@SneakyThrows
		void shouldReturn() {
			var result = client.sendMessage(xtaMessage);

			assertThat(result.status()).isEqualTo(XtaMessageStatus.OPEN);
		}
	}

}