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

GH-1235 Fix support for text/* contentType

Browse Source 
Resolves #1235
This commit is contained in:
Oleg Zhurakousky
2025-02-06 10:32:54 +01:00
parent 86359baad5
commit 7bcad7edc8
2 changed files with 24 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
spring-cloud-function-adapters/spring-cloud-function-adapter-gcp/src/main/java/org/springframework/cloud/function/adapter/gcp/FunctionInvoker.java
View File

@@ -117,7 +117,7 @@ public class FunctionInvoker implements HttpFunction, RawBackgroundFunction {
Message<BufferedReader> message = this.functionWrapped.getInputType() == Void.class || this.functionWrapped.getInputType() == null ? null
: MessageBuilder.withPayload(httpRequest.getReader()).copyHeaders(httpRequest.getHeaders()).build();
Message<byte[]> result = function.apply(message);
Message<?> result = function.apply(message);
if (result != null) {
MessageHeaders headers = result.getHeaders();
@@ -130,7 +130,8 @@ public class FunctionInvoker implements HttpFunction, RawBackgroundFunction {
else {
httpRequest.getContentType().ifPresent(contentType -> httpResponse.setContentType(contentType));
}
httpResponse.getWriter().write(new String(result.getPayload(), StandardCharsets.UTF_8));
String content = result.getPayload() instanceof String strPayload ? strPayload : new String((byte[]) result.getPayload(), StandardCharsets.UTF_8);
httpResponse.getWriter().write(content);
for (Entry<String, Object> header : headers.entrySet()) {
Object values = header.getValue();
if (values instanceof Collection<?>) {