nima

Author: SentryMan

http-generator-nima/src/main/java/io/avaje/http/generator/helidon/nima/ControllerMethodWriter.java

@@ -1,6 +1,7 @@
 package io.avaje.http.generator.helidon.nima;
 
 import static io.avaje.http.generator.core.ProcessingContext.platform;
+
 import java.util.List;
 import java.util.Optional;
 
@@ -53,18 +54,25 @@ void writeHandler(boolean requestScoped) {
       } else {
         // use default helidon content negotiation
         method.params().stream()
-          .filter(MethodParam::isBody)
-          .forEach(
-            param -> {
-              final var type = param.utype();
-              writer.append("    var %s = req.content().as(", method.bodyName());
-              if (type.param0() != null) {
-                writer.append("new io.helidon.common.GenericType<%s>() {}", type.full());
-              } else {
-                writer.append("%s.class", type.full());
-              }
-              writer.append(");").eol();
-            });
+            .filter(MethodParam::isBody)
+            .forEach(
+                param -> {
+                  final var type = param.utype();
+
+                  writer.append("    var %s = req.content()", method.bodyName());
+
+                  if (type.full().startsWith("java.io.InputStream")) {
+                    writer.append(".inputStream();").eol();
+                    return;
+                  }
+                  writer.append(".as(");
+                  if (type.param0() != null) {
+                    writer.append("new io.helidon.common.GenericType<%s>() {}", type.full());
+                  } else {
+                    writer.append("%s.class", type.full());
+                  }
+                  writer.append(");").eol();
+                });
       }
     } else if (usesFormParams()) {
       writer.append("    var formParams = req.content().as(Parameters.class);").eol();
@@ -111,7 +119,7 @@ void writeHandler(boolean requestScoped) {
     if (!method.isVoid()) {
       writeContextReturn();
       if (producesJson()) {
-        final UType uType = UType.parse(method.returnType());
+        final var uType = UType.parse(method.returnType());
         writer.append("    %sJsonType.toJson(result, res.outputStream());", uType.shortName()).eol();
       } else {
         writer.append("    res.send(result);").eol();

tests/test-javalin-jsonb/src/main/java/org/example/myapp/web/test/TestController2.java

@@ -50,7 +50,12 @@ String mapTest(Map<String, List<String>> strings) {
   }
 
   @Get("/inputStream")
-  String mapTest(InputStream stream) {
+  String stream(InputStream stream) {
     return stream.toString();
   }
+
+  @Get("/byteArray")
+  String bytes(byte[] array) {
+    return array.toString();
+  }
 }

tests/test-nima-jsonb/src/main/java/org/example/TestController.java

@@ -1,5 +1,6 @@
 package org.example;
 
+import java.io.InputStream;
 import java.util.Set;
 
 import io.avaje.http.api.Controller;
@@ -45,4 +46,9 @@ String enumMultiQuery(@QueryParam @Default({"FFA", "PROXY"}) Set<ServerType> typ
   String enumQueryImplied(String s, @QueryParam ServerType type) {
     return type.name();
   }
+
+  @Get("/inputStream")
+  String stream(InputStream stream) {
+    return stream.toString();
+  }
 }