test(int-aws-support): S3InboundChannelAdapterParserTest

Author: boolivar

int-aws-support/build.gradle

@@ -10,4 +10,6 @@ dependencies {
     compileOnly "io.awspring.cloud:spring-cloud-aws-sqs"
     compileOnly "org.springframework.integration:spring-integration-file"
     compileOnly "org.springframework.integration:spring-integration-http"
+
+    testImplementation "io.github.boolivar:mockito-inline-extension"
 }

int-aws-support/src/test/java/org/springframework/integration/aws/support/config/xml/parsers/ParserTestBase.java

@@ -0,0 +1,52 @@
+package org.springframework.integration.aws.support.config.xml.parsers;
+
+import org.bool.junit.mockito.inline.MockitoInlineExtension;
+
+import org.apache.commons.io.IOUtils;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.BDDMockito;
+import org.mockito.junit.jupiter.MockitoExtension;
+import org.springframework.beans.factory.support.BeanDefinitionBuilder;
+import org.springframework.beans.factory.support.DefaultListableBeanFactory;
+import org.springframework.beans.factory.xml.XmlBeanDefinitionReader;
+import org.springframework.context.expression.StandardBeanExpressionResolver;
+import org.springframework.core.io.ByteArrayResource;
+
+import java.io.IOException;
+import java.io.UncheckedIOException;
+import java.nio.charset.StandardCharsets;
+
+@ExtendWith(MockitoInlineExtension.class)
+@ExtendWith(MockitoExtension.class)
+class ParserTestBase extends BDDMockito {
+
+    final DefaultListableBeanFactory beanFactory = new DefaultListableBeanFactory();
+
+    @BeforeEach
+    void configureBeanFactory() {
+        beanFactory.setBeanExpressionResolver(new StandardBeanExpressionResolver());
+    }
+
+    void registerBean(String name, Object bean) {
+        registerBean(name, bean.getClass(), bean);
+    }
+
+    <T> void registerBean(String name, Class<T> type, Object bean) {
+        beanFactory.registerBeanDefinition(name, BeanDefinitionBuilder.genericBeanDefinition(type, () -> type.cast(bean)).getBeanDefinition());
+    }
+
+    int parse(String content) {
+        return new XmlBeanDefinitionReader(beanFactory)
+            .loadBeanDefinitions(new ByteArrayResource(formatXml(content).getBytes(StandardCharsets.UTF_8)));
+    }
+
+    private String formatXml(String content) {
+        try {
+            return IOUtils.resourceToString("/template.xml", StandardCharsets.UTF_8)
+                .replace("<!-- template -->", content);
+        } catch (IOException e) {
+            throw new UncheckedIOException("Error read template.xml", e);
+        }
+    }
+}

int-aws-support/src/test/java/org/springframework/integration/aws/support/config/xml/parsers/S3InboundChannelAdapterParserTest.java

@@ -0,0 +1,87 @@
+package org.springframework.integration.aws.support.config.xml.parsers;
+
+import org.bool.junit.mockito.inline.ConstructionMock;
+
+import org.assertj.core.api.InstanceOfAssertFactories;
+import org.junit.jupiter.api.Test;
+import org.mockito.Mock;
+import org.mockito.MockedConstruction.Context;
+import org.springframework.integration.aws.inbound.S3InboundFileSynchronizer;
+import org.springframework.integration.aws.inbound.S3InboundFileSynchronizingMessageSource;
+import org.springframework.integration.aws.support.S3SessionFactory;
+import org.springframework.integration.file.filters.CompositeFileListFilter;
+import org.springframework.integration.file.filters.FileListFilter;
+
+import java.io.File;
+import java.util.Comparator;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+@ConstructionMock({
+    S3InboundFileSynchronizingMessageSource.class,
+    S3InboundFileSynchronizer.class
+})
+class S3InboundChannelAdapterParserTest extends ParserTestBase {
+
+    @Mock
+    private S3SessionFactory sessionFactory;
+
+    @Mock
+    private Comparator<File> comparator;
+
+    @Mock
+    private FileListFilter<File> localFilter;
+
+    private S3InboundFileSynchronizer synchronizer;
+
+    @Test
+    void testAdapter() {
+        registerBean("sf", sessionFactory);
+        registerBean("cmp", comparator);
+        registerBean("lf", localFilter);
+
+        parse("""
+            <int-aws:s3-inbound-channel-adapter
+                    id="s3ica"
+                    channel="c"
+                    local-directory="local"
+                    session-factory="sf"
+                    auto-create-local-directory="#{true}"
+                    comparator="cmp"
+                    delete-remote-files="#{true}"
+                    filename-pattern="file*name"
+                    local-filename-generator-expression="file.name"
+                    local-filter="lf"
+                    preserve-timestamp="#{true}"
+                    remote-directory="remote"
+                    remote-file-separator=";"
+                    temporary-file-suffix=".test"
+                    />
+            """);
+
+        var messageSource = beanFactory.getBean(S3InboundFileSynchronizingMessageSource.class);
+
+        verify(messageSource).setLocalDirectory(new File("local"));
+        verify(messageSource).setLocalFilter(localFilter);
+        verify(messageSource).setAutoCreateLocalDirectory(true);
+
+        verify(synchronizer).setDeleteRemoteFiles(true);
+        verify(synchronizer).setLocalFilenameGeneratorExpression(assertArg(e -> assertThat(e.getExpressionString()).isEqualTo("file.name")));
+        verify(synchronizer).setPreserveTimestamp(true);
+        verify(synchronizer).setRemoteDirectoryExpression(assertArg(e -> assertThat(e.getValue()).isEqualTo("remote")));
+        verify(synchronizer).setRemoteFileSeparator(";");
+        verify(synchronizer).setTemporaryFileSuffix(".test");
+        verify(synchronizer).setFilter(assertArg(f -> assertThat(f).isInstanceOf(CompositeFileListFilter.class)));
+    }
+
+    void testAdapter(S3InboundFileSynchronizingMessageSource mock, Context context) {
+        assertThat(context.arguments()).asInstanceOf(InstanceOfAssertFactories.LIST)
+            .contains(synchronizer, comparator);
+    }
+
+    void testAdapter(S3InboundFileSynchronizer mock, Context context) {
+        assertThat(context.arguments()).asInstanceOf(InstanceOfAssertFactories.LIST)
+            .contains(sessionFactory);
+        synchronizer = mock;
+    }
+}

int-aws-support/src/test/resources/template.xml

@@ -0,0 +1,10 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<beans xmlns="http://www.springframework.org/schema/beans"
+       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+       xmlns:int-aws="http://www.springframework.org/schema/integration/aws"
+       xsi:schemaLocation="http://www.springframework.org/schema/beans https://www.springframework.org/schema/beans/spring-beans.xsd
+       http://www.springframework.org/schema/integration/aws https://www.springframework.org/schema/integration/aws/spring-integration-aws.xsd">
+
+    <!-- template -->
+
+</beans>