Select Git revision
XtaClientITCase.java
XtaClientITCase.java 3.58 KiB
package de.ozgcloud.xta.client;
import static de.ozgcloud.xta.client.XtaDevServerSetupExtension.*;
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.extension.RegisterExtension;
import genv3.de.xoev.transport.xta.x211.InvalidMessageIDException;
import lombok.SneakyThrows;
class XtaClientITCase {
@RegisterExtension
static final XtaTestServerSetupExtension XTA_TEST_SERVER_SETUP_EXTENSION = new XtaTestServerSetupExtension();
private XtaClient client;
@BeforeEach
@SneakyThrows
void setup() {
client = XTA_TEST_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_TEST_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_TEST_SERVER_SETUP_EXTENSION.sendTestMessage();
}
@DisplayName("should return message")
@Test
@SneakyThrows
void shouldReturnMessage() {
var result = client.getMessage(CLIENT_IDENTIFIER1.value(), messageId);
assertThat(result.message().metaData().messageId()).isEqualTo(messageId);
}
@DisplayName("should return transport report")
@Test
@SneakyThrows
void shouldReturnTransportReport() {
var result = client.getMessage(CLIENT_IDENTIFIER1.value(), messageId);
assertThat(result.transportReport().metaData().messageId()).isEqualTo(messageId);
}
@DisplayName("should throw invalid message id exception on second call due to closed message")
@Test
@SneakyThrows
void shouldThrowInvalidMessageIdExceptionOnSecondCallDueToClosedMessage() {
client.getMessage(CLIENT_IDENTIFIER1.value(), messageId);
assertThatThrownBy(() -> client.getMessage(CLIENT_IDENTIFIER1.value(), messageId))
.isInstanceOf(InvalidMessageIDException.class);
}
@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);
}
}
}