Skip to content
Snippets Groups Projects
Select Git revision
  • c0c8f8039c9a2bb9211a49c800efc79dcea281bb
  • master default protected
  • dev
  • ckan-2.9
  • refactor-css
  • improve-accessibility
  • fix-get_action-calls
  • summary-collection
  • debug-collections
  • debug-eakte
  • experimental-linked-resources-as-uploads
  • button-text-detail
  • Detailinfo
  • hash
  • URL_Upload
  • URL_Upload_working_BB
  • url_exp
  • ODPSH-550
  • href-for-preview
  • ODPSH-HASH-ALGO
  • Algo
  • v1.61
  • v1.6
  • v1.51
  • v1.5
  • v1.4
  • v1.3
  • v1.2
  • v1.1
  • v1.0
  • v0.1
  • sprint-18
  • sprint11_2
  • sprint10
  • sprint8
  • sprint7
  • sprint6
37 results

thumbnail.py

Blame
  • XtaClientITCase.java 15.14 KiB
    package de.ozgcloud.xta.client;
    
    import static de.ozgcloud.xta.client.XtaClient.*;
    import static de.ozgcloud.xta.client.extension.XtaServerSetupExtensionTestUtil.*;
    import static java.util.Collections.*;
    import static org.assertj.core.api.Assertions.*;
    
    import java.util.ArrayList;
    import java.util.List;
    import java.util.function.Consumer;
    import java.util.function.Predicate;
    import java.util.stream.Stream;
    
    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 de.ozgcloud.xta.client.extension.StaticStringListAppender;
    import de.ozgcloud.xta.client.extension.XtaMessageExampleLoader;
    import de.ozgcloud.xta.client.extension.XtaTestServerSetupExtension;
    import de.ozgcloud.xta.client.model.XtaIdentifier;
    import de.ozgcloud.xta.client.model.XtaMessage;
    import de.ozgcloud.xta.client.model.XtaMessageMetaData;
    import de.ozgcloud.xta.client.model.XtaMessageStatus;
    import de.ozgcloud.xta.client.model.XtaTransportReport;
    import lombok.SneakyThrows;
    
    class XtaClientITCase {
    
    	@RegisterExtension
    	static final XtaTestServerSetupExtension XTA_TEST_SERVER_SETUP_EXTENSION = new XtaTestServerSetupExtension();
    	static final int TWO_MAX_LIST_ITEMS = 2;
    
    	private XtaClient setupClient;
    	private XtaClient testClient;
    
    	private List<XtaMessageMetaData> supportCheckedMetadataItems;
    	private List<XtaMessage> processedMessages;
    	private Consumer<XtaMessage> processMessageDummy;
    	private Predicate<XtaMessageMetaData> isSupportedDummy;
    
    	@BeforeEach
    	@SneakyThrows
    	void setup() {
    		processMessageDummy = (message) -> {
    		};
    		supportCheckedMetadataItems = new ArrayList<>();
    		isSupportedDummy = (metaData) -> true;
    		processedMessages = new ArrayList<>();
    		setupClient = XTA_TEST_SERVER_SETUP_EXTENSION.getSetupClient();
    
    		StaticStringListAppender.clearLogLines();
    		closeMessagesForAllReaders();
    	}
    
    	private void closeMessagesForAllReaders() {
    		closeAllMessages(setupClient, READER_CLIENT_IDENTIFIER1);
    		closeAllMessages(setupClient, READER_CLIENT_IDENTIFIER2);
    		closeAllMessages(setupClient, READER_CLIENT_IDENTIFIER3);
    	}
    
    
    	@DisplayName("fetch messages")
    	@Nested
    	class TestFetchMessages {
    
    		private List<XtaMessage> sendMessages;
    		private List<String> sendMessageIds;