Add support for AWS CRT Client

Author: driverpt

aws-sdk-v2/build.gradle.kts

@@ -12,6 +12,7 @@ dependencies {
     compileOnly(libs.awssdk.url.connection.client)
     compileOnly(libs.awssdk.netty.nio.client)
     compileOnly(libs.awssdk.apache.client)
+    compileOnly(libs.awssdk.aws.crt.client)
 
     // Services
     compileOnly(libs.awssdk.apigatewaymanagementapi)

aws-sdk-v2/src/main/java/io/micronaut/aws/sdk/v2/client/crt/AwsCrtClientConfiguration.java

@@ -0,0 +1,61 @@
+/*
+ * Copyright 2017-2020 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.aws.sdk.v2.client.crt;
+
+import io.micronaut.aws.AWSConfiguration;
+import io.micronaut.context.annotation.BootstrapContextCompatible;
+import io.micronaut.context.annotation.ConfigurationBuilder;
+import io.micronaut.context.annotation.ConfigurationProperties;
+import software.amazon.awssdk.http.crt.AwsCrtAsyncHttpClient;
+import software.amazon.awssdk.http.crt.ProxyConfiguration;
+
+/**
+ * Configuration properties for the Netty async client.
+ *
+ * @author Luis Duarte
+ * @since 4.12.x
+ */
+@ConfigurationProperties(AwsCrtClientConfiguration.PREFIX)
+@BootstrapContextCompatible
+public class AwsCrtClientConfiguration extends AWSConfiguration {
+
+    public static final String PREFIX = "aws-crt-client";
+
+    @ConfigurationBuilder(prefixes = {""}, excludes = {"proxyConfiguration", "buildWithDefaults", "applyMutation"})
+    private AwsCrtAsyncHttpClient.Builder builder = AwsCrtAsyncHttpClient.builder();
+
+    @ConfigurationBuilder(configurationPrefix = "proxy", prefixes = {""}, excludes = {"applyMutation", "copy"})
+    private ProxyConfiguration.Builder proxy = ProxyConfiguration.builder();
+
+    /**
+     * @return The builder for {@link AwsCrtAsyncHttpClient}
+     */
+    public AwsCrtAsyncHttpClient.Builder getBuilder() {
+        return builder.proxyConfiguration(proxy.build());
+    }
+
+    /**
+     * @return The builder for {@link ProxyConfiguration}
+     */
+    public ProxyConfiguration.Builder getProxy() {
+        return proxy;
+    }
+
+    boolean isProxyConfigured() {
+        ProxyConfiguration proxyConfig = proxy.build();
+        return proxyConfig.host() != null;
+    }
+}

aws-sdk-v2/src/main/java/io/micronaut/aws/sdk/v2/client/crt/AwsCrtClientFactory.java

@@ -0,0 +1,56 @@
+/*
+ * Copyright 2017-2025 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.aws.sdk.v2.client.crt;
+
+import io.micronaut.context.annotation.Bean;
+import io.micronaut.context.annotation.BootstrapContextCompatible;
+import io.micronaut.context.annotation.Factory;
+import io.micronaut.context.annotation.Requires;
+import jakarta.inject.Singleton;
+import software.amazon.awssdk.http.async.SdkAsyncHttpClient;
+
+@Factory
+@BootstrapContextCompatible
+public class AwsCrtClientFactory {
+    public static final String ASYNC_SERVICE_IMPL = "software.amazon.awssdk.http.async.service.impl";
+    public static final String AWS_CRT_SDK_ASYNC_HTTP_SERVICE = "software.amazon.awssdk.http.crt.AwsCrtSdkHttpService";
+
+    /**
+     * @param configuration The AWS CRT client configuration
+     * @return an instance of {@link SdkAsyncHttpClient}
+     */
+    @Bean(preDestroy = "close")
+    @Singleton
+    public SdkAsyncHttpClient awsCrtClient(AwsCrtClientConfiguration configuration) {
+        return doCreateClient(configuration);
+    }
+
+    /**
+     * @param configuration The AWS CRT client configuration
+     * @return an instance of {@link SdkAsyncHttpClient}
+     */
+    @Bean(preDestroy = "close")
+    @Singleton
+    @Requires(property = ASYNC_SERVICE_IMPL, value = AWS_CRT_SDK_ASYNC_HTTP_SERVICE)
+    public SdkAsyncHttpClient systemPropertyClient(AwsCrtClientConfiguration configuration) {
+        return doCreateClient(configuration);
+    }
+
+    private SdkAsyncHttpClient doCreateClient(AwsCrtClientConfiguration configuration) {
+        return configuration.getBuilder().build();
+    }
+
+}

aws-sdk-v2/src/main/java/io/micronaut/aws/sdk/v2/client/crt/package-info.java

@@ -0,0 +1,28 @@
+/*
+ * Copyright 2017-2020 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.
+ */
+/**
+ * AWS CRT client configuration and factory.
+ *
+ * @author Luis Duarte
+ * @since 4.12.x
+ */
+@Requires(classes = AwsCrtAsyncHttpClient.class)
+@Configuration
+package io.micronaut.aws.sdk.v2.client.crt;
+
+import io.micronaut.context.annotation.Configuration;
+import io.micronaut.context.annotation.Requires;
+import software.amazon.awssdk.http.crt.AwsCrtAsyncHttpClient;

aws-sdk-v2/src/test/groovy/io/micronaut/aws/sdk/v2/client/crt/AwsCrtClientConfigurationSpec.groovy

@@ -0,0 +1,19 @@
+package io.micronaut.aws.sdk.v2.client.crt
+
+import io.micronaut.context.ApplicationContext
+import io.micronaut.context.annotation.BootstrapContextCompatible
+import spock.lang.Specification
+
+class AwsCrtClientConfigurationSpec extends Specification {
+
+    void 'AwsCrtClientConfiguration is annotated with BootstrapContextCompatible'() {
+        given:
+        ApplicationContext context = ApplicationContext.run()
+
+        expect:
+        context.getBeanDefinition(AwsCrtClientConfiguration).getAnnotationNameByStereotype(BootstrapContextCompatible).isPresent()
+
+        cleanup:
+        context.close()
+    }
+}

aws-sdk-v2/src/test/groovy/io/micronaut/aws/sdk/v2/client/crt/AwsCrtClientFactorySpec.groovy

@@ -0,0 +1,19 @@
+package io.micronaut.aws.sdk.v2.client.crt
+
+import io.micronaut.context.ApplicationContext
+import io.micronaut.context.annotation.BootstrapContextCompatible
+import spock.lang.Specification
+
+class AwsCrtClientFactorySpec extends Specification {
+
+    void 'AwsCrtClientFactory is annotated with BootstrapContextCompatible'() {
+        given:
+        ApplicationContext context = ApplicationContext.run()
+
+        expect:
+        context.getBeanDefinition(AwsCrtClientFactory).getAnnotationNameByStereotype(BootstrapContextCompatible).isPresent()
+
+        cleanup:
+        context.close()
+    }
+}

gradle/libs.versions.toml

@@ -79,6 +79,7 @@ awssdk-sqs = { module = 'software.amazon.awssdk:sqs' }
 awssdk-ssm = { module = 'software.amazon.awssdk:ssm' }
 awssdk-iam = { module = 'software.amazon.awssdk:iam' }
 awssdk-url-connection-client = { module = 'software.amazon.awssdk:url-connection-client' }
+awssdk-aws-crt-client = { module = 'software.amazon.awssdk:aws-crt-client' }
 
 kotlin-stdlib-jdk8 = { module = 'org.jetbrains.kotlin:kotlin-stdlib-jdk8', version.ref = 'kotlin' }