From c6ddfe1af454700029144983de6fda3d8beb85ef Mon Sep 17 00:00:00 2001 From: Marcin Grzejszczak Date: Sun, 3 Feb 2019 15:34:10 +0100 Subject: [PATCH] Added checkstyle for tests --- Guardfile | 8 +- pom.xml | 2 + ...ringBootApiGatewayRequestHandlerTests.java | 16 ++++ .../AzureSpringBootRequestHandlerTests.java | 4 +- .../AzureSpringFunctionInitializerTests.java | 1 + .../openwhisk/OpenWhiskActionHandlerTest.java | 15 ++-- .../compiler/java/CompilationMessage.java | 4 +- .../compiler/java/InMemoryJavaFileObject.java | 2 +- .../compiler/java/JrtEntryJavaFileObject.java | 2 +- .../compiler/java/JrtFsEnumeration.java | 4 +- .../java/MemoryBasedJavaFileManager.java | 6 +- .../CompilerDependencyResolutionTests.java | 55 ++++++------ .../java/RuntimeJavaCompilerTests.java | 84 ++++++++++--------- .../proxy/ByteCodeLoadingFunctionTests.java | 3 +- .../src/test/resources/logback.xml | 2 +- .../context/FunctionRegistrationTests.java | 1 + .../function/context/FunctionTypeTests.java | 1 + .../catalog/InMemoryFunctionCatalogTests.java | 13 ++- ...FunctionCatalogAutoConfigurationTests.java | 2 +- ...ontextFunctionCatalogInitializerTests.java | 2 +- .../ContextFunctionPostProcessorTests.java | 3 +- .../string/FunctionalStringSourceTests.java | 2 + .../function/inject/FooConfiguration.java | 1 + .../cloud/function/util/JsonMapperTests.java | 1 + .../java/com/example/functions/Emitter.java | 2 +- .../deployer/FunctionApplication.java | 1 + .../FunctionCreatorConfigurationTests.java | 2 +- .../SingleEntryFunctionRegistryTests.java | 1 + .../SpringFunctionAppConfigurationTests.java | 2 +- ...FunctionAppExplodedConfigurationTests.java | 2 +- .../SpringFunctionFluxConfigurationTests.java | 4 +- .../test/resources/app/META-INF/MANIFEST.MF | 2 +- .../main/resources/META-INF/spring.factories | 2 +- .../src/main/java/example/Config.java | 7 +- .../src/test/java/example/MapTests.java | 2 +- .../src/main/java/example/FooHandler.java | 6 +- .../src/test/java/example/MapTests.java | 2 +- .../example/SampleCompiledConsumerTests.java | 12 +-- .../example/SampleCompiledFunctionTests.java | 10 +-- .../java/com/example/SampleApplication.java | 4 +- .../example/SampleApplicationMvcTests.java | 6 +- .../com/example/SampleApplicationTests.java | 37 ++++---- .../java/com/example/SampleApplication.java | 10 +-- .../test/java/com/example/FunctionTests.java | 29 +++---- .../example/SampleApplicationMvcTests.java | 4 +- .../com/example/SampleApplicationTests.java | 36 ++++---- .../main/resources/META-INF/spring.factories | 2 +- .../cloud/function/web/util/HeaderUtils.java | 8 +- .../flux/FluxRestApplicationTests.java | 3 + .../function/mvc/MvcRestApplicationTests.java | 3 + .../test/FunctionalWithInputSetTests.java | 8 +- .../function/test/HeadersToMessageTests.java | 1 + .../cloud/function/test/PojoTests.java | 4 +- .../web/flux/HeadersToMessageTests.java | 24 +++--- .../web/flux/HttpGetIntegrationTests.java | 1 + .../web/flux/HttpPostIntegrationTests.java | 1 + .../web/mvc/HeadersToMessageTests.java | 23 ++--- .../web/mvc/HttpGetIntegrationTests.java | 1 + .../web/mvc/HttpPostIntegrationTests.java | 1 + .../main/resources/META-INF/spring.provides | 2 +- .../main/resources/META-INF/spring.provides | 2 +- 61 files changed, 273 insertions(+), 228 deletions(-) diff --git a/Guardfile b/Guardfile index 51dddedc8..da91d82bb 100644 --- a/Guardfile +++ b/Guardfile @@ -5,8 +5,8 @@ require './src/main/ruby/readme.rb' options = {:mkdirs => true, :safe => :unsafe, :attributes => ['linkcss', 'allow-uri-read']} guard 'shell' do - watch(/^src\/[A-Z-a-z][^#]*\.adoc$/) {|m| - SpringCloud::Build.render_file('src/main/asciidoc/README.adoc', :to_file => './README.adoc') - Asciidoctor.render_file('src/main/asciidoc/spring-cloud-cli.adoc', options.merge(:to_dir => 'target/generated-docs')) - } + watch(/^src\/[A-Z-a-z][^#]*\.adoc$/) {|m| + SpringCloud::Build.render_file('src/main/asciidoc/README.adoc', :to_file => './README.adoc') + Asciidoctor.render_file('src/main/asciidoc/spring-cloud-cli.adoc', options.merge(:to_dir => 'target/generated-docs')) + } end diff --git a/pom.xml b/pom.xml index 89b6e2466..c614752b9 100644 --- a/pom.xml +++ b/pom.xml @@ -26,6 +26,8 @@ true true + true + diff --git a/spring-cloud-function-adapters/spring-cloud-function-adapter-aws/src/test/java/org/springframework/cloud/function/adapter/aws/SpringBootApiGatewayRequestHandlerTests.java b/spring-cloud-function-adapters/spring-cloud-function-adapter-aws/src/test/java/org/springframework/cloud/function/adapter/aws/SpringBootApiGatewayRequestHandlerTests.java index 1841a9c90..858ac7c75 100644 --- a/spring-cloud-function-adapters/spring-cloud-function-adapter-aws/src/test/java/org/springframework/cloud/function/adapter/aws/SpringBootApiGatewayRequestHandlerTests.java +++ b/spring-cloud-function-adapters/spring-cloud-function-adapter-aws/src/test/java/org/springframework/cloud/function/adapter/aws/SpringBootApiGatewayRequestHandlerTests.java @@ -1,3 +1,19 @@ +/* + * Copyright 2012-2019 the original author or authors. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + package org.springframework.cloud.function.adapter.aws; import java.util.Collections; diff --git a/spring-cloud-function-adapters/spring-cloud-function-adapter-azure/src/test/java/org/springframework/cloud/function/adapter/azure/AzureSpringBootRequestHandlerTests.java b/spring-cloud-function-adapters/spring-cloud-function-adapter-azure/src/test/java/org/springframework/cloud/function/adapter/azure/AzureSpringBootRequestHandlerTests.java index 09090dcae..223a208a9 100644 --- a/spring-cloud-function-adapters/spring-cloud-function-adapter-azure/src/test/java/org/springframework/cloud/function/adapter/azure/AzureSpringBootRequestHandlerTests.java +++ b/spring-cloud-function-adapters/spring-cloud-function-adapter-azure/src/test/java/org/springframework/cloud/function/adapter/azure/AzureSpringBootRequestHandlerTests.java @@ -188,7 +188,7 @@ class Foo { Foo() { } - public Foo(String value) { + Foo(String value) { this.value = value; } @@ -217,7 +217,7 @@ class Bar { Bar() { } - public Bar(String value) { + Bar(String value) { this.value = value; } diff --git a/spring-cloud-function-adapters/spring-cloud-function-adapter-azure/src/test/java/org/springframework/cloud/function/adapter/azure/AzureSpringFunctionInitializerTests.java b/spring-cloud-function-adapters/spring-cloud-function-adapter-azure/src/test/java/org/springframework/cloud/function/adapter/azure/AzureSpringFunctionInitializerTests.java index f50d44752..3303490ed 100644 --- a/spring-cloud-function-adapters/spring-cloud-function-adapter-azure/src/test/java/org/springframework/cloud/function/adapter/azure/AzureSpringFunctionInitializerTests.java +++ b/spring-cloud-function-adapters/spring-cloud-function-adapter-azure/src/test/java/org/springframework/cloud/function/adapter/azure/AzureSpringFunctionInitializerTests.java @@ -13,6 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ + package org.springframework.cloud.function.adapter.azure; import java.io.IOException; diff --git a/spring-cloud-function-adapters/spring-cloud-function-adapter-openwhisk/src/test/java/org/springframework/cloud/function/adapter/openwhisk/OpenWhiskActionHandlerTest.java b/spring-cloud-function-adapters/spring-cloud-function-adapter-openwhisk/src/test/java/org/springframework/cloud/function/adapter/openwhisk/OpenWhiskActionHandlerTest.java index 229ab8067..b74392637 100644 --- a/spring-cloud-function-adapters/spring-cloud-function-adapter-openwhisk/src/test/java/org/springframework/cloud/function/adapter/openwhisk/OpenWhiskActionHandlerTest.java +++ b/spring-cloud-function-adapters/spring-cloud-function-adapter-openwhisk/src/test/java/org/springframework/cloud/function/adapter/openwhisk/OpenWhiskActionHandlerTest.java @@ -36,14 +36,13 @@ import org.springframework.context.annotation.Scope; import org.springframework.test.context.TestPropertySource; import org.springframework.test.context.junit4.SpringRunner; -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertNotNull; +import static org.assertj.core.api.Assertions.assertThat; /** * @author Kamesh Sampath */ @RunWith(SpringRunner.class) -@SpringBootTest() +@SpringBootTest @EnableAutoConfiguration @TestPropertySource(locations = "classpath:/application-test.properties") public class OpenWhiskActionHandlerTest { @@ -65,9 +64,9 @@ public class OpenWhiskActionHandlerTest { actionRequest.setActionName("test_action"); actionRequest.setValue(eventData); Object result = this.actionHandler.run(actionRequest); - assertNotNull(result); - assertEquals("{\"result\":{\"name\":\"Spring\",\"message\":\"Hello, Spring\"}}", - result); + assertThat(result).isNotNull(); + assertThat(result).isEqualTo( + "{\"result\":{\"name\":\"Spring\",\"message\":\"Hello, Spring\"}}"); } @Test @@ -78,8 +77,8 @@ public class OpenWhiskActionHandlerTest { OpenWhiskActionRequest actionRequest = new OpenWhiskActionRequest(); actionRequest.setActionName("test_action"); Object result = this.actionHandler.run(actionRequest); - assertNotNull(result); - assertEquals("{\"result\":\"No input provided\"}", result); + assertThat(result).isNotNull(); + assertThat(result).isEqualTo("{\"result\":\"No input provided\"}"); } @Configuration diff --git a/spring-cloud-function-compiler/src/main/java/org/springframework/cloud/function/compiler/java/CompilationMessage.java b/spring-cloud-function-compiler/src/main/java/org/springframework/cloud/function/compiler/java/CompilationMessage.java index add6f621c..69a09f5e1 100644 --- a/spring-cloud-function-compiler/src/main/java/org/springframework/cloud/function/compiler/java/CompilationMessage.java +++ b/spring-cloud-function-compiler/src/main/java/org/springframework/cloud/function/compiler/java/CompilationMessage.java @@ -43,7 +43,7 @@ public class CompilationMessage { this.sourceCode = sourceCode; this.startPosition = startPosition; this.endPosition = endPosition; - }; + } /** * @return the type of message @@ -84,7 +84,7 @@ public class CompilationMessage { StringBuilder s = new StringBuilder(); s.append("==========\n"); if (this.sourceCode != null) { // Cannot include source context if no source - // available + // available int[] lineStartEnd = getLineStartEnd(this.startPosition); s.append(this.sourceCode.substring(lineStartEnd[0], lineStartEnd[1])) .append("\n"); diff --git a/spring-cloud-function-compiler/src/main/java/org/springframework/cloud/function/compiler/java/InMemoryJavaFileObject.java b/spring-cloud-function-compiler/src/main/java/org/springframework/cloud/function/compiler/java/InMemoryJavaFileObject.java index 73f24cc97..1f4e2b458 100644 --- a/spring-cloud-function-compiler/src/main/java/org/springframework/cloud/function/compiler/java/InMemoryJavaFileObject.java +++ b/spring-cloud-function-compiler/src/main/java/org/springframework/cloud/function/compiler/java/InMemoryJavaFileObject.java @@ -201,7 +201,7 @@ public final class InMemoryJavaFileObject implements JavaFileObject { InMemoryJavaFileObject.this.lastModifiedTime = System.currentTimeMillis(); InMemoryJavaFileObject.this.content = new String(toCharArray()) .getBytes(); // Ignoring encoding... - }; + } }; } diff --git a/spring-cloud-function-compiler/src/main/java/org/springframework/cloud/function/compiler/java/JrtEntryJavaFileObject.java b/spring-cloud-function-compiler/src/main/java/org/springframework/cloud/function/compiler/java/JrtEntryJavaFileObject.java index 519e5642f..ed58885be 100644 --- a/spring-cloud-function-compiler/src/main/java/org/springframework/cloud/function/compiler/java/JrtEntryJavaFileObject.java +++ b/spring-cloud-function-compiler/src/main/java/org/springframework/cloud/function/compiler/java/JrtEntryJavaFileObject.java @@ -48,7 +48,7 @@ public class JrtEntryJavaFileObject implements JavaFileObject { */ public JrtEntryJavaFileObject(Path path) { this.pathToClassString = path.subpath(2, path.getNameCount()).toString(); // e.g. - // java/lang/Object.class + // java/lang/Object.class this.path = path; } diff --git a/spring-cloud-function-compiler/src/main/java/org/springframework/cloud/function/compiler/java/JrtFsEnumeration.java b/spring-cloud-function-compiler/src/main/java/org/springframework/cloud/function/compiler/java/JrtFsEnumeration.java index 4dc8b16eb..ffabc5446 100644 --- a/spring-cloud-function-compiler/src/main/java/org/springframework/cloud/function/compiler/java/JrtFsEnumeration.java +++ b/spring-cloud-function-compiler/src/main/java/org/springframework/cloud/function/compiler/java/JrtFsEnumeration.java @@ -127,8 +127,8 @@ public class JrtFsEnumeration implements Enumeration { throws IOException { int fnc = file.getNameCount(); if (fnc >= 3 && file.toString().endsWith(".class")) { // There is a preceeding - // module name - e.g. - // /modules/java.base/java/lang/Object.class + // module name - e.g. + // /modules/java.base/java/lang/Object.class // file.subpath(2, fnc); // e.g. java/lang/Object.class JrtFsEnumeration.this.jfos.add(new JrtEntryJavaFileObject(file)); } diff --git a/spring-cloud-function-compiler/src/main/java/org/springframework/cloud/function/compiler/java/MemoryBasedJavaFileManager.java b/spring-cloud-function-compiler/src/main/java/org/springframework/cloud/function/compiler/java/MemoryBasedJavaFileManager.java index 2bcd2a23c..ed3780334 100644 --- a/spring-cloud-function-compiler/src/main/java/org/springframework/cloud/function/compiler/java/MemoryBasedJavaFileManager.java +++ b/spring-cloud-function-compiler/src/main/java/org/springframework/cloud/function/compiler/java/MemoryBasedJavaFileManager.java @@ -207,8 +207,8 @@ public class MemoryBasedJavaFileManager implements JavaFileManager { URL[] urls = loader.getURLs(); if (urls.length > 1) { // heuristic that catches Maven surefire tests if (!urls[0].toString().startsWith("jar:file:")) { // heuristic for - // Spring Boot fat - // jar + // Spring Boot fat + // jar StringBuilder builder = new StringBuilder(); for (URL url : urls) { if (builder.length() > 0) { @@ -627,7 +627,7 @@ public class MemoryBasedJavaFileManager implements JavaFileManager { if (file.getNameCount() > 3 && file.toString().endsWith(".class")) { int fnc = file.getNameCount(); if (fnc > 3) { // There is a package name - e.g. - // /modules/java.base/java/lang/Object.class + // /modules/java.base/java/lang/Object.class Path packagePath = file.subpath(2, fnc - 1); // e.g. java/lang String packagePathString = packagePath.toString() + "/"; CompilationInfoCache.this.packageCache.put(packagePathString, diff --git a/spring-cloud-function-compiler/src/test/java/org/springframework/cloud/function/compiler/CompilerDependencyResolutionTests.java b/spring-cloud-function-compiler/src/test/java/org/springframework/cloud/function/compiler/CompilerDependencyResolutionTests.java index ccd7e2868..51a330d2c 100644 --- a/spring-cloud-function-compiler/src/test/java/org/springframework/cloud/function/compiler/CompilerDependencyResolutionTests.java +++ b/spring-cloud-function-compiler/src/test/java/org/springframework/cloud/function/compiler/CompilerDependencyResolutionTests.java @@ -13,6 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ + package org.springframework.cloud.function.compiler; import java.io.File; @@ -42,15 +43,13 @@ import org.springframework.cloud.function.compiler.java.RuntimeJavaCompiler; import org.springframework.cloud.function.core.FunctionFactoryUtils; import static org.assertj.core.api.Assertions.assertThat; -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertTrue; /** * Tests that verify dependency resolution. Dependencies can be resolved against simple * classpath entries or against classes under BOOT-INF/classes or in a nested jar under * under BOOT-INF/lib. Finding classes in those locations enables compilation against a * packaged boot jar. - * + * * @author Andy Clement */ public class CompilerDependencyResolutionTests { @@ -60,7 +59,7 @@ public class CompilerDependencyResolutionTests { ClassDescriptor t1 = compile("Test1", "package com.test;\npublic class Test1 { public static String doit() { return \"T1\";}}\n"); String result = (String) t1.clazz.getDeclaredMethod("doit").invoke(null); - assertEquals("T1", result); + assertThat(result).isEqualTo("T1"); } @Test @@ -140,12 +139,12 @@ public class CompilerDependencyResolutionTests { "public class A {\n" + " public static Object run() {\n" + " return new TestX();\n" + " }\n" + "}", jar.toURI().toString()); - assertTrue("Should be no problems: " + result.getCompilationMessages(), - result.getCompilationMessages().isEmpty()); + assertThat(result.getCompilationMessages().isEmpty()) + .as("Should be no problems: " + result.getCompilationMessages()).isTrue(); try (URLClassLoader cl = new TestClassLoader(tx, descriptorFromResult(result))) { Class class1 = cl.loadClass("A"); Object invoke = class1.getDeclaredMethod("run").invoke(null); - assertEquals(tx.name, invoke.getClass().getName()); + assertThat(invoke.getClass().getName()).isEqualTo(tx.name); } } @@ -162,12 +161,12 @@ public class CompilerDependencyResolutionTests { "public class A {\n" + " public static Object run() {\n" + " return new TestX();\n" + " }\n" + "}", jar.toURI().toString()); - assertTrue("Should be no problems: " + result.getCompilationMessages(), - result.getCompilationMessages().isEmpty()); + assertThat(result.getCompilationMessages().isEmpty()) + .as("Should be no problems: " + result.getCompilationMessages()).isTrue(); try (URLClassLoader cl = new TestClassLoader(t1, descriptorFromResult(result))) { Class class1 = cl.loadClass("A"); Object invoke = class1.getDeclaredMethod("run").invoke(null); - assertEquals(t1.name, invoke.getClass().getName()); + assertThat(invoke.getClass().getName()).isEqualTo(t1.name); } } @@ -185,12 +184,12 @@ public class CompilerDependencyResolutionTests { "public class A {\n" + " public static Object run() {\n" + " return new TestX();\n" + " }\n" + "}", jar2.toURI().toString()); - assertTrue("Should be no problems: " + result.getCompilationMessages(), - result.getCompilationMessages().isEmpty()); + assertThat(result.getCompilationMessages().isEmpty()) + .as("Should be no problems: " + result.getCompilationMessages()).isTrue(); try (URLClassLoader cl = new TestClassLoader(t1, descriptorFromResult(result))) { Class class1 = cl.loadClass("A"); Object invoke = class1.getDeclaredMethod("run").invoke(null); - assertEquals(t1.name, invoke.getClass().getName()); + assertThat(invoke.getClass().getName()).isEqualTo(t1.name); } } @@ -205,12 +204,12 @@ public class CompilerDependencyResolutionTests { + " public static Object run() {\n" + " return new Test1();\n" + " }\n" + "}", jar.toURI().toString()); - assertTrue("Should be no problems: " + result.getCompilationMessages(), - result.getCompilationMessages().isEmpty()); + assertThat(result.getCompilationMessages().isEmpty()) + .as("Should be no problems: " + result.getCompilationMessages()).isTrue(); try (URLClassLoader cl = new TestClassLoader(t1, descriptorFromResult(result))) { Class class1 = cl.loadClass("A"); Object invoke = class1.getDeclaredMethod("run").invoke(null); - assertEquals(t1.name, invoke.getClass().getName()); + assertThat(invoke.getClass().getName()).isEqualTo(t1.name); } } @@ -226,12 +225,12 @@ public class CompilerDependencyResolutionTests { + " public static Object run() {\n" + " return new Test1();\n" + " }\n" + "}", jar.toURI().toString()); - assertTrue("Should be no problems: " + result.getCompilationMessages(), - result.getCompilationMessages().isEmpty()); + assertThat(result.getCompilationMessages().isEmpty()) + .as("Should be no problems: " + result.getCompilationMessages()).isTrue(); try (URLClassLoader cl = new TestClassLoader(t1, descriptorFromResult(result))) { Class class1 = cl.loadClass("A"); Object invoke = class1.getDeclaredMethod("run").invoke(null); - assertEquals(t1.name, invoke.getClass().getName()); + assertThat(invoke.getClass().getName()).isEqualTo(t1.name); } } @@ -248,12 +247,12 @@ public class CompilerDependencyResolutionTests { + " public static Object run() {\n" + " return new Test1();\n" + " }\n" + "}", jar2.toURI().toString()); - assertTrue("Should be no problems: " + result.getCompilationMessages(), - result.getCompilationMessages().isEmpty()); + assertThat(result.getCompilationMessages().isEmpty()) + .as("Should be no problems: " + result.getCompilationMessages()).isTrue(); try (URLClassLoader cl = new TestClassLoader(t1, descriptorFromResult(result))) { Class class1 = cl.loadClass("A"); Object invoke = class1.getDeclaredMethod("run").invoke(null); - assertEquals(t1.name, invoke.getClass().getName()); + assertThat(invoke.getClass().getName()).isEqualTo(t1.name); } } @@ -268,8 +267,8 @@ public class CompilerDependencyResolutionTests { private ClassDescriptor compile(String className, String classSourceCode) { CompilationResult compile = new RuntimeJavaCompiler().compile(className, classSourceCode); - assertTrue("Should be empty: \n" + compile.getCompilationMessages(), - compile.getCompilationMessages().isEmpty()); + assertThat(compile.getCompilationMessages().isEmpty()) + .as("Should be empty: \n" + compile.getCompilationMessages()).isTrue(); Class clazz = compile.getCompiledClasses().get(0); return new ClassDescriptor(clazz.getName(), compile.getClassBytes(clazz.getName()), @@ -299,7 +298,7 @@ public class CompilerDependencyResolutionTests { clazzes.add(prefix + classDescriptor.name.replace('.', '/') + ".class"); } walkJar(jar, (entry) -> clazzes.remove(entry.getName())); - assertTrue("Should be empty: " + clazzes, clazzes.isEmpty()); + assertThat(clazzes.isEmpty()).as("Should be empty: " + clazzes).isTrue(); } private void walkJar(File jar, Consumer fn) { @@ -336,7 +335,7 @@ public class CompilerDependencyResolutionTests { final Class clazz; - public ClassDescriptor(String name, byte[] bytes, Class clazz) { + ClassDescriptor(String name, byte[] bytes, Class clazz) { this.name = name; this.bytes = bytes; this.clazz = clazz; @@ -344,7 +343,7 @@ public class CompilerDependencyResolutionTests { } - static class JarBuilder { + static final class JarBuilder { File jarFile; @@ -446,7 +445,7 @@ public class CompilerDependencyResolutionTests { ClassDescriptor[] descriptors; - public TestClassLoader(ClassDescriptor... descriptors) { + TestClassLoader(ClassDescriptor... descriptors) { super(new URL[0], TestClassLoader.class.getClassLoader()); this.descriptors = descriptors; } diff --git a/spring-cloud-function-compiler/src/test/java/org/springframework/cloud/function/compiler/java/RuntimeJavaCompilerTests.java b/spring-cloud-function-compiler/src/test/java/org/springframework/cloud/function/compiler/java/RuntimeJavaCompilerTests.java index e08504df0..e5250c193 100644 --- a/spring-cloud-function-compiler/src/test/java/org/springframework/cloud/function/compiler/java/RuntimeJavaCompilerTests.java +++ b/spring-cloud-function-compiler/src/test/java/org/springframework/cloud/function/compiler/java/RuntimeJavaCompilerTests.java @@ -23,8 +23,7 @@ import java.util.function.Supplier; import org.junit.Test; -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertTrue; +import static org.assertj.core.api.Assertions.assertThat; /** * @author Andy Clement @@ -37,7 +36,7 @@ public class RuntimeJavaCompilerTests { RuntimeJavaCompiler rjc = new RuntimeJavaCompiler(); CompilationResult cr = rjc.compile("A", "public class A {}"); List compilationMessages = cr.getCompilationMessages(); - assertTrue(compilationMessages.isEmpty()); + assertThat(compilationMessages.isEmpty()).isTrue(); } @Test @@ -52,18 +51,19 @@ public class RuntimeJavaCompilerTests { + " String message = (String) exp.getValue();" + " return message;\n" + " }\n" + "}"); List compilationMessages = cr.getCompilationMessages(); - assertEquals(3, compilationMessages.size()); - assertTrue( - compilationMessages.get(0).getMessage().contains("cannot find symbol")); - assertTrue(compilationMessages.get(0).getMessage() - .contains("class ExpressionParser")); - assertTrue( - compilationMessages.get(1).getMessage().contains("cannot find symbol")); - assertTrue(compilationMessages.get(1).getMessage() - .contains("class SpelExpressionParser")); - assertTrue( - compilationMessages.get(2).getMessage().contains("cannot find symbol")); - assertTrue(compilationMessages.get(2).getMessage().contains("class Expression")); + assertThat(compilationMessages.size()).isEqualTo(3); + assertThat(compilationMessages.get(0).getMessage().contains("cannot find symbol")) + .isTrue(); + assertThat(compilationMessages.get(0).getMessage() + .contains("class ExpressionParser")).isTrue(); + assertThat(compilationMessages.get(1).getMessage().contains("cannot find symbol")) + .isTrue(); + assertThat(compilationMessages.get(1).getMessage() + .contains("class SpelExpressionParser")).isTrue(); + assertThat(compilationMessages.get(2).getMessage().contains("cannot find symbol")) + .isTrue(); + assertThat(compilationMessages.get(2).getMessage().contains("class Expression")) + .isTrue(); } @Test @@ -80,12 +80,12 @@ public class RuntimeJavaCompilerTests { + " return message;\n" + " }\n" + "}", "maven://org.springframework:spring-expression:4.3.9.RELEASE"); List compilationMessages = cr.getCompilationMessages(); - assertTrue(compilationMessages.isEmpty()); + assertThat(compilationMessages.isEmpty()).isTrue(); try (SimpleClassLoader cl = new SimpleClassLoader( this.getClass().getClassLoader())) { Class clazz = cl.defineClass("A", cr.getClassBytes("A")); Supplier supplier = (Supplier) clazz.newInstance(); - assertEquals("Hello World", supplier.get()); + assertThat(supplier.get()).isEqualTo("Hello World"); } } @@ -100,27 +100,27 @@ public class RuntimeJavaCompilerTests { CompilationResult cr = rjc.compile("A", source, "maven://joda-time:joda-time:2.9.9"); List compilationMessages = cr.getCompilationMessages(); - assertTrue(compilationMessages.isEmpty()); + assertThat(compilationMessages.isEmpty()).isTrue(); List resolvedAdditionalDependencies = cr .getResolvedAdditionalDependencies(); try (SimpleClassLoader cl = new SimpleClassLoader(resolvedAdditionalDependencies, this.getClass().getClassLoader())) { Class clazz = cl.defineClass("A", cr.getClassBytes("A")); Supplier supplier = (Supplier) clazz.newInstance(); - assertEquals("true", supplier.get()); + assertThat(supplier.get()).isEqualTo("true"); } cr = rjc.compile("A", source, "maven://org.springframework:spring-expression:4.3.9.RELEASE", "maven://joda-time:joda-time:2.9.9"); compilationMessages = cr.getCompilationMessages(); - assertTrue(compilationMessages.isEmpty()); + assertThat(compilationMessages.isEmpty()).isTrue(); resolvedAdditionalDependencies = cr.getResolvedAdditionalDependencies(); try (SimpleClassLoader cl = new SimpleClassLoader(resolvedAdditionalDependencies, this.getClass().getClassLoader())) { Class clazz = cl.defineClass("A", cr.getClassBytes("A")); Supplier supplier = (Supplier) clazz.newInstance(); - assertEquals("true", supplier.get()); + assertThat(supplier.get()).isEqualTo("true"); } } @@ -130,43 +130,45 @@ public class RuntimeJavaCompilerTests { RuntimeJavaCompiler rjc = new RuntimeJavaCompiler(); CompilationResult cr = rjc.compile("A", "public class A {}", "maven://org.springframework:spring-expression2:4.3.9.RELEASE"); // extra - // '2' - // in - // there + // '2' + // in + // there List compilationMessages = cr.getCompilationMessages(); - assertEquals(1, compilationMessages.size()); + assertThat(compilationMessages.size()).isEqualTo(1); // ERROR:org.eclipse.aether.resolution.ArtifactResolutionException: Could not find // artifact org.springframework:spring-expression2:jar:4.3.9.RELEASE in // spring-snapshots (https://repo.spring.io/libs-snapshot) - assertTrue(compilationMessages.get(0).getMessage().contains( - "Could not find artifact org.springframework:spring-expression2:jar:4.3.9.RELEASE")); + assertThat(compilationMessages.get(0).getMessage().contains( + "Could not find artifact org.springframework:spring-expression2:jar:4.3.9.RELEASE")) + .isTrue(); // Failure: rjc = new RuntimeJavaCompiler(); cr = rjc.compile("A", "public class A {}", "trouble://org.springframework:spring-expression:4.3.9.RELEASE"); // rogue - // prefix - // (should - // be - // "maven:") + // prefix + // (should + // be + // "maven:") compilationMessages = cr.getCompilationMessages(); - assertEquals(1, compilationMessages.size()); - assertTrue(compilationMessages.get(0).toString(), compilationMessages.get(0) - .getMessage().contains("Unrecognized dependency: ")); + assertThat(compilationMessages.size()).isEqualTo(1); + assertThat(compilationMessages.get(0).getMessage() + .contains("Unrecognized dependency: ")) + .as(compilationMessages.get(0).toString()).isTrue(); // Success rjc = new RuntimeJavaCompiler(); cr = rjc.compile("A", "public class A {}", "maven://joda-time:joda-time:2.9.9"); compilationMessages = cr.getCompilationMessages(); - assertEquals(0, compilationMessages.size()); + assertThat(compilationMessages.size()).isEqualTo(0); List resolvedAdditionalDependencies = cr .getResolvedAdditionalDependencies(); - assertEquals(1, resolvedAdditionalDependencies.size()); - assertTrue( - "Expected this to end with 'joda-time-2.9.9.jar': " - + resolvedAdditionalDependencies.get(0).toString(), - resolvedAdditionalDependencies.get(0).toString() - .endsWith("joda-time-2.9.9.jar")); + assertThat(resolvedAdditionalDependencies.size()).isEqualTo(1); + assertThat(resolvedAdditionalDependencies.get(0).toString() + .endsWith("joda-time-2.9.9.jar")) + .as("Expected this to end with 'joda-time-2.9.9.jar': " + + resolvedAdditionalDependencies.get(0).toString()) + .isTrue(); } } diff --git a/spring-cloud-function-compiler/src/test/java/org/springframework/cloud/function/compiler/proxy/ByteCodeLoadingFunctionTests.java b/spring-cloud-function-compiler/src/test/java/org/springframework/cloud/function/compiler/proxy/ByteCodeLoadingFunctionTests.java index 0c7134e21..6356576dc 100644 --- a/spring-cloud-function-compiler/src/test/java/org/springframework/cloud/function/compiler/proxy/ByteCodeLoadingFunctionTests.java +++ b/spring-cloud-function-compiler/src/test/java/org/springframework/cloud/function/compiler/proxy/ByteCodeLoadingFunctionTests.java @@ -87,7 +87,8 @@ public class ByteCodeLoadingFunctionTests { @Test public void compileFluxFunction() throws Exception { - CompiledFunctionFactory, Flux>> compiled = new FunctionCompiler, Flux>( + CompiledFunctionFactory, Flux>> compiled = null; + compiled = new FunctionCompiler, Flux>( String.class.getName()).compile("foos", "flux -> flux.map(v -> v.toUpperCase())", "Flux", "Flux"); diff --git a/spring-cloud-function-compiler/src/test/resources/logback.xml b/spring-cloud-function-compiler/src/test/resources/logback.xml index c72797c13..7d0a9651e 100644 --- a/spring-cloud-function-compiler/src/test/resources/logback.xml +++ b/spring-cloud-function-compiler/src/test/resources/logback.xml @@ -5,4 +5,4 @@ - \ No newline at end of file + diff --git a/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/FunctionRegistrationTests.java b/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/FunctionRegistrationTests.java index 32176ce7a..5cdc481ae 100644 --- a/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/FunctionRegistrationTests.java +++ b/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/FunctionRegistrationTests.java @@ -13,6 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ + package org.springframework.cloud.function.context; import java.util.function.Function; diff --git a/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/FunctionTypeTests.java b/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/FunctionTypeTests.java index 85fe0e59a..1c5c32f05 100644 --- a/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/FunctionTypeTests.java +++ b/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/FunctionTypeTests.java @@ -13,6 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ + package org.springframework.cloud.function.context; import java.lang.reflect.Type; diff --git a/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/catalog/InMemoryFunctionCatalogTests.java b/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/catalog/InMemoryFunctionCatalogTests.java index 19456737d..38e217abd 100644 --- a/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/catalog/InMemoryFunctionCatalogTests.java +++ b/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/catalog/InMemoryFunctionCatalogTests.java @@ -24,10 +24,7 @@ import org.springframework.cloud.function.context.FunctionRegistration; import org.springframework.cloud.function.context.FunctionType; import org.springframework.cloud.function.core.FluxFunction; -import static org.junit.Assert.assertNotNull; -import static org.junit.Assert.assertNull; -import static org.junit.Assert.assertSame; -import static org.junit.Assert.assertTrue; +import static org.assertj.core.api.Assertions.assertThat; /** * @author Oleg Zhurakousky @@ -43,7 +40,7 @@ public class InMemoryFunctionCatalogTests { InMemoryFunctionCatalog catalog = new InMemoryFunctionCatalog(); catalog.register(registration); FunctionRegistration registration2 = catalog.getRegistration(function); - assertSame(registration, registration2); + assertThat(registration2).isSameAs(registration); } @Test @@ -55,11 +52,11 @@ public class InMemoryFunctionCatalogTests { catalog.register(registration); Object lookedUpFunction = catalog.lookup("hello"); - assertNull(lookedUpFunction); + assertThat(lookedUpFunction).isNull(); lookedUpFunction = catalog.lookup("foo"); - assertNotNull(lookedUpFunction); - assertTrue(lookedUpFunction instanceof FluxFunction); + assertThat(lookedUpFunction).isNotNull(); + assertThat(lookedUpFunction instanceof FluxFunction).isTrue(); } private static class TestFunction implements Function { diff --git a/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/config/ContextFunctionCatalogAutoConfigurationTests.java b/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/config/ContextFunctionCatalogAutoConfigurationTests.java index 9a0ccdff1..98e419c50 100644 --- a/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/config/ContextFunctionCatalogAutoConfigurationTests.java +++ b/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/config/ContextFunctionCatalogAutoConfigurationTests.java @@ -1,5 +1,5 @@ /* - * Copyright 2012-2019-2018 the original author or authors. + * Copyright 2012-2019 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/config/ContextFunctionCatalogInitializerTests.java b/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/config/ContextFunctionCatalogInitializerTests.java index 11f312a47..280876d82 100644 --- a/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/config/ContextFunctionCatalogInitializerTests.java +++ b/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/config/ContextFunctionCatalogInitializerTests.java @@ -1,5 +1,5 @@ /* - * Copyright 2012-2019-2018 the original author or authors. + * Copyright 2012-2019 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/config/ContextFunctionPostProcessorTests.java b/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/config/ContextFunctionPostProcessorTests.java index 27c27b14b..c63ca0b5f 100644 --- a/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/config/ContextFunctionPostProcessorTests.java +++ b/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/config/ContextFunctionPostProcessorTests.java @@ -40,7 +40,6 @@ import org.springframework.test.util.ReflectionTestUtils; import org.springframework.util.ClassUtils; import static org.assertj.core.api.Assertions.assertThat; -import static org.junit.Assert.assertNull; /** * @author Dave Syer @@ -132,7 +131,7 @@ public class ContextFunctionPostProcessorTests { System.out::println, "consumer")); Supplier> supplier = (Supplier>) this.processor .lookupSupplier("supplier|consumer"); - assertNull(supplier.get().block()); + assertThat(supplier.get().block()).isNull(); } @Test diff --git a/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/string/FunctionalStringSourceTests.java b/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/string/FunctionalStringSourceTests.java index f8777550d..21759004e 100644 --- a/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/string/FunctionalStringSourceTests.java +++ b/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/string/FunctionalStringSourceTests.java @@ -36,7 +36,9 @@ import static org.assertj.core.api.Assertions.assertThat; * */ @RunWith(SpringRunner.class) +// @checkstyle:off @FunctionalSpringBootTest(classes = Object.class, properties = "spring.main.sources=org.springframework.cloud.function.context.string.FunctionalStringSourceTests.TestConfiguration") +// @checkstyle:on public class FunctionalStringSourceTests { @Autowired diff --git a/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/inject/FooConfiguration.java b/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/inject/FooConfiguration.java index 4148022ce..0bd796406 100644 --- a/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/inject/FooConfiguration.java +++ b/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/inject/FooConfiguration.java @@ -13,6 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ + package org.springframework.cloud.function.inject; import java.util.function.Function; diff --git a/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/util/JsonMapperTests.java b/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/util/JsonMapperTests.java index 3688599ac..b35560adc 100644 --- a/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/util/JsonMapperTests.java +++ b/spring-cloud-function-context/src/test/java/org/springframework/cloud/function/util/JsonMapperTests.java @@ -13,6 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ + package org.springframework.cloud.function.util; import java.util.Arrays; diff --git a/spring-cloud-function-deployer/src/it/support/src/main/java/com/example/functions/Emitter.java b/spring-cloud-function-deployer/src/it/support/src/main/java/com/example/functions/Emitter.java index 9b1d4a1ee..f5afa8992 100644 --- a/spring-cloud-function-deployer/src/it/support/src/main/java/com/example/functions/Emitter.java +++ b/spring-cloud-function-deployer/src/it/support/src/main/java/com/example/functions/Emitter.java @@ -25,7 +25,7 @@ public class Emitter implements Supplier { private int i = 0; - private String[] values = { "one", "two", "three", "four" }; + private String[] values = {"one", "two", "three", "four"}; @Override public String get() { diff --git a/spring-cloud-function-deployer/src/main/java/org/springframework/cloud/function/deployer/FunctionApplication.java b/spring-cloud-function-deployer/src/main/java/org/springframework/cloud/function/deployer/FunctionApplication.java index b285eba3d..d30c95f1e 100644 --- a/spring-cloud-function-deployer/src/main/java/org/springframework/cloud/function/deployer/FunctionApplication.java +++ b/spring-cloud-function-deployer/src/main/java/org/springframework/cloud/function/deployer/FunctionApplication.java @@ -21,6 +21,7 @@ import java.io.IOException; import org.springframework.boot.autoconfigure.SpringBootApplication; // @checkstyle:off + /** * @author Mark Fisher * @author Dave Syer diff --git a/spring-cloud-function-deployer/src/test/java/org/springframework/cloud/function/deployer/FunctionCreatorConfigurationTests.java b/spring-cloud-function-deployer/src/test/java/org/springframework/cloud/function/deployer/FunctionCreatorConfigurationTests.java index dd336589d..02e261e68 100644 --- a/spring-cloud-function-deployer/src/test/java/org/springframework/cloud/function/deployer/FunctionCreatorConfigurationTests.java +++ b/spring-cloud-function-deployer/src/test/java/org/springframework/cloud/function/deployer/FunctionCreatorConfigurationTests.java @@ -1,5 +1,5 @@ /* - * Copyright 2012-2019-2018 the original author or authors. + * Copyright 2012-2019 the original author or authors. * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. diff --git a/spring-cloud-function-deployer/src/test/java/org/springframework/cloud/function/deployer/SingleEntryFunctionRegistryTests.java b/spring-cloud-function-deployer/src/test/java/org/springframework/cloud/function/deployer/SingleEntryFunctionRegistryTests.java index 4305c34e2..b8285dc3a 100644 --- a/spring-cloud-function-deployer/src/test/java/org/springframework/cloud/function/deployer/SingleEntryFunctionRegistryTests.java +++ b/spring-cloud-function-deployer/src/test/java/org/springframework/cloud/function/deployer/SingleEntryFunctionRegistryTests.java @@ -13,6 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ + package org.springframework.cloud.function.deployer; import java.util.function.Function; diff --git a/spring-cloud-function-deployer/src/test/java/org/springframework/cloud/function/deployer/SpringFunctionAppConfigurationTests.java b/spring-cloud-function-deployer/src/test/java/org/springframework/cloud/function/deployer/SpringFunctionAppConfigurationTests.java index 13187eae4..3d4670d20 100644 --- a/spring-cloud-function-deployer/src/test/java/org/springframework/cloud/function/deployer/SpringFunctionAppConfigurationTests.java +++ b/spring-cloud-function-deployer/src/test/java/org/springframework/cloud/function/deployer/SpringFunctionAppConfigurationTests.java @@ -39,7 +39,7 @@ import static org.hamcrest.Matchers.containsString; @RunWith(SpringRunner.class) @SpringBootTest(classes = FunctionDeployerConfiguration.class, webEnvironment = SpringBootTest.WebEnvironment.NONE) @TestPropertySource(properties = { - "function.location=file:target/it/support/target/function-sample-1.0.0.M1-exec.jar", }) + "function.location=file:target/it/support/target/function-sample-1.0.0.M1-exec.jar" }) public abstract class SpringFunctionAppConfigurationTests { @Autowired diff --git a/spring-cloud-function-deployer/src/test/java/org/springframework/cloud/function/deployer/SpringFunctionAppExplodedConfigurationTests.java b/spring-cloud-function-deployer/src/test/java/org/springframework/cloud/function/deployer/SpringFunctionAppExplodedConfigurationTests.java index 296443efe..2b521ee04 100644 --- a/spring-cloud-function-deployer/src/test/java/org/springframework/cloud/function/deployer/SpringFunctionAppExplodedConfigurationTests.java +++ b/spring-cloud-function-deployer/src/test/java/org/springframework/cloud/function/deployer/SpringFunctionAppExplodedConfigurationTests.java @@ -39,7 +39,7 @@ import static org.hamcrest.Matchers.containsString; @RunWith(SpringRunner.class) @SpringBootTest(classes = FunctionDeployerConfiguration.class, webEnvironment = SpringBootTest.WebEnvironment.NONE) @TestPropertySource(properties = { - "function.location=file:target/it/support/target/dependency", }) + "function.location=file:target/it/support/target/dependency" }) public abstract class SpringFunctionAppExplodedConfigurationTests { @Autowired diff --git a/spring-cloud-function-deployer/src/test/java/org/springframework/cloud/function/deployer/SpringFunctionFluxConfigurationTests.java b/spring-cloud-function-deployer/src/test/java/org/springframework/cloud/function/deployer/SpringFunctionFluxConfigurationTests.java index 818efcabb..abda0412d 100644 --- a/spring-cloud-function-deployer/src/test/java/org/springframework/cloud/function/deployer/SpringFunctionFluxConfigurationTests.java +++ b/spring-cloud-function-deployer/src/test/java/org/springframework/cloud/function/deployer/SpringFunctionFluxConfigurationTests.java @@ -98,10 +98,10 @@ class Foo { private String value; - public Foo() { + Foo() { } - public Foo(String value) { + Foo(String value) { this.value = value; } diff --git a/spring-cloud-function-deployer/src/test/resources/app/META-INF/MANIFEST.MF b/spring-cloud-function-deployer/src/test/resources/app/META-INF/MANIFEST.MF index d1f4a9c13..1f1bb507b 100644 --- a/spring-cloud-function-deployer/src/test/resources/app/META-INF/MANIFEST.MF +++ b/spring-cloud-function-deployer/src/test/resources/app/META-INF/MANIFEST.MF @@ -11,4 +11,4 @@ Start-Class: org.springframework.cloud.function.test.FunctionApp Created-By: Apache Maven 3.5.0 Build-Jdk: 1.8.0_131 Implementation-URL: http://projects.spring.io/spring-boot/function-sam - ple/ \ No newline at end of file + ple/ diff --git a/spring-cloud-function-kotlin/src/main/resources/META-INF/spring.factories b/spring-cloud-function-kotlin/src/main/resources/META-INF/spring.factories index 3ca9bed74..74b563338 100644 --- a/spring-cloud-function-kotlin/src/main/resources/META-INF/spring.factories +++ b/spring-cloud-function-kotlin/src/main/resources/META-INF/spring.factories @@ -1,2 +1,2 @@ org.springframework.boot.autoconfigure.EnableAutoConfiguration=\ -org.springframework.cloud.function.context.config.KotlinLambdaToFunctionAutoConfiguration \ No newline at end of file +org.springframework.cloud.function.context.config.KotlinLambdaToFunctionAutoConfiguration diff --git a/spring-cloud-function-samples/function-sample-aws/src/main/java/example/Config.java b/spring-cloud-function-samples/function-sample-aws/src/main/java/example/Config.java index 0b1635985..721b78a59 100644 --- a/spring-cloud-function-samples/function-sample-aws/src/main/java/example/Config.java +++ b/spring-cloud-function-samples/function-sample-aws/src/main/java/example/Config.java @@ -48,7 +48,8 @@ public class Config implements ApplicationContextInitializer function() { return value -> new Bar( - value.uppercase() + (this.props.getFoo() != null ? "-" + this.props.getFoo() : "")); + value.uppercase() + (this.props.getFoo() != null ? "-" + this.props + .getFoo() : "")); } @Override @@ -57,8 +58,8 @@ public class Config implements ApplicationContextInitializer properties); context.registerBean("function", FunctionRegistration.class, - () -> new FunctionRegistration>(function()) - .type(FunctionType.from(Foo.class).to(Bar.class).getType())); + () -> new FunctionRegistration>(function()) + .type(FunctionType.from(Foo.class).to(Bar.class).getType())); } } diff --git a/spring-cloud-function-samples/function-sample-aws/src/test/java/example/MapTests.java b/spring-cloud-function-samples/function-sample-aws/src/test/java/example/MapTests.java index 1631c66a7..2f724ebe2 100644 --- a/spring-cloud-function-samples/function-sample-aws/src/test/java/example/MapTests.java +++ b/spring-cloud-function-samples/function-sample-aws/src/test/java/example/MapTests.java @@ -37,7 +37,7 @@ public class MapTests { @Test public void start() throws Exception { SpringBootRequestHandler handler = new SpringBootRequestHandler<>( - Config.class); + Config.class); handler.handleRequest(new Foo("foo"), null); handler.close(); } diff --git a/spring-cloud-function-samples/function-sample-azure/src/main/java/example/FooHandler.java b/spring-cloud-function-samples/function-sample-azure/src/main/java/example/FooHandler.java index 51b7b9190..a48d29842 100644 --- a/spring-cloud-function-samples/function-sample-azure/src/main/java/example/FooHandler.java +++ b/spring-cloud-function-samples/function-sample-azure/src/main/java/example/FooHandler.java @@ -31,9 +31,9 @@ public class FooHandler extends AzureSpringBootRequestHandler { @FunctionName("uppercase") public Bar execute( - @HttpTrigger(name = "req", methods = { HttpMethod.GET, - HttpMethod.POST }, authLevel = AuthorizationLevel.ANONYMOUS) Foo foo, - ExecutionContext context) { + @HttpTrigger(name = "req", methods = {HttpMethod.GET, + HttpMethod.POST}, authLevel = AuthorizationLevel.ANONYMOUS) Foo foo, + ExecutionContext context) { return handleRequest(foo, context); } diff --git a/spring-cloud-function-samples/function-sample-azure/src/test/java/example/MapTests.java b/spring-cloud-function-samples/function-sample-azure/src/test/java/example/MapTests.java index be695a55c..f6ab4f9af 100644 --- a/spring-cloud-function-samples/function-sample-azure/src/test/java/example/MapTests.java +++ b/spring-cloud-function-samples/function-sample-azure/src/test/java/example/MapTests.java @@ -37,7 +37,7 @@ public class MapTests { @Test public void start() throws Exception { AzureSpringBootRequestHandler handler = new AzureSpringBootRequestHandler<>( - Config.class); + Config.class); Bar result = handler.handleRequest(new Foo("foo"), null); handler.close(); assertThat(result.getValue()).isEqualTo("FOO"); diff --git a/spring-cloud-function-samples/function-sample-compiler/src/test/java/com/example/SampleCompiledConsumerTests.java b/spring-cloud-function-samples/function-sample-compiler/src/test/java/com/example/SampleCompiledConsumerTests.java index 2a902282e..371bc6870 100644 --- a/spring-cloud-function-samples/function-sample-compiler/src/test/java/com/example/SampleCompiledConsumerTests.java +++ b/spring-cloud-function-samples/function-sample-compiler/src/test/java/com/example/SampleCompiledConsumerTests.java @@ -26,16 +26,15 @@ import org.springframework.boot.web.server.LocalServerPort; import org.springframework.test.context.junit4.SpringRunner; import static org.assertj.core.api.Assertions.assertThat; -import static org.junit.Assert.assertEquals; /** * @author Mark Fisher */ @RunWith(SpringRunner.class) @SpringBootTest(webEnvironment = WebEnvironment.RANDOM_PORT, properties = { - "spring.cloud.function.compile.test.lambda=com.example.SampleCompiledConsumerTests.Reference::set", - "spring.cloud.function.compile.test.inputType=String", - "spring.cloud.function.compile.test.type=consumer" }) + "spring.cloud.function.compile.test.lambda=com.example.SampleCompiledConsumerTests.Reference::set", + "spring.cloud.function.compile.test.inputType=String", + "spring.cloud.function.compile.test.type=consumer"}) public class SampleCompiledConsumerTests { @LocalServerPort @@ -44,8 +43,9 @@ public class SampleCompiledConsumerTests { @Test public void print() { assertThat(new TestRestTemplate().postForObject( - "http://localhost:" + this.port + "/test", "it works", String.class)).isNull(); - assertEquals("it works", Reference.instance); + "http://localhost:" + this.port + "/test", "it works", String.class)) + .isNull(); + assertThat(Reference.instance).isEqualTo("it works"); } public static class Reference { diff --git a/spring-cloud-function-samples/function-sample-compiler/src/test/java/com/example/SampleCompiledFunctionTests.java b/spring-cloud-function-samples/function-sample-compiler/src/test/java/com/example/SampleCompiledFunctionTests.java index c2a898c4b..4fe94a08c 100644 --- a/spring-cloud-function-samples/function-sample-compiler/src/test/java/com/example/SampleCompiledFunctionTests.java +++ b/spring-cloud-function-samples/function-sample-compiler/src/test/java/com/example/SampleCompiledFunctionTests.java @@ -32,9 +32,9 @@ import static org.assertj.core.api.Assertions.assertThat; */ @RunWith(SpringRunner.class) @SpringBootTest(webEnvironment = WebEnvironment.RANDOM_PORT, properties = { - "spring.cloud.function.compile.test.lambda=f->f.map(s->s+\"!!!\")", - "spring.cloud.function.compile.test.inputType=Flux", - "spring.cloud.function.compile.test.outputType=Flux" }) + "spring.cloud.function.compile.test.lambda=f->f.map(s->s+\"!!!\")", + "spring.cloud.function.compile.test.inputType=Flux", + "spring.cloud.function.compile.test.outputType=Flux"}) public class SampleCompiledFunctionTests { @LocalServerPort @@ -43,8 +43,8 @@ public class SampleCompiledFunctionTests { @Test public void lowercase() { assertThat(new TestRestTemplate().postForObject( - "http://localhost:" + this.port + "/test", "it works", String.class)) - .contains("it works!!!"); + "http://localhost:" + this.port + "/test", "it works", String.class)) + .contains("it works!!!"); } } diff --git a/spring-cloud-function-samples/function-sample-pojo/src/main/java/com/example/SampleApplication.java b/spring-cloud-function-samples/function-sample-pojo/src/main/java/com/example/SampleApplication.java index a0cebd78d..b44c4a0ad 100644 --- a/spring-cloud-function-samples/function-sample-pojo/src/main/java/com/example/SampleApplication.java +++ b/spring-cloud-function-samples/function-sample-pojo/src/main/java/com/example/SampleApplication.java @@ -46,14 +46,14 @@ public class SampleApplication { return multiValueMap -> { Map result = new HashMap<>(); multiValueMap.forEach((s, strings) -> result.put(s, - strings.stream().mapToInt(Integer::parseInt).sum())); + strings.stream().mapToInt(Integer::parseInt).sum())); return result; }; } @Bean public Supplier> words() { - return () -> Flux.fromArray(new Foo[] { new Foo("foo"), new Foo("bar") }).log(); + return () -> Flux.fromArray(new Foo[] {new Foo("foo"), new Foo("bar")}).log(); } } diff --git a/spring-cloud-function-samples/function-sample-pojo/src/test/java/com/example/SampleApplicationMvcTests.java b/spring-cloud-function-samples/function-sample-pojo/src/test/java/com/example/SampleApplicationMvcTests.java index ebc863205..efdb46d55 100644 --- a/spring-cloud-function-samples/function-sample-pojo/src/test/java/com/example/SampleApplicationMvcTests.java +++ b/spring-cloud-function-samples/function-sample-pojo/src/test/java/com/example/SampleApplicationMvcTests.java @@ -13,6 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ + package com.example; import java.net.URI; @@ -43,10 +44,11 @@ public class SampleApplicationMvcTests { @Test public void words() throws Exception { - ResponseEntity result = this.rest.exchange(RequestEntity.get(new URI("/words")) + ResponseEntity result = this.rest + .exchange(RequestEntity.get(new URI("/words")) .accept(MediaType.APPLICATION_JSON).build(), String.class); assertThat(result.getBody()) - .isEqualTo("[{\"value\":\"foo\"},{\"value\":\"bar\"}]"); + .isEqualTo("[{\"value\":\"foo\"},{\"value\":\"bar\"}]"); } } diff --git a/spring-cloud-function-samples/function-sample-pojo/src/test/java/com/example/SampleApplicationTests.java b/spring-cloud-function-samples/function-sample-pojo/src/test/java/com/example/SampleApplicationTests.java index 557629178..cee4c48b5 100644 --- a/spring-cloud-function-samples/function-sample-pojo/src/test/java/com/example/SampleApplicationTests.java +++ b/spring-cloud-function-samples/function-sample-pojo/src/test/java/com/example/SampleApplicationTests.java @@ -13,6 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ + package com.example; import java.net.URI; @@ -58,35 +59,37 @@ public class SampleApplicationTests { @Test public void words() { - assertThat(this.rest.getForObject("http://localhost:" + this.port + "/words", String.class)) - .isEqualTo("[{\"value\":\"foo\"},{\"value\":\"bar\"}]"); + assertThat(this.rest + .getForObject("http://localhost:" + this.port + "/words", String.class)) + .isEqualTo("[{\"value\":\"foo\"},{\"value\":\"bar\"}]"); } @Test public void uppercase() { assertThat(this.rest.postForObject("http://localhost:" + this.port + "/uppercase", - new HttpEntity<>("[{\"value\":\"foo\"}]", this.headers), String.class)) - .isEqualTo("[{\"value\":\"FOO\"}]"); + new HttpEntity<>("[{\"value\":\"foo\"}]", this.headers), String.class)) + .isEqualTo("[{\"value\":\"FOO\"}]"); } @Test public void composite() { - assertThat(this.rest.getForObject("http://localhost:" + this.port + "/words,uppercase", + assertThat(this.rest + .getForObject("http://localhost:" + this.port + "/words,uppercase", String.class)).isEqualTo("[{\"value\":\"FOO\"},{\"value\":\"BAR\"}]"); } @Test public void single() { assertThat(this.rest.postForObject("http://localhost:" + this.port + "/uppercase", - new HttpEntity<>("{\"value\":\"foo\"}", this.headers), String.class)) - .isEqualTo("{\"value\":\"FOO\"}"); + new HttpEntity<>("{\"value\":\"foo\"}", this.headers), String.class)) + .isEqualTo("{\"value\":\"FOO\"}"); } @Test public void lowercase() { assertThat(this.rest.postForObject("http://localhost:" + this.port + "/lowercase", - new HttpEntity<>("[{\"value\":\"Foo\"}]", this.headers), String.class)) - .isEqualTo("[{\"value\":\"foo\"}]"); + new HttpEntity<>("[{\"value\":\"Foo\"}]", this.headers), String.class)) + .isEqualTo("[{\"value\":\"foo\"}]"); } @Test @@ -98,10 +101,10 @@ public class SampleApplicationTests { map.put("B", Arrays.asList("5", "6")); assertThat(this.rest.exchange( - RequestEntity.post(new URI("http://localhost:" + this.port + "/sum")) - .accept(MediaType.APPLICATION_JSON) - .contentType(MediaType.APPLICATION_FORM_URLENCODED).body(map), - String.class).getBody()).isEqualTo("[{\"A\":6,\"B\":11}]"); + RequestEntity.post(new URI("http://localhost:" + this.port + "/sum")) + .accept(MediaType.APPLICATION_JSON) + .contentType(MediaType.APPLICATION_FORM_URLENCODED).body(map), + String.class).getBody()).isEqualTo("[{\"A\":6,\"B\":11}]"); } @Test @@ -114,10 +117,10 @@ public class SampleApplicationTests { map.put("B", Arrays.asList("5", "6")); assertThat(this.rest.exchange( - RequestEntity.post(new URI("http://localhost:" + this.port + "/sum")) - .accept(MediaType.APPLICATION_JSON) - .contentType(MediaType.MULTIPART_FORM_DATA).body(map), - String.class).getBody()).isEqualTo("[{\"A\":6,\"B\":11}]"); + RequestEntity.post(new URI("http://localhost:" + this.port + "/sum")) + .accept(MediaType.APPLICATION_JSON) + .contentType(MediaType.MULTIPART_FORM_DATA).body(map), + String.class).getBody()).isEqualTo("[{\"A\":6,\"B\":11}]"); } } diff --git a/spring-cloud-function-samples/function-sample/src/main/java/com/example/SampleApplication.java b/spring-cloud-function-samples/function-sample/src/main/java/com/example/SampleApplication.java index 28876cbc2..ececd960d 100644 --- a/spring-cloud-function-samples/function-sample/src/main/java/com/example/SampleApplication.java +++ b/spring-cloud-function-samples/function-sample/src/main/java/com/example/SampleApplication.java @@ -53,25 +53,25 @@ public class SampleApplication { @Bean public Supplier> words() { - return () -> Flux.fromArray(new String[] { "foo", "bar" }); + return () -> Flux.fromArray(new String[] {"foo", "bar"}); } @Bean public Function compiledUppercase( - FunctionCompiler compiler) { + FunctionCompiler compiler) { String lambda = "s -> s.toUpperCase()"; LambdaCompilingFunction function = new LambdaCompilingFunction<>( - new ByteArrayResource(lambda.getBytes()), compiler); + new ByteArrayResource(lambda.getBytes()), compiler); function.setTypeParameterizations("String", "String"); return function; } @Bean public Function, Flux> compiledLowercase( - FunctionCompiler, Flux> compiler) { + FunctionCompiler, Flux> compiler) { String lambda = "f->f.map(o->o.toString().toLowerCase())"; return new LambdaCompilingFunction<>(new ByteArrayResource(lambda.getBytes()), - compiler); + compiler); } @Bean diff --git a/spring-cloud-function-samples/function-sample/src/test/java/com/example/FunctionTests.java b/spring-cloud-function-samples/function-sample/src/test/java/com/example/FunctionTests.java index 623d6f8e0..6b8be8ae4 100644 --- a/spring-cloud-function-samples/function-sample/src/test/java/com/example/FunctionTests.java +++ b/spring-cloud-function-samples/function-sample/src/test/java/com/example/FunctionTests.java @@ -24,7 +24,7 @@ import com.example.functions.Greeter; import org.junit.Test; import reactor.core.publisher.Flux; -import static org.junit.Assert.assertEquals; +import static org.assertj.core.api.Assertions.assertThat; public class FunctionTests { @@ -33,36 +33,36 @@ public class FunctionTests { @Test public void testUppercase() { String output = this.functions.uppercase().apply("foobar"); - assertEquals("FOOBAR", output); + assertThat(output).isEqualTo("FOOBAR"); } @Test public void testLowercase() { Flux output = this.functions.lowercase().apply(Flux.just("FOO", "BAR")); List results = output.collectList().block(); - assertEquals(2, results.size()); - assertEquals("foo", results.get(0)); - assertEquals("bar", results.get(1)); + assertThat(results.size()).isEqualTo(2); + assertThat(results.get(0)).isEqualTo("foo"); + assertThat(results.get(1)).isEqualTo("bar"); } @Test public void testHello() { String output = this.functions.hello().get(); - assertEquals("hello", output); + assertThat(output).isEqualTo("hello"); } @Test public void testWords() { Flux output = this.functions.words().get(); List results = output.collectList().block(); - assertEquals(2, results.size()); - assertEquals("foo", results.get(0)); - assertEquals("bar", results.get(1)); + assertThat(results.size()).isEqualTo(2); + assertThat(results.get(0)).isEqualTo("foo"); + assertThat(results.get(1)).isEqualTo("bar"); } @Test public void testGreeter() { - assertEquals("Hello World", new Greeter().apply("World")); + assertThat(new Greeter().apply("World")).isEqualTo("Hello World"); } @Test @@ -70,14 +70,15 @@ public class FunctionTests { Flux input = Flux.just("foo", "bar"); Flux output = new Exclaimer().apply(input); List results = output.collectList().block(); - assertEquals(2, results.size()); - assertEquals("foo!!!", results.get(0)); - assertEquals("bar!!!", results.get(1)); + assertThat(results.size()).isEqualTo(2); + assertThat(results.get(0)).isEqualTo("foo!!!"); + assertThat(results.get(1)).isEqualTo("bar!!!"); } @Test public void testCharCounter() { - assertEquals((Integer) 21, new CharCounter().apply("this is 21 chars long")); + assertThat(new CharCounter().apply("this is 21 chars long")) + .isEqualTo((Integer) 21); } } diff --git a/spring-cloud-function-samples/function-sample/src/test/java/com/example/SampleApplicationMvcTests.java b/spring-cloud-function-samples/function-sample/src/test/java/com/example/SampleApplicationMvcTests.java index 3c8a623ce..92d7cf54f 100644 --- a/spring-cloud-function-samples/function-sample/src/test/java/com/example/SampleApplicationMvcTests.java +++ b/spring-cloud-function-samples/function-sample/src/test/java/com/example/SampleApplicationMvcTests.java @@ -13,6 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ + package com.example; import org.junit.Ignore; @@ -40,7 +41,8 @@ public class SampleApplicationMvcTests { @Test @Ignore("FIXME") public void words() throws Exception { - this.mockMvc.perform(get("/words")).andExpect(content().string("[\"foo\",\"bar\"]")); + this.mockMvc.perform(get("/words")) + .andExpect(content().string("[\"foo\",\"bar\"]")); } } diff --git a/spring-cloud-function-samples/function-sample/src/test/java/com/example/SampleApplicationTests.java b/spring-cloud-function-samples/function-sample/src/test/java/com/example/SampleApplicationTests.java index a3565f8bd..c96a3fbb5 100644 --- a/spring-cloud-function-samples/function-sample/src/test/java/com/example/SampleApplicationTests.java +++ b/spring-cloud-function-samples/function-sample/src/test/java/com/example/SampleApplicationTests.java @@ -28,7 +28,7 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.test.context.junit4.SpringRunner; -import static org.junit.Assert.assertEquals; +import static org.assertj.core.api.Assertions.assertThat; @RunWith(SpringRunner.class) @SpringBootTest @@ -60,22 +60,22 @@ public class SampleApplicationTests { @Test public void testUppercase() { String output = this.uppercase.apply("foobar"); - assertEquals("FOOBAR", output); + assertThat(output).isEqualTo("FOOBAR"); } @Test public void testLowercase() { Flux output = this.lowercase.apply(Flux.just("FOO", "BAR")); List results = output.collectList().block(); - assertEquals(2, results.size()); - assertEquals("foo", results.get(0)); - assertEquals("bar", results.get(1)); + assertThat(results.size()).isEqualTo(2); + assertThat(results.get(0)).isEqualTo("foo"); + assertThat(results.get(1)).isEqualTo("bar"); } @Test public void testHello() { String output = this.hello.get(); - assertEquals("hello", output); + assertThat(output).isEqualTo("hello"); } // the following are contributed via @FunctionScan: @@ -84,15 +84,15 @@ public class SampleApplicationTests { public void testWords() { Flux output = this.words.get(); List results = output.collectList().block(); - assertEquals(2, results.size()); - assertEquals("foo", results.get(0)); - assertEquals("bar", results.get(1)); + assertThat(results.size()).isEqualTo(2); + assertThat(results.get(0)).isEqualTo("foo"); + assertThat(results.get(1)).isEqualTo("bar"); } @Test public void testCompiledUppercase() { String output = this.compiledUppercase.apply("foobar"); - assertEquals("FOOBAR", output); + assertThat(output).isEqualTo("FOOBAR"); } @Test @@ -100,15 +100,15 @@ public class SampleApplicationTests { Flux input = Flux.just("FOO", "BAR"); Flux output = this.compiledLowercase.apply(input); List results = output.collectList().block(); - assertEquals(2, results.size()); - assertEquals("foo", results.get(0)); - assertEquals("bar", results.get(1)); + assertThat(results.size()).isEqualTo(2); + assertThat(results.get(0)).isEqualTo("foo"); + assertThat(results.get(1)).isEqualTo("bar"); } @Test public void testGreeter() { String greeting = this.greeter.apply("World"); - assertEquals("Hello World", greeting); + assertThat(greeting).isEqualTo("Hello World"); } @Test @@ -116,15 +116,15 @@ public class SampleApplicationTests { Flux input = Flux.just("foo", "bar"); Flux output = this.exclaimer.apply(input); List results = output.collectList().block(); - assertEquals(2, results.size()); - assertEquals("foo!!!", results.get(0)); - assertEquals("bar!!!", results.get(1)); + assertThat(results.size()).isEqualTo(2); + assertThat(results.get(0)).isEqualTo("foo!!!"); + assertThat(results.get(1)).isEqualTo("bar!!!"); } @Test public void testCharCounter() { Integer length = this.charCounter.apply("the quick brown fox"); - assertEquals(new Integer(19), length); + assertThat(length).isEqualTo(new Integer(19)); } } diff --git a/spring-cloud-function-task/src/main/resources/META-INF/spring.factories b/spring-cloud-function-task/src/main/resources/META-INF/spring.factories index 92a351e91..d1a315e33 100644 --- a/spring-cloud-function-task/src/main/resources/META-INF/spring.factories +++ b/spring-cloud-function-task/src/main/resources/META-INF/spring.factories @@ -1,2 +1,2 @@ org.springframework.boot.autoconfigure.EnableAutoConfiguration=\ -org.springframework.cloud.function.task.TaskConfiguration \ No newline at end of file +org.springframework.cloud.function.task.TaskConfiguration diff --git a/spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/util/HeaderUtils.java b/spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/util/HeaderUtils.java index ccefd1279..2b0d58c4c 100644 --- a/spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/util/HeaderUtils.java +++ b/spring-cloud-function-web/src/main/java/org/springframework/cloud/function/web/util/HeaderUtils.java @@ -35,10 +35,6 @@ public final class HeaderUtils { private static HttpHeaders REQUEST_ONLY = new HttpHeaders(); - private HeaderUtils() { - throw new IllegalStateException("Can't instantiate a utility class"); - } - static { IGNORED.add(MessageHeaders.ID, ""); IGNORED.add(HttpHeaders.CONTENT_LENGTH, "0"); @@ -49,6 +45,10 @@ public final class HeaderUtils { REQUEST_ONLY.add(HttpHeaders.HOST, ""); } + private HeaderUtils() { + throw new IllegalStateException("Can't instantiate a utility class"); + } + public static HttpHeaders fromMessage(MessageHeaders headers) { HttpHeaders result = new HttpHeaders(); for (String name : headers.keySet()) { diff --git a/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/flux/FluxRestApplicationTests.java b/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/flux/FluxRestApplicationTests.java index 49996169a..1d9d811cb 100644 --- a/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/flux/FluxRestApplicationTests.java +++ b/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/flux/FluxRestApplicationTests.java @@ -13,6 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ + package org.springframework.cloud.function.flux; import java.net.URI; @@ -62,7 +63,9 @@ import static org.assertj.core.api.Assertions.assertThat; * */ @RunWith(SpringRunner.class) +// @checkstyle:off @SpringBootTest(classes = TestConfiguration.class, webEnvironment = WebEnvironment.RANDOM_PORT, properties = "spring.main.web-application-type=reactive") +// @checkstyle:on public class FluxRestApplicationTests { private static final MediaType EVENT_STREAM = MediaType.valueOf("text/event-stream"); diff --git a/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/mvc/MvcRestApplicationTests.java b/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/mvc/MvcRestApplicationTests.java index 836c747b1..f1d9f1ea9 100644 --- a/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/mvc/MvcRestApplicationTests.java +++ b/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/mvc/MvcRestApplicationTests.java @@ -13,6 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ + package org.springframework.cloud.function.mvc; import java.net.URI; @@ -60,7 +61,9 @@ import static org.assertj.core.api.Assertions.assertThat; * @author Dave Syer * */ +// @checkstyle:off @SpringBootTest(classes = TestConfiguration.class, webEnvironment = WebEnvironment.RANDOM_PORT, properties = "spring.main.web-application-type=servlet") +// @checkstyle:on @RunWith(SpringRunner.class) public class MvcRestApplicationTests { diff --git a/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/test/FunctionalWithInputSetTests.java b/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/test/FunctionalWithInputSetTests.java index cba093dec..8d1c3dd74 100644 --- a/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/test/FunctionalWithInputSetTests.java +++ b/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/test/FunctionalWithInputSetTests.java @@ -31,7 +31,7 @@ import org.springframework.cloud.function.context.test.FunctionalSpringBootTest; import org.springframework.test.context.junit4.SpringRunner; import org.springframework.test.web.reactive.server.WebTestClient; -import static org.junit.Assert.assertTrue; +import static org.assertj.core.api.Assertions.assertThat; /** * @author Dave Syer @@ -52,9 +52,9 @@ public class FunctionalWithInputSetTests { String.class) .exchange().expectStatus().isOk().expectBody(String.class).returnResult() .getResponseBody(); - assertTrue(reply.contains("FOO")); - assertTrue(reply.contains("BAR")); - assertTrue(reply.contains("{\"value\":\"")); + assertThat(reply.contains("FOO")).isTrue(); + assertThat(reply.contains("BAR")).isTrue(); + assertThat(reply.contains("{\"value\":\"")).isTrue(); } @SpringBootConfiguration diff --git a/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/test/HeadersToMessageTests.java b/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/test/HeadersToMessageTests.java index 619f9f8d5..9bbc05f48 100644 --- a/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/test/HeadersToMessageTests.java +++ b/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/test/HeadersToMessageTests.java @@ -13,6 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ + package org.springframework.cloud.function.test; import java.util.function.Function; diff --git a/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/test/PojoTests.java b/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/test/PojoTests.java index 680a22b1d..313ed73fd 100644 --- a/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/test/PojoTests.java +++ b/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/test/PojoTests.java @@ -74,10 +74,10 @@ class Foo { private String value; - public Foo() { + Foo() { } - public Foo(String value) { + Foo(String value) { this.value = value; } diff --git a/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/web/flux/HeadersToMessageTests.java b/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/web/flux/HeadersToMessageTests.java index 5589a274c..b561930e3 100644 --- a/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/web/flux/HeadersToMessageTests.java +++ b/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/web/flux/HeadersToMessageTests.java @@ -13,6 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ + package org.springframework.cloud.function.web.flux; import java.net.URI; @@ -37,8 +38,7 @@ import org.springframework.messaging.support.MessageBuilder; import org.springframework.test.context.ContextConfiguration; import org.springframework.test.context.junit4.SpringRunner; -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertTrue; +import static org.assertj.core.api.Assertions.assertThat; /** * @author Dave Syer @@ -62,20 +62,20 @@ public class HeadersToMessageTests { .exchange(RequestEntity.post(new URI("/functions/employee")) .contentType(MediaType.APPLICATION_JSON) .body("{\"name\":\"Bob\",\"age\":25}"), String.class); - assertEquals("{\"name\":\"Bob\",\"age\":25}", postForEntity.getBody()); - assertTrue(postForEntity.getHeaders().containsKey("x-content-type")); - assertEquals("application/xml", - postForEntity.getHeaders().get("x-content-type").get(0)); - assertEquals("bar", postForEntity.getHeaders().get("foo").get(0)); + assertThat(postForEntity.getBody()).isEqualTo("{\"name\":\"Bob\",\"age\":25}"); + assertThat(postForEntity.getHeaders().containsKey("x-content-type")).isTrue(); + assertThat(postForEntity.getHeaders().get("x-content-type").get(0)) + .isEqualTo("application/xml"); + assertThat(postForEntity.getHeaders().get("foo").get(0)).isEqualTo("bar"); // test simple type payload postForEntity = this.rest.postForEntity(new URI("/functions/string"), "{\"name\":\"Bob\",\"age\":25}", String.class); - assertEquals("{\"name\":\"Bob\",\"age\":25}", postForEntity.getBody()); - assertTrue(postForEntity.getHeaders().containsKey("x-content-type")); - assertEquals("application/xml", - postForEntity.getHeaders().get("x-content-type").get(0)); - assertEquals("bar", postForEntity.getHeaders().get("foo").get(0)); + assertThat(postForEntity.getBody()).isEqualTo("{\"name\":\"Bob\",\"age\":25}"); + assertThat(postForEntity.getHeaders().containsKey("x-content-type")).isTrue(); + assertThat(postForEntity.getHeaders().get("x-content-type").get(0)) + .isEqualTo("application/xml"); + assertThat(postForEntity.getHeaders().get("foo").get(0)).isEqualTo("bar"); } @EnableAutoConfiguration diff --git a/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/web/flux/HttpGetIntegrationTests.java b/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/web/flux/HttpGetIntegrationTests.java index 40a182fd5..eba707687 100644 --- a/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/web/flux/HttpGetIntegrationTests.java +++ b/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/web/flux/HttpGetIntegrationTests.java @@ -13,6 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ + package org.springframework.cloud.function.web.flux; import java.net.URI; diff --git a/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/web/flux/HttpPostIntegrationTests.java b/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/web/flux/HttpPostIntegrationTests.java index fe97442bb..00f31d8c1 100644 --- a/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/web/flux/HttpPostIntegrationTests.java +++ b/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/web/flux/HttpPostIntegrationTests.java @@ -13,6 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ + package org.springframework.cloud.function.web.flux; import java.net.URI; diff --git a/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/web/mvc/HeadersToMessageTests.java b/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/web/mvc/HeadersToMessageTests.java index 66619be9b..a8793d3ff 100644 --- a/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/web/mvc/HeadersToMessageTests.java +++ b/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/web/mvc/HeadersToMessageTests.java @@ -13,6 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ + package org.springframework.cloud.function.web.mvc; import java.net.URI; @@ -39,8 +40,7 @@ import org.springframework.messaging.support.MessageBuilder; import org.springframework.test.context.ContextConfiguration; import org.springframework.test.context.junit4.SpringRunner; -import static org.junit.Assert.assertEquals; -import static org.junit.Assert.assertTrue; +import static org.assertj.core.api.Assertions.assertThat; /** * @author Oleg Zhurakousky @@ -62,11 +62,11 @@ public class HeadersToMessageTests { .exchange(RequestEntity.post(new URI("/functions/employee")) .contentType(MediaType.APPLICATION_JSON) .body("{\"name\":\"Bob\",\"age\":25}"), String.class); - assertEquals("{\"name\":\"Bob\",\"age\":25}", postForEntity.getBody()); - assertTrue(postForEntity.getHeaders().containsKey("x-content-type")); - assertEquals("application/xml", - postForEntity.getHeaders().get("x-content-type").get(0)); - assertEquals("bar", postForEntity.getHeaders().get("foo").get(0)); + assertThat(postForEntity.getBody()).isEqualTo("{\"name\":\"Bob\",\"age\":25}"); + assertThat(postForEntity.getHeaders().containsKey("x-content-type")).isTrue(); + assertThat(postForEntity.getHeaders().get("x-content-type").get(0)) + .isEqualTo("application/xml"); + assertThat(postForEntity.getHeaders().get("foo").get(0)).isEqualTo("bar"); } @Test @@ -76,10 +76,11 @@ public class HeadersToMessageTests { .contentType(MediaType.APPLICATION_JSON) .header("x-context-type", "rubbish") .body("{\"name\":\"Bob\",\"age\":25}"), String.class); - assertEquals("{\"name\":\"Bob\",\"age\":25,\"foo\":\"bar\"}", - postForEntity.getBody()); - assertTrue(postForEntity.getHeaders().containsKey("x-context-type")); - assertEquals("rubbish", postForEntity.getHeaders().get("x-context-type").get(0)); + assertThat(postForEntity.getBody()) + .isEqualTo("{\"name\":\"Bob\",\"age\":25,\"foo\":\"bar\"}"); + assertThat(postForEntity.getHeaders().containsKey("x-context-type")).isTrue(); + assertThat(postForEntity.getHeaders().get("x-context-type").get(0)) + .isEqualTo("rubbish"); } @EnableAutoConfiguration diff --git a/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/web/mvc/HttpGetIntegrationTests.java b/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/web/mvc/HttpGetIntegrationTests.java index 8fddbc3b4..9365bdfea 100644 --- a/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/web/mvc/HttpGetIntegrationTests.java +++ b/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/web/mvc/HttpGetIntegrationTests.java @@ -13,6 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ + package org.springframework.cloud.function.web.mvc; import java.net.URI; diff --git a/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/web/mvc/HttpPostIntegrationTests.java b/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/web/mvc/HttpPostIntegrationTests.java index 1b4af66bb..396029c4e 100644 --- a/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/web/mvc/HttpPostIntegrationTests.java +++ b/spring-cloud-function-web/src/test/java/org/springframework/cloud/function/web/mvc/HttpPostIntegrationTests.java @@ -13,6 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ + package org.springframework.cloud.function.web.mvc; import java.net.URI; diff --git a/spring-cloud-starter-function-web/src/main/resources/META-INF/spring.provides b/spring-cloud-starter-function-web/src/main/resources/META-INF/spring.provides index d7c921aae..ac09c44ea 100644 --- a/spring-cloud-starter-function-web/src/main/resources/META-INF/spring.provides +++ b/spring-cloud-starter-function-web/src/main/resources/META-INF/spring.provides @@ -1 +1 @@ -provides: spring-cloud-function-context \ No newline at end of file +provides: spring-cloud-function-context diff --git a/spring-cloud-starter-function-webflux/src/main/resources/META-INF/spring.provides b/spring-cloud-starter-function-webflux/src/main/resources/META-INF/spring.provides index d7c921aae..ac09c44ea 100644 --- a/spring-cloud-starter-function-webflux/src/main/resources/META-INF/spring.provides +++ b/spring-cloud-starter-function-webflux/src/main/resources/META-INF/spring.provides @@ -1 +1 @@ -provides: spring-cloud-function-context \ No newline at end of file +provides: spring-cloud-function-context