Apply various fixes to Kotlin Serialization modules

extensions/resteasy-reactive/quarkus-resteasy-reactive-kotlin-serialization-common/deployment/pom.xml

@@ -18,6 +18,10 @@
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-resteasy-reactive-kotlin-serialization-common</artifactId>
         </dependency>
+        <dependency>
+            <groupId>io.quarkus</groupId>
+            <artifactId>quarkus-arc-deployment</artifactId>
+        </dependency>
         <dependency>
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-kotlin-deployment</artifactId>
@@ -40,4 +44,4 @@
         </plugins>
     </build>
 
-</project>
+</project>

extensions/resteasy-reactive/quarkus-resteasy-reactive-kotlin-serialization-common/deployment/src/main/java/io/quarkus/kotlin/serialization/KotlinSerializationCommonProcessor.java

@@ -0,0 +1,23 @@
+package io.quarkus.kotlin.serialization;
+
+import static io.quarkus.deployment.annotations.ExecutionTime.STATIC_INIT;
+
+import javax.inject.Singleton;
+
+import io.quarkus.arc.deployment.SyntheticBeanBuildItem;
+import io.quarkus.deployment.annotations.BuildStep;
+import io.quarkus.deployment.annotations.Record;
+import kotlinx.serialization.json.Json;
+
+public class KotlinSerializationCommonProcessor {
+
+    @BuildStep
+    @Record(STATIC_INIT)
+    public SyntheticBeanBuildItem createJson(KotlinSerializerRecorder recorder, KotlinSerializationConfig config) {
+        return SyntheticBeanBuildItem
+                .configure(Json.class)
+                .scope(Singleton.class)
+                .supplier(recorder.configFactory(config))
+                .unremovable().done();
+    }
+}

extensions/resteasy-reactive/quarkus-resteasy-reactive-kotlin-serialization-common/runtime/pom.xml

@@ -97,6 +97,10 @@
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-kotlin</artifactId>
         </dependency>
+        <dependency>
+            <groupId>io.quarkus</groupId>
+            <artifactId>quarkus-arc</artifactId>
+        </dependency>
         <dependency>
             <groupId>org.jetbrains.kotlinx</groupId>
             <artifactId>kotlinx-serialization-json</artifactId>
@@ -108,4 +112,4 @@
         </dependency>
     </dependencies>
 
-</project>
+</project>

extensions/resteasy-reactive/quarkus-resteasy-reactive-kotlin-serialization/deployment/src/main/java/io/quarkus/kotlin/serialization/deployment/KotlinSerializationProcessor.java

@@ -1,28 +1,23 @@
 package io.quarkus.kotlin.serialization.deployment;
 
 import static io.quarkus.deployment.Feature.RESTEASY_REACTIVE_KOTLIN_SERIALIZATION;
-import static io.quarkus.deployment.annotations.ExecutionTime.STATIC_INIT;
 import static io.quarkus.resteasy.reactive.common.deployment.ServerDefaultProducesHandlerBuildItem.json;
 
 import java.util.List;
 
-import javax.inject.Singleton;
+import javax.ws.rs.Priorities;
+import javax.ws.rs.RuntimeType;
 import javax.ws.rs.core.MediaType;
 
 import io.quarkus.arc.deployment.AdditionalBeanBuildItem;
-import io.quarkus.arc.deployment.SyntheticBeanBuildItem;
 import io.quarkus.deployment.annotations.BuildProducer;
 import io.quarkus.deployment.annotations.BuildStep;
-import io.quarkus.deployment.annotations.Record;
 import io.quarkus.deployment.builditem.FeatureBuildItem;
-import io.quarkus.kotlin.serialization.KotlinSerializationConfig;
 import io.quarkus.kotlin.serialization.KotlinSerializationMessageBodyReader;
 import io.quarkus.kotlin.serialization.KotlinSerializationMessageBodyWriter;
-import io.quarkus.kotlin.serialization.KotlinSerializerRecorder;
 import io.quarkus.resteasy.reactive.common.deployment.ServerDefaultProducesHandlerBuildItem;
 import io.quarkus.resteasy.reactive.spi.MessageBodyReaderBuildItem;
 import io.quarkus.resteasy.reactive.spi.MessageBodyWriterBuildItem;
-import kotlinx.serialization.json.Json;
 
 public class KotlinSerializationProcessor {
     @BuildStep
@@ -36,20 +31,12 @@ public void additionalProviders(
                 .setUnremovable().build());
         additionalReaders.produce(new MessageBodyReaderBuildItem(
                 KotlinSerializationMessageBodyReader.class.getName(), Object.class.getName(), List.of(
-                        MediaType.APPLICATION_JSON)));
+                        MediaType.APPLICATION_JSON),
+                RuntimeType.SERVER, true, Priorities.USER));
         additionalWriters.produce(new MessageBodyWriterBuildItem(
                 KotlinSerializationMessageBodyWriter.class.getName(), Object.class.getName(), List.of(
-                        MediaType.APPLICATION_JSON)));
-    }
-
-    @BuildStep
-    @Record(STATIC_INIT)
-    public SyntheticBeanBuildItem createJson(KotlinSerializerRecorder recorder, KotlinSerializationConfig config) {
-        return SyntheticBeanBuildItem
-                .configure(Json.class)
-                .scope(Singleton.class)
-                .supplier(recorder.configFactory(config))
-                .unremovable().done();
+                        MediaType.APPLICATION_JSON),
+                RuntimeType.SERVER, true, Priorities.USER));
     }
 
     @BuildStep

extensions/resteasy-reactive/quarkus-resteasy-reactive-kotlin-serialization/runtime/src/main/kotlin/io/quarkus/kotlin/serialization/KotlinSerializationMessageBodyReader.kt

@@ -15,8 +15,8 @@ import javax.inject.Inject
 import javax.ws.rs.core.MediaType
 import javax.ws.rs.core.MultivaluedMap
 
-class KotlinSerializationMessageBodyReader(@Inject var json: Json) : AbstractJsonMessageBodyReader(), ServerMessageBodyReader<Any> {
-    override fun isReadable(type: Class<*>, genericType: Type, annotations: Array<Annotation>, mediaType: MediaType) =
+class KotlinSerializationMessageBodyReader(private val json: Json) : AbstractJsonMessageBodyReader(), ServerMessageBodyReader<Any> {
+    override fun isReadable(type: Class<*>, genericType: Type, annotations: Array<Annotation>?, mediaType: MediaType) =
         isReadable(mediaType, type)
 
     override fun isReadable(type: Class<*>, genericType: Type, lazyMethod: ResteasyReactiveResourceInfo, mediaType: MediaType) =
@@ -42,4 +42,4 @@ class KotlinSerializationMessageBodyReader(@Inject var json: Json) : AbstractJso
         return if (StreamUtil.isEmpty(entityStream)) null else
             json.decodeFromStream(serializer(type), entityStream)
     }
-}
+}

extensions/resteasy-reactive/quarkus-resteasy-reactive-kotlin-serialization/runtime/src/main/kotlin/io/quarkus/kotlin/serialization/KotlinSerializationMessageBodyWriter.kt

@@ -18,7 +18,7 @@ import javax.ws.rs.core.MultivaluedMap
 
 @Produces("application/json", "application/*+json", "text/json")
 @OptIn(ExperimentalSerializationApi::class)
-class KotlinSerializationMessageBodyWriter(@Inject var json: Json) : AllWriteableMessageBodyWriter() {
+class KotlinSerializationMessageBodyWriter(private val json: Json) : AllWriteableMessageBodyWriter() {
     override fun writeTo(
         o: Any, type: Class<*>, genericType: Type, annotations: Array<Annotation>, mediaType: MediaType,
         httpHeaders: MultivaluedMap<String, Any>, entityStream: OutputStream

extensions/resteasy-reactive/rest-client-reactive-kotlin-serialization/deployment/pom.xml

@@ -15,10 +15,6 @@
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-rest-client-reactive-kotlin-serialization</artifactId>
         </dependency>
-        <dependency>
-            <groupId>io.quarkus</groupId>
-            <artifactId>quarkus-resteasy-reactive-deployment</artifactId>
-        </dependency>
         <dependency>
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-kotlin-deployment</artifactId>
@@ -35,6 +31,10 @@
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-rest-client-reactive-deployment</artifactId>
         </dependency>
+        <dependency>
+            <groupId>io.quarkus</groupId>
+            <artifactId>quarkus-resteasy-reactive-kotlin-serialization-common-deployment</artifactId>
+        </dependency>
 
         <!-- test dependencies: -->
         <dependency>

extensions/resteasy-reactive/rest-client-reactive-kotlin-serialization/deployment/src/main/java/io/quarkus/rest/client/reactive/kotlin/deployment/RestClientReactiveKotlinSerializationProcessor.java

@@ -1,26 +1,21 @@
 package io.quarkus.rest.client.reactive.kotlin.deployment;
 
 import static io.quarkus.deployment.Feature.REST_CLIENT_REACTIVE_KOTLIN_SERIALIZATION;
-import static io.quarkus.deployment.annotations.ExecutionTime.STATIC_INIT;
 
 import java.util.Collections;
 
-import javax.inject.Singleton;
+import javax.ws.rs.Priorities;
+import javax.ws.rs.RuntimeType;
 import javax.ws.rs.core.MediaType;
 
 import io.quarkus.arc.deployment.AdditionalBeanBuildItem;
-import io.quarkus.arc.deployment.SyntheticBeanBuildItem;
 import io.quarkus.deployment.annotations.BuildProducer;
 import io.quarkus.deployment.annotations.BuildStep;
-import io.quarkus.deployment.annotations.Record;
 import io.quarkus.deployment.builditem.FeatureBuildItem;
-import io.quarkus.kotlin.serialization.KotlinSerializationConfig;
-import io.quarkus.kotlin.serialization.KotlinSerializerRecorder;
 import io.quarkus.rest.client.reactive.kotlin.runtime.serializers.ClientKotlinMessageBodyReader;
 import io.quarkus.rest.client.reactive.kotlin.runtime.serializers.ClientKotlinMessageBodyWriter;
 import io.quarkus.resteasy.reactive.spi.MessageBodyReaderBuildItem;
 import io.quarkus.resteasy.reactive.spi.MessageBodyWriterBuildItem;
-import kotlinx.serialization.json.Json;
 
 public class RestClientReactiveKotlinSerializationProcessor {
 
@@ -41,19 +36,9 @@ void additionalProviders(
 
         additionalReaders
                 .produce(new MessageBodyReaderBuildItem(ClientKotlinMessageBodyReader.class.getName(), Object.class.getName(),
-                        Collections.singletonList(MediaType.APPLICATION_JSON)));
+                        Collections.singletonList(MediaType.APPLICATION_JSON), RuntimeType.CLIENT, true, Priorities.USER));
         additionalWriters
                 .produce(new MessageBodyWriterBuildItem(ClientKotlinMessageBodyWriter.class.getName(), Object.class.getName(),
-                        Collections.singletonList(MediaType.APPLICATION_JSON)));
-    }
-
-    @BuildStep
-    @Record(STATIC_INIT)
-    public SyntheticBeanBuildItem createJson(KotlinSerializerRecorder recorder, KotlinSerializationConfig config) {
-        return SyntheticBeanBuildItem
-                .configure(Json.class)
-                .scope(Singleton.class)
-                .supplier(recorder.configFactory(config))
-                .unremovable().done();
+                        Collections.singletonList(MediaType.APPLICATION_JSON), RuntimeType.CLIENT, true, Priorities.USER));
     }
 }

extensions/resteasy-reactive/rest-client-reactive-kotlin-serialization/runtime/pom.xml

@@ -22,10 +22,6 @@
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-resteasy-reactive-kotlin-serialization-common</artifactId>
         </dependency>
-        <dependency>
-            <groupId>io.quarkus</groupId>
-            <artifactId>quarkus-resteasy-reactive</artifactId>
-        </dependency>
     </dependencies>
 
     <build>
@@ -100,4 +96,4 @@
             </plugin>
         </plugins>
     </build>
-</project>
+</project>

extensions/resteasy-reactive/rest-client-reactive-kotlin-serialization/runtime/src/main/kotlin/io/quarkus/rest/client/reactive/kotlin/runtime/serializers/ClientKotlinMessageBodyReader.kt

@@ -13,7 +13,7 @@ import javax.ws.rs.core.MultivaluedMap
 import javax.ws.rs.ext.MessageBodyReader
 
 @OptIn(ExperimentalSerializationApi::class)
-class ClientKotlinMessageBodyReader(@Inject val json: Json) : MessageBodyReader<Any> {
+class ClientKotlinMessageBodyReader(private val json: Json) : MessageBodyReader<Any> {
     override fun isReadable(type: Class<*>?, generic: Type?, annotations: Array<out Annotation>?, mediaType: MediaType?) = true
 
     override fun readFrom(
@@ -23,4 +23,4 @@ class ClientKotlinMessageBodyReader(@Inject val json: Json) : MessageBodyReader<
         return if (StreamUtil.isEmpty(entityStream)) null else
             json.decodeFromStream(serializer(generic), entityStream)
     }
-}
+}

extensions/resteasy-reactive/rest-client-reactive-kotlin-serialization/runtime/src/main/kotlin/io/quarkus/rest/client/reactive/kotlin/runtime/serializers/ClientKotlinMessageBodyWriter.kt

@@ -12,7 +12,7 @@ import javax.ws.rs.core.MultivaluedMap
 import javax.ws.rs.ext.MessageBodyWriter
 
 @OptIn(ExperimentalSerializationApi::class)
-class ClientKotlinMessageBodyWriter(@Inject val json: Json) : MessageBodyWriter<Any> {
+class ClientKotlinMessageBodyWriter(private val json: Json) : MessageBodyWriter<Any> {
     override fun isWriteable(type: Class<*>, genericType: Type, annotations: Array<out Annotation>?, mediaType: MediaType?) = true
 
     override fun writeTo(
@@ -21,4 +21,4 @@ class ClientKotlinMessageBodyWriter(@Inject val json: Json) : MessageBodyWriter<
     ) {
         json.encodeToStream(serializer(genericType), t, entityStream)
     }
-}
+}

integration-tests/rest-client-reactive-kotlin-serialization/pom.xml

@@ -12,6 +12,10 @@
     <name>Quarkus - Integration Tests - REST Client Reactive Kotlin Serialization</name>
 
     <dependencies>
+        <dependency>
+            <groupId>io.quarkus</groupId>
+            <artifactId>quarkus-resteasy-reactive-kotlin-serialization</artifactId>
+        </dependency>
         <dependency>
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-rest-client-reactive-kotlin-serialization</artifactId>
@@ -40,6 +44,19 @@
         </dependency>
 
         <!-- Minimal test dependencies to *-deployment artifacts for consistent build order -->
+        <dependency>
+            <groupId>io.quarkus</groupId>
+            <artifactId>quarkus-resteasy-reactive-kotlin-serialization-deployment</artifactId>
+            <version>${project.version}</version>
+            <type>pom</type>
+            <scope>test</scope>
+            <exclusions>
+                <exclusion>
+                    <groupId>*</groupId>
+                    <artifactId>*</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
         <dependency>
             <groupId>io.quarkus</groupId>
             <artifactId>quarkus-rest-client-reactive-kotlin-serialization-deployment</artifactId>