SpringCloud/spring-cloud-function
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Add tests to illustrate the bug

Browse Source
This commit is contained in:
Chris Bono
2023-07-14 16:56:02 -05:00
committed by Oleg Zhurakousky
parent f3b9896010
commit c97c0b2a96
2 changed files with 39 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
spring-cloud-function-context/src/test/java/org/springframework/cloud/function/context/catalog/SimpleFunctionRegistryTests.java
View File

@@ -41,6 +41,8 @@ import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.params.ParameterizedTest;
import org.junit.jupiter.params.provider.ValueSource;
import org.reactivestreams.Publisher;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;
@@ -79,6 +81,7 @@ import static org.assertj.core.api.Assertions.assertThat;
/**
* @author Oleg Zhurakousky
* @author Soby Chacko
* @author Chris Bono
*/
public class SimpleFunctionRegistryTests {
@@ -190,6 +193,20 @@ public class SimpleFunctionRegistryTests {
assertThat(result).isEqualTo("{\"HELLO\":\"WORLD\"}");
}
// TODO: Once bug is fixed this test (last entry) will fully pass and this COMMENT should be removed
@ParameterizedTest
@ValueSource(strings = {"[hello", "hello]", "[hello]"})
void textContentTypeWithValueWrappedBracketsIsOk(String inputMessagePayloadValue) {
var catalog = new SimpleFunctionRegistry(this.conversionService, this.messageConverter, new JacksonMapper(new ObjectMapper()));
catalog.register(new FunctionRegistration<>(new Echo(), "echo").type(Echo.class));
FunctionInvocationWrapper lookedUpFunction = catalog.lookup("echo");
var inputMessage = MessageBuilder.withPayload(inputMessagePayloadValue)
.setHeader("contentType", "text/plain")
.build();
var functionResult = lookedUpFunction.apply(inputMessage);
assertThat(functionResult).isEqualTo(inputMessagePayloadValue);
}
@SuppressWarnings("unchecked")
@Test
public void testSCF762() {