Fix #9 to add config to register classes

deployment/src/main/java/io/quarkiverse/fury/deployment/FuryProcessor.java

@@ -1,6 +1,7 @@
 package io.quarkiverse.fury.deployment;
 
 import java.util.List;
+import java.util.Optional;
 
 import org.jboss.jandex.AnnotationTarget;
 import org.jboss.jandex.DotName;
@@ -46,11 +47,22 @@ void unremovableBeans(
 
     @BuildStep
     @Record(ExecutionTime.STATIC_INIT)
-    public void registerClasses(
+    public void registerClasses(FuryBuildTimeConfig configs,
             FuryBuildItem fury, List<FurySerializerBuildItem> classes, FuryRecorder recorder) {
         for (FurySerializerBuildItem item : classes) {
             recorder.registerClass(fury.getFury(), item.getClazz(), item.getClassId(), item.getSerializer());
         }
+
+        if (configs.registerClassNames().isPresent()) {
+            for (String name : configs.registerClassNames().get().split(",")) {
+                recorder.registerClassByName(fury.getFury(), name, -1, Optional.empty());
+            }
+        }
+
+        for (var config : configs.registerClasses().entrySet()) {
+            recorder.registerClassByName(fury.getFury(), config.getKey(), config.getValue().classId(),
+                    config.getValue().serializer());
+        }
     }
 
     @BuildStep

docs/modules/ROOT/pages/includes/quarkus-fury.adoc

@@ -41,5 +41,61 @@ endif::add-copy-button-to-env-var[]
 |boolean
 |`true`
 
+a|icon:lock[title=Fixed at build time] [[quarkus-fury_quarkus-fury-register-class-names]] [.property-path]##link:#quarkus-fury_quarkus-fury-register-class-names[`quarkus.fury.register-class-names`]##
+
+[.description]
+--
+Names of classes to register which no need to be with class-id or customize serializer.
+
+
+ifdef::add-copy-button-to-env-var[]
+Environment variable: env_var_with_copy_button:+++QUARKUS_FURY_REGISTER_CLASS_NAMES+++[]
+endif::add-copy-button-to-env-var[]
+ifndef::add-copy-button-to-env-var[]
+Environment variable: `+++QUARKUS_FURY_REGISTER_CLASS_NAMES+++`
+endif::add-copy-button-to-env-var[]
+--
+|string
+|
+
+h|[[quarkus-fury_section_quarkus-fury-register-classes]] [.section-name.section-level0]##link:#quarkus-fury_section_quarkus-fury-register-classes[Configurations of register classes]##
+h|Type
+h|Default
+
+a|icon:lock[title=Fixed at build time] [[quarkus-fury_quarkus-fury-register-classes-register-class-name-class-id]] [.property-path]##link:#quarkus-fury_quarkus-fury-register-classes-register-class-name-class-id[`quarkus.fury.register-classes."register-class-name".class-id`]##
+
+[.description]
+--
+Class id must be greater or equal to 256, and it must be different between classes. The default is -1.
+
+
+ifdef::add-copy-button-to-env-var[]
+Environment variable: env_var_with_copy_button:+++QUARKUS_FURY_REGISTER_CLASSES__REGISTER_CLASS_NAME__CLASS_ID+++[]
+endif::add-copy-button-to-env-var[]
+ifndef::add-copy-button-to-env-var[]
+Environment variable: `+++QUARKUS_FURY_REGISTER_CLASSES__REGISTER_CLASS_NAME__CLASS_ID+++`
+endif::add-copy-button-to-env-var[]
+--
+|int
+|`-1`
+
+a|icon:lock[title=Fixed at build time] [[quarkus-fury_quarkus-fury-register-classes-register-class-name-serializer]] [.property-path]##link:#quarkus-fury_quarkus-fury-register-classes-register-class-name-serializer[`quarkus.fury.register-classes."register-class-name".serializer`]##
+
+[.description]
+--
+Specify a customized serializer for current class. This should be empty to let Fury create serializer for current class. But if users want to customize serialization for this class, one can provide serializer here.
+
+
+ifdef::add-copy-button-to-env-var[]
+Environment variable: env_var_with_copy_button:+++QUARKUS_FURY_REGISTER_CLASSES__REGISTER_CLASS_NAME__SERIALIZER+++[]
+endif::add-copy-button-to-env-var[]
+ifndef::add-copy-button-to-env-var[]
+Environment variable: `+++QUARKUS_FURY_REGISTER_CLASSES__REGISTER_CLASS_NAME__SERIALIZER+++`
+endif::add-copy-button-to-env-var[]
+--
+|string
+|
+
+
 |===
 

docs/modules/ROOT/pages/includes/quarkus-fury_quarkus.fury.adoc

@@ -41,5 +41,61 @@ endif::add-copy-button-to-env-var[]
 |boolean
 |`true`
 
+a|icon:lock[title=Fixed at build time] [[quarkus-fury_quarkus-fury-register-class-names]] [.property-path]##link:#quarkus-fury_quarkus-fury-register-class-names[`quarkus.fury.register-class-names`]##
+
+[.description]
+--
+Names of classes to register which no need to be with class-id or customize serializer.
+
+
+ifdef::add-copy-button-to-env-var[]
+Environment variable: env_var_with_copy_button:+++QUARKUS_FURY_REGISTER_CLASS_NAMES+++[]
+endif::add-copy-button-to-env-var[]
+ifndef::add-copy-button-to-env-var[]
+Environment variable: `+++QUARKUS_FURY_REGISTER_CLASS_NAMES+++`
+endif::add-copy-button-to-env-var[]
+--
+|string
+|
+
+h|[[quarkus-fury_section_quarkus-fury-register-classes]] [.section-name.section-level0]##link:#quarkus-fury_section_quarkus-fury-register-classes[Configurations of register classes]##
+h|Type
+h|Default
+
+a|icon:lock[title=Fixed at build time] [[quarkus-fury_quarkus-fury-register-classes-register-class-name-class-id]] [.property-path]##link:#quarkus-fury_quarkus-fury-register-classes-register-class-name-class-id[`quarkus.fury.register-classes."register-class-name".class-id`]##
+
+[.description]
+--
+Class id must be greater or equal to 256, and it must be different between classes. The default is -1.
+
+
+ifdef::add-copy-button-to-env-var[]
+Environment variable: env_var_with_copy_button:+++QUARKUS_FURY_REGISTER_CLASSES__REGISTER_CLASS_NAME__CLASS_ID+++[]
+endif::add-copy-button-to-env-var[]
+ifndef::add-copy-button-to-env-var[]
+Environment variable: `+++QUARKUS_FURY_REGISTER_CLASSES__REGISTER_CLASS_NAME__CLASS_ID+++`
+endif::add-copy-button-to-env-var[]
+--
+|int
+|`-1`
+
+a|icon:lock[title=Fixed at build time] [[quarkus-fury_quarkus-fury-register-classes-register-class-name-serializer]] [.property-path]##link:#quarkus-fury_quarkus-fury-register-classes-register-class-name-serializer[`quarkus.fury.register-classes."register-class-name".serializer`]##
+
+[.description]
+--
+Specify a customized serializer for current class. This should be empty to let Fury create serializer for current class. But if users want to customize serialization for this class, one can provide serializer here.
+
+
+ifdef::add-copy-button-to-env-var[]
+Environment variable: env_var_with_copy_button:+++QUARKUS_FURY_REGISTER_CLASSES__REGISTER_CLASS_NAME__SERIALIZER+++[]
+endif::add-copy-button-to-env-var[]
+ifndef::add-copy-button-to-env-var[]
+Environment variable: `+++QUARKUS_FURY_REGISTER_CLASSES__REGISTER_CLASS_NAME__SERIALIZER+++`
+endif::add-copy-button-to-env-var[]
+--
+|string
+|
+
+
 |===
 

integration-tests/src/main/java/io/quarkiverse/fury/it/Foo.java

@@ -22,8 +22,5 @@
 import java.util.List;
 import java.util.Map;
 
-import io.quarkiverse.fury.FurySerialization;
-
-@FurySerialization(classId = 300)
 public record Foo(int f1, String f2, List<String> f3, Map<String, Long> f4) {
 }

integration-tests/src/main/java/io/quarkiverse/fury/it/Struct.java

@@ -22,9 +22,6 @@
 import java.io.Serializable;
 import java.util.Objects;
 
-import io.quarkiverse.fury.FurySerialization;
-
-@FurySerialization
 public class Struct implements Serializable {
     public int f1;
     public long f2;

integration-tests/src/main/resources/application.properties

@@ -0,0 +1,2 @@
+quarkus.fury.register-class-names=io.quarkiverse.fury.it.Struct
+quarkus.fury.register-classes."io.quarkiverse.fury.it.Foo".class-id=300

runtime/src/main/java/io/quarkiverse/fury/FuryBuildTimeConfig.java

@@ -1,5 +1,10 @@
 package io.quarkiverse.fury;
 
+import java.util.Map;
+import java.util.Optional;
+
+import io.quarkus.runtime.annotations.ConfigDocMapKey;
+import io.quarkus.runtime.annotations.ConfigDocSection;
 import io.quarkus.runtime.annotations.ConfigPhase;
 import io.quarkus.runtime.annotations.ConfigRoot;
 import io.smallrye.config.ConfigMapping;
@@ -15,4 +20,17 @@ public interface FuryBuildTimeConfig {
     /** Whether to use thread safe fury. The default is true. */
     @WithDefault("true")
     boolean threadSafe();
+
+    /**
+     * Names of classes to register which no need to be with class-id or customize serializer.
+     */
+    Optional<String> registerClassNames();
+
+    /**
+     * Configurations of register classes
+     */
+    @ConfigDocSection
+    @ConfigDocMapKey("register-class-name")
+    Map<String, FuryRegisterClassConfig> registerClasses();
+
 }

runtime/src/main/java/io/quarkiverse/fury/FuryRecorder.java

@@ -1,19 +1,24 @@
 package io.quarkiverse.fury;
 
+import java.util.Optional;
+
 import org.apache.fury.BaseFury;
 import org.apache.fury.Fury;
 import org.apache.fury.ThreadSafeFury;
 import org.apache.fury.config.FuryBuilder;
 import org.apache.fury.resolver.ClassResolver;
 import org.apache.fury.serializer.Serializer;
 import org.apache.fury.util.Preconditions;
+import org.jboss.logging.Logger;
 
 import io.quarkus.arc.runtime.BeanContainer;
 import io.quarkus.runtime.RuntimeValue;
 import io.quarkus.runtime.annotations.Recorder;
 
 @Recorder
 public class FuryRecorder {
+    private static final Logger LOG = Logger.getLogger(FuryRecorder.class);
+
     public RuntimeValue<BaseFury> createFury(
             final FuryBuildTimeConfig config, final BeanContainer beanContainer) {
         // create the Fury instance from the config
@@ -26,6 +31,25 @@ public RuntimeValue<BaseFury> createFury(
         return new RuntimeValue<>(fury);
     }
 
+    public void registerClassByName(final RuntimeValue<BaseFury> furyValue, final String className, final int classId,
+            final Optional<String> serializerClassName) {
+        try {
+            Class<?> clazz = Thread.currentThread().getContextClassLoader().loadClass(className);
+            Class<? extends Serializer> serializer = null;
+            if (serializerClassName.isPresent()) {
+                serializer = (Class<? extends Serializer>) Thread.currentThread().getContextClassLoader()
+                        .loadClass(serializerClassName.get());
+            }
+            registerClass(furyValue, clazz, classId, serializer);
+        } catch (ClassNotFoundException e) {
+            LOG.warn("can not find register class: " + className
+                    + (serializerClassName.isPresent()
+                            ? " with serializer: " + serializerClassName.get()
+                            : ""));
+            throw new RuntimeException(e);
+        }
+    }
+
     public void registerClass(
             final RuntimeValue<BaseFury> furyValue, final Class<?> clazz,
             final int classId, Class<? extends Serializer> serializer) {
@@ -40,13 +64,17 @@ public void registerClass(
             if (fury instanceof ThreadSafeFury) {
                 ThreadSafeFury threadSafeFury = (ThreadSafeFury) fury;
                 registeredClass = (threadSafeFury).execute(f -> f.getClassResolver().getRegisteredClass((short) classId));
-                // Generate serializer bytecode.
-                threadSafeFury.execute(f -> f.getClassResolver().getSerializerClass(clazz));
+                if (serializer == null) {
+                    // Generate serializer bytecode.
+                    threadSafeFury.execute(f -> f.getClassResolver().getSerializerClass(clazz));
+                }
             } else {
                 ClassResolver classResolver = ((Fury) fury).getClassResolver();
                 registeredClass = classResolver.getRegisteredClass((short) classId);
-                // Generate serializer bytecode.
-                classResolver.getSerializerClass(clazz);
+                if (serializer == null) {
+                    // Generate serializer bytecode.
+                    classResolver.getSerializerClass(clazz);
+                }
             }
             Preconditions.checkArgument(
                     registeredClass == null,
@@ -56,7 +84,7 @@ public void registerClass(
             fury.register(clazz, (short) classId);
         } else {
             // Generate serializer bytecode.
-            fury.register(clazz, true);
+            fury.register(clazz, serializer == null);
         }
         if (serializer != null) {
             fury.registerSerializer(clazz, serializer);

runtime/src/main/java/io/quarkiverse/fury/FuryRegisterClassConfig.java

@@ -0,0 +1,24 @@
+package io.quarkiverse.fury;
+
+import java.util.Optional;
+
+import io.quarkus.runtime.annotations.ConfigGroup;
+import io.smallrye.config.WithDefault;
+
+@ConfigGroup
+public interface FuryRegisterClassConfig {
+    /**
+     * Class id must be greater or equal to 256, and it must be different between classes.
+     * The default is -1.
+     */
+    @WithDefault("-1")
+    Integer classId();
+
+    /**
+     * Specify a customized serializer for current class.
+     * This should be empty to let Fury create serializer for current class. But if
+     * users want to customize serialization for this class, one can provide serializer here.
+     */
+    Optional<String> serializer();
+
+}