mark nullable

Signed-off-by: neo <1100909+neowu@users.noreply.github.com>

Author: neowu

buildSrc/src/main/kotlin/db-migration.gradle.kts

@@ -5,7 +5,7 @@ plugins {
 }
 
 tasks.withType<AbstractFlywayTask> {
-    notCompatibleWithConfigurationCache("https://github.com/flyway/flyway/issues/3550")
+    notCompatibleWithConfigurationCache("https://github.com/flyway/flyway/issues/4107")
 
     val migrationDir = file("src/main/resources/db/migration")
     if (!migrationDir.exists()) throw Error("$migrationDir does not exist")

core-ng-search/src/main/java/core/framework/search/impl/DocumentClassValidator.java

@@ -29,7 +29,7 @@ public void visitClass(Class<?> objectClass, @Nullable String path) {
     }
 
     @Override
-    public void visitField(Field field, String parentPath) {
+    public void visitField(Field field, @Nullable String parentPath) {
         super.visitField(field, parentPath);
 
         try {

core-ng/src/main/java/core/framework/internal/inject/BeanFactory.java

@@ -34,7 +34,7 @@ public void bind(Type type, @Nullable String name, Object instance) {
             throw new Error(format("found duplicate bean, type={}, name={}, previous={}", type.getTypeName(), name, previous));
     }
 
-    public Object bean(Type type, String name) {
+    public Object bean(Type type, @Nullable String name) {
         Object bean = beans.get(new Key(type, name));
         if (bean == null) throw new Error(format("can not find bean, type={}, name={}", type.getTypeName(), name));
         return bean;

core-ng/src/main/java/core/framework/internal/inject/InjectValidator.java

@@ -3,6 +3,7 @@
 import core.framework.inject.Inject;
 import core.framework.internal.reflect.Fields;
 import core.framework.util.Strings;
+import org.jspecify.annotations.Nullable;
 
 import java.lang.reflect.Field;
 import java.lang.reflect.Modifier;
@@ -61,6 +62,7 @@ private boolean shouldInspect(Object value) {
         return !visitedObjects.contains(value);
     }
 
+    @Nullable
     private Object fieldValue(Field field, Object instance) {
         if (field.trySetAccessible()) {
             try {

core-ng/src/main/java/core/framework/internal/inject/package-info.java

@@ -0,0 +1,4 @@
+@NullMarked
+package core.framework.internal.inject;
+
+import org.jspecify.annotations.NullMarked;

core-ng/src/main/java/core/framework/internal/json/JSONClassValidator.java

@@ -7,6 +7,7 @@
 import core.framework.internal.validate.ClassVisitor;
 import core.framework.util.Maps;
 import core.framework.util.Sets;
+import org.jspecify.annotations.Nullable;
 
 import java.lang.reflect.Field;
 import java.math.BigDecimal;
@@ -55,7 +56,7 @@ public void validate() {
     }
 
     @Override
-    public void visitField(Field field, String parentPath) {
+    public void visitField(Field field, @Nullable String parentPath) {
         Property property = field.getDeclaredAnnotation(Property.class);
         if (property == null)
             throw new Error("field must have @Property, field=" + Fields.path(field));

core-ng/src/main/java/core/framework/internal/log/AbstractLogger.java

@@ -1,5 +1,6 @@
 package core.framework.internal.log;
 
+import org.jspecify.annotations.Nullable;
 import org.slf4j.Logger;
 import org.slf4j.Marker;
 
@@ -13,23 +14,23 @@ abstract class AbstractLogger implements Logger {
         this.name = name;
     }
 
-    abstract void log(Marker marker, LogLevel level, String message, Object[] arguments, Throwable exception);
+    abstract void log(@Nullable Marker marker, LogLevel level, String message, @Nullable Object[] arguments, @Nullable Throwable exception);
 
-    private void logWithOneArgument(Marker marker, LogLevel level, String format, Object arg) {
+    private void logWithOneArgument(@Nullable Marker marker, LogLevel level, String format, Object arg) {
         if (arg instanceof Throwable exception)
             log(marker, level, format, null, exception);
         else
             log(marker, level, format, new Object[]{arg}, null);
     }
 
-    private void logWithTwoArguments(Marker marker, LogLevel level, String format, Object arg1, Object arg2) {
+    private void logWithTwoArguments(@Nullable Marker marker, LogLevel level, String format, Object arg1, Object arg2) {
         if (arg2 instanceof Throwable exception)
             log(marker, level, format, new Object[]{arg1}, exception);
         else
             log(marker, level, format, new Object[]{arg1, arg2}, null);
     }
 
-    private void logWithArguments(Marker marker, LogLevel level, String format, Object... arguments) {
+    private void logWithArguments(@Nullable Marker marker, LogLevel level, String format, Object... arguments) {
         if (arguments.length > 0 && arguments[arguments.length - 1] instanceof Throwable exception) {
             Object[] messageArguments = new Object[arguments.length - 1];
             System.arraycopy(arguments, 0, messageArguments, 0, arguments.length - 1);

core-ng/src/main/java/core/framework/internal/log/ActionLog.java

@@ -37,14 +37,19 @@ public final class ActionLog {
     public LogLevel result = LogLevel.INFO;
     public Trace trace = Trace.NONE;        // whether flush trace log for all subsequent actions
     public String action = "unassigned";
+    @Nullable
     public List<String> correlationIds;     // with bulk message handler, there will be multiple correlationIds handled by one batch
+    @Nullable
     public List<String> clients;
+    @Nullable
     public List<String> refIds;
-    public String errorMessage;
     long elapsed;
+    @Nullable
+    public String errorMessage;
+    @Nullable
     private String errorCode;
 
-    public ActionLog(String message, String id) {
+    public ActionLog(String message, @Nullable String id) {
         startTime = System.nanoTime();
         date = Instant.now();
         if (id == null) {

core-ng/src/main/java/core/framework/internal/log/LogEvent.java

@@ -17,12 +17,14 @@ final class LogEvent {
 
     private final long time = System.nanoTime();
     private final String logger;
+    @Nullable
     private final Marker marker;
     private final String message;
-    private final Object[] arguments;
+    private final Object @Nullable [] arguments;
+    @Nullable
     private final Throwable exception;
 
-    LogEvent(String logger, Marker marker, LogLevel level, String message, Object[] arguments, Throwable exception) {
+    LogEvent(String logger, @Nullable Marker marker, LogLevel level, String message, Object @Nullable [] arguments, @Nullable Throwable exception) {
         this.logger = logger;
         this.marker = marker;
         this.level = level;

core-ng/src/main/java/core/framework/internal/log/LogManager.java

@@ -53,6 +53,7 @@ public static ActionLog currentActionLog() {
     }
 
     private final ActionLogMessageFactory actionLogMessageFactory = new ActionLogMessageFactory();
+    @Nullable
     public LogAppender appender;
 
     // this is internal api, to simplify the design, task must not throw exceptions, all callers catch throwable and log error