Add HTTP POJA implementation based on Apache to the 4.10.x branch

.github/workflows/release.yml

@@ -160,6 +160,6 @@ jobs:
       - name: Upload assets
         # Upload the artifacts to the existing release. Note that the SLSA provenance will
         # attest to each artifact file and not the aggregated ZIP file.
-        uses: softprops/action-gh-release@de2c0eb89ae2a093876385947365aca7b0e5f844 # v0.1.15
+        uses: softprops/action-gh-release@c062e08bd532815e2082a85e87e3ef29c3e6d191 # v2.0.8
         with:
           files: artifacts.zip

config/checkstyle/suppressions.xml

@@ -9,4 +9,6 @@
               <!-- files="DefaultBeanContext.java|BeanDefinitionWriter.java|DefaultHttpClient.java"/> -->
 
     <suppress checks="MissingJavadocType" files=".*doc-examples.*" />
+
+    <suppress checks=".*" files=".*/http-poja-common/src/main/java/io/micronaut/http/poja/util/QueryStringDecoder.java" />
 </suppressions>

gradle/libs.versions.toml

@@ -12,6 +12,7 @@ undertow = '2.3.15.Final'
 tomcat = '10.1.26'
 bcpkix = "1.70"
 
+managed-apache-http-core5 = "5.2.5"
 managed-jetty = '11.0.22'
 
 micronaut-reactor = "3.5.0"
@@ -46,6 +47,7 @@ junit-platform-engine = { module = "org.junit.platform:junit-platform-suite-engi
 kotlin-stdlib-jdk8 = { module = 'org.jetbrains.kotlin:kotlin-stdlib-jdk8' }
 kotlin-reflect = { module = 'org.jetbrains.kotlin:kotlin-reflect' }
 
+apache-http-core5 = { module = 'org.apache.httpcomponents.core5:httpcore5', version.ref = 'managed-apache-http-core5' }
 tomcat-embed-core = { module = 'org.apache.tomcat.embed:tomcat-embed-core', version.ref = 'tomcat' }
 undertow-servlet = { module = 'io.undertow:undertow-servlet', version.ref = 'undertow' }
 jetty-servlet = { module = 'org.eclipse.jetty:jetty-servlet', version.ref = 'managed-jetty' }

http-poja-apache/build.gradle

@@ -0,0 +1,40 @@
+/*
+ * Copyright © 2024 Oracle and/or its affiliates.
+ *
+ * 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
+ *
+ * https://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.
+ */
+plugins {
+    id("io.micronaut.build.internal.servlet.module")
+    id("idea")
+}
+
+dependencies {
+    api(projects.micronautHttpPojaCommon)
+    implementation(libs.apache.http.core5)
+
+    compileOnly(mn.reactor)
+    compileOnly(mn.micronaut.json.core)
+
+
+    testImplementation(mnSerde.micronaut.serde.jackson)
+}
+
+micronautBuild {
+    binaryCompatibility {
+        enabled.set(false)
+    }
+}
+
+javadoc {
+    failOnError(false)
+}

http-poja-apache/src/main/java/io/micronaut/http/poja/llhttp/ApacheServerlessApplication.java

@@ -0,0 +1,110 @@
+/*
+ * Copyright 2017-2024 original 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
+ *
+ * https://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 io.micronaut.http.poja.llhttp;
+
+import io.micronaut.context.ApplicationContext;
+import io.micronaut.core.convert.ConversionService;
+import io.micronaut.http.HttpStatus;
+import io.micronaut.http.MediaType;
+import io.micronaut.http.codec.MediaTypeCodecRegistry;
+import io.micronaut.http.poja.PojaHttpServerlessApplication;
+import io.micronaut.http.poja.llhttp.exception.ApacheServletBadRequestException;
+import io.micronaut.http.server.exceptions.HttpServerException;
+import io.micronaut.inject.qualifiers.Qualifiers;
+import io.micronaut.runtime.ApplicationConfiguration;
+import io.micronaut.scheduling.TaskExecutors;
+import io.micronaut.servlet.http.ServletHttpHandler;
+import jakarta.inject.Singleton;
+import org.apache.hc.core5.http.ClassicHttpResponse;
+import org.apache.hc.core5.http.HttpEntity;
+import org.apache.hc.core5.http.HttpException;
+import org.apache.hc.core5.http.impl.io.DefaultHttpResponseWriter;
+import org.apache.hc.core5.http.impl.io.SessionOutputBufferImpl;
+import org.apache.hc.core5.http.io.SessionOutputBuffer;
+
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.OutputStream;
+import java.util.concurrent.ExecutorService;
+
+/**
+ * Implementation of {@link PojaHttpServerlessApplication} for Apache.
+ *
+ * @author Andriy Dmytruk.
+ * @since 4.10.0
+ */
+@Singleton
+public class ApacheServerlessApplication
+    extends PojaHttpServerlessApplication<ApacheServletHttpRequest<?>, ApacheServletHttpResponse<?>> {
+
+    private final ConversionService conversionService;
+    private final MediaTypeCodecRegistry codecRegistry;
+    private final ExecutorService ioExecutor;
+    private final ApacheServletConfiguration configuration;
+
+    /**
+     * Default constructor.
+     *
+     * @param applicationContext       The application context
+     * @param applicationConfiguration The application configuration
+     */
+    public ApacheServerlessApplication(ApplicationContext applicationContext,
+                                       ApplicationConfiguration applicationConfiguration) {
+        super(applicationContext, applicationConfiguration);
+        conversionService = applicationContext.getConversionService();
+        codecRegistry = applicationContext.getBean(MediaTypeCodecRegistry.class);
+        ioExecutor = applicationContext.getBean(ExecutorService.class, Qualifiers.byName(TaskExecutors.BLOCKING));
+        configuration = applicationContext.getBean(ApacheServletConfiguration.class);
+    }
+
+    @Override
+    protected void handleSingleRequest(
+            ServletHttpHandler<ApacheServletHttpRequest<?>, ApacheServletHttpResponse<?>> servletHttpHandler,
+            InputStream in,
+            OutputStream out
+    ) throws IOException {
+        ApacheServletHttpResponse<?> response = new ApacheServletHttpResponse<>(conversionService);
+        try {
+            ApacheServletHttpRequest exchange = new ApacheServletHttpRequest<>(
+                in, conversionService, codecRegistry, ioExecutor, response, configuration
+            );
+            servletHttpHandler.service(exchange);
+        } catch (ApacheServletBadRequestException e) {
+            response.status(HttpStatus.BAD_REQUEST);
+            response.contentType(MediaType.TEXT_PLAIN_TYPE);
+            response.getOutputStream().write(e.getMessage().getBytes());
+        }
+        writeResponse(response.getNativeResponse(), out);
+    }
+
+    private void writeResponse(ClassicHttpResponse response, OutputStream out) throws IOException {
+        SessionOutputBuffer buffer = new SessionOutputBufferImpl(configuration.outputBufferSize());
+        DefaultHttpResponseWriter responseWriter = new DefaultHttpResponseWriter();
+        try {
+            responseWriter.write(response, buffer, out);
+        } catch (HttpException e) {
+            throw new HttpServerException("Could not write response body", e);
+        }
+        buffer.flush(out);
+
+        HttpEntity entity = response.getEntity();
+        if (entity != null) {
+            entity.writeTo(out);
+        }
+        out.flush();
+    }
+
+}

http-poja-apache/src/main/java/io/micronaut/http/poja/llhttp/ApacheServletConfiguration.java

@@ -0,0 +1,39 @@
+/*
+ * Copyright 2017-2024 original 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
+ *
+ * https://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 io.micronaut.http.poja.llhttp;
+
+import io.micronaut.context.annotation.ConfigurationProperties;
+import io.micronaut.core.bind.annotation.Bindable;
+
+/**
+ * Configuration specific to the Apache POJA serverless application.
+ *
+ * @param inputBufferSize The size of the buffer that is used to read and parse the HTTP request
+ *                        (in bytes). Default value is 8192 (8Kb).
+ * @param outputBufferSize The size of the buffer that is used to write the HTTP response
+ *                        (in bytes). Default value is 8192 (8Kb).
+ * @author Andriy Dmytruk
+ * @since 4.10.0
+ */
+@ConfigurationProperties("poja.apache")
+public record ApacheServletConfiguration(
+    @Bindable(defaultValue = "8192")
+    int inputBufferSize,
+    @Bindable(defaultValue = "8192")
+    int outputBufferSize
+) {
+
+}