fix(core): strip null bytes from JSONB values before PostgreSQL insert (#15647)

PostgreSQL rejects JSONB payloads containing \u0000 null bytes. Instead
of catching the error after the fact, proactively strip them via a
JdbcJsonbUtils utility used at all JSONB.valueOf() call sites.

Author: Skraye

jdbc-postgres/src/main/java/io/kestra/repository/postgres/PostgresRepository.java

@@ -16,6 +16,7 @@
 import org.jooq.impl.DSL;
 
 import io.kestra.core.repositories.ArrayListTotal;
+import io.kestra.jdbc.JdbcJsonbUtils;
 import io.kestra.jdbc.JdbcTableConfig;
 import io.kestra.jdbc.JooqDSLContextWrapper;
 
@@ -57,7 +58,7 @@ public Condition fullTextCondition(List<String> fields, String query) {
     public Map<Field<Object>, Object> persistFields(T entity) {
         String json = MAPPER.writeValueAsString(entity);
         Map<Field<Object>, Object> fields = HashMap.newHashMap(1);
-        fields.put(VALUE_FIELD, DSL.val(JSONB.valueOf(json)));
+        fields.put(VALUE_FIELD, DSL.val(JdbcJsonbUtils.valueOf(json)));
         return fields;
     }
 

jdbc/src/main/java/io/kestra/jdbc/JdbcJsonbUtils.java

@@ -0,0 +1,14 @@
+package io.kestra.jdbc;
+
+import org.jooq.JSONB;
+
+/**
+ * Strips PostgreSQL-incompatible null bytes from JSONB payloads.
+ */
+public final class JdbcJsonbUtils {
+    private JdbcJsonbUtils() {}
+
+    public static JSONB valueOf(String json) {
+        return json == null ? null : JSONB.valueOf(json.replace("\u0000", ""));
+    }
+}

jdbc/src/main/java/io/kestra/jdbc/runner/JdbcQueue.java

@@ -32,6 +32,7 @@
 import io.kestra.core.utils.ExecutorsUtils;
 import io.kestra.core.utils.IdUtils;
 import io.kestra.core.utils.ListUtils;
+import io.kestra.jdbc.JdbcJsonbUtils;
 import io.kestra.jdbc.JdbcMapper;
 import io.kestra.jdbc.JdbcTableConfigs;
 import io.kestra.jdbc.JooqDSLContextWrapper;
@@ -130,7 +131,7 @@ protected Map<Field<Object>, Object> produceFields(String consumerGroup, String
         Map<Field<Object>, Object> fields = HashMap.newHashMap(4);
         fields.put(TYPE_FIELD, queueType());
         fields.put(KEY_FIELD, key != null ? key : IdUtils.create());
-        fields.put(VALUE_FIELD, JSONB.valueOf(new String(bytes)));
+        fields.put(VALUE_FIELD, JdbcJsonbUtils.valueOf(new String(bytes)));
 
         if (consumerGroup != null) {
             fields.put(CONSUMER_GROUP_FIELD, consumerGroup);

jdbc/src/test/java/io/kestra/jdbc/JdbcJsonbUtilsTest.java

@@ -0,0 +1,53 @@
+package io.kestra.jdbc;
+
+import org.jooq.JSONB;
+import org.junit.jupiter.api.Test;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+class JdbcJsonbUtilsTest {
+    @Test
+    void shouldReturnNullForNullInput() {
+        assertThat(JdbcJsonbUtils.valueOf(null)).isNull();
+    }
+
+    @Test
+    void shouldStripNullBytes() {
+        // Given
+        String jsonWithNullBytes = "{\"key\":\"value\u0000with\u0000nulls\"}";
+
+        // When
+        JSONB result = JdbcJsonbUtils.valueOf(jsonWithNullBytes);
+
+        // Then
+        assertThat(result).isNotNull();
+        assertThat(result.data()).isEqualTo("{\"key\":\"valuewithnulls\"}");
+        assertThat(result.data()).doesNotContain("\u0000");
+    }
+
+    @Test
+    void shouldLeaveCleanJsonUnchanged() {
+        // Given
+        String cleanJson = "{\"key\":\"value\",\"number\":42}";
+
+        // When
+        JSONB result = JdbcJsonbUtils.valueOf(cleanJson);
+
+        // Then
+        assertThat(result).isNotNull();
+        assertThat(result.data()).isEqualTo(cleanJson);
+    }
+
+    @Test
+    void shouldHandleJsonWithOnlyNullByte() {
+        // Given
+        String onlyNullByte = "\u0000";
+
+        // When
+        JSONB result = JdbcJsonbUtils.valueOf(onlyNullByte);
+
+        // Then
+        assertThat(result).isNotNull();
+        assertThat(result.data()).isEmpty();
+    }
+}