Skip to content
Snippets Groups Projects
Select Git revision
  • fd4fcb7170fc3634e2fd3abc67740f597c361865
  • main default protected
  • KOP-3351-open-source-files
  • KOP-3064-Test-Nachrichten-Fuer-Enaio-DMS
  • OZG-8085-ci-components-poc
  • KOP-3126-Reproduce-Bug
  • 0.2.2
  • 0.2.1
  • 0.2.0
9 results

XtaClientITCase.java

Blame
  • 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);
    		}
    
    
    	}
    
    }