feat(scheduling): use kotlinx.serialization as the JsonMapper

Author: SIMULATAN

build.gradle.kts

@@ -112,13 +112,9 @@ dependencies { with(libs) {
     implementation(log.kotlinLogging)
     implementation(log.coroutines)
 
-    // serialization
-    implementation(libraries.jackson.core)
-    implementation(libraries.jackson.databind)
-    implementation(libraries.jackson.kotlin)
-
     // task scheduling
     implementation(libraries.jobrunr)
+    implementation(libraries.jobrunr.kotlin)
 
     // feature flags
     implementation(libraries.openfeature)

gradle/libs.versions.toml

@@ -3,14 +3,15 @@ hoplite = "2.9.0"
 koin = "4.1.0-Beta5"
 koin-annotations = "2.0.0-RC1"
 ksp = "2.1.10-1.0.29"
-jackson = "2.18.2"
 kotlinx-serialization = "1.8.0"
 kotlin = "2.1.10"
 coroutines = "1.10.1"
 
 mongodb = "5.3.1"
 exposed = "0.59.0"
 
+jobrunr = "7.4.0-kotlinx.1"
+
 opentelemetry = "1.47.0"
 opentelemetry-semconv = "1.29.0-alpha"
 opentelemetry-instrumentation = "2.11.0-alpha"
@@ -79,10 +80,8 @@ libraries-coroutines-core = { group = "org.jetbrains.kotlinx", name = "kotlinx-c
 libraries-bson-kotlin = { group = "org.mongodb", name = "bson-kotlin", version.ref = "mongodb" }
 libraries-bson-kotlinx = { group = "org.mongodb", name = "bson-kotlinx", version.ref = "mongodb" }
 libraries-ical4j = { group = "org.mnode.ical4j", name = "ical4j", version = "4.1.0" }
-libraries-jackson-core = { group = "com.fasterxml.jackson.core", name = "jackson-core", version.ref = "jackson" }
-libraries-jackson-databind = { group = "com.fasterxml.jackson.core", name = "jackson-databind", version.ref = "jackson" }
-libraries-jackson-kotlin = { group = "com.fasterxml.jackson.module", name = "jackson-module-kotlin", version.ref = "jackson" }
-libraries-jobrunr = { group = "org.jobrunr", name = "jobrunr", version = "7.4.0" }
+libraries-jobrunr = { group = "org.jobrunr", name = "jobrunr", version.ref = "jobrunr" }
+libraries-jobrunr-kotlin = { group = "org.jobrunr", name = "jobrunr-kotlin-2.1-support", version.ref = "jobrunr" }
 libraries-kotlinx-datetime = { group = "org.jetbrains.kotlinx", name = "kotlinx-datetime", version = "0.6.1" }
 libraries-kotlinx-serialization = { group = "org.jetbrains.kotlinx", name = "kotlinx-serialization-core", version.ref = "kotlinx-serialization" }
 libraries-openfeature = { group = "dev.openfeature", name = "sdk", version = "1.14.0" }

gradle/repositories.gradle.kts

@@ -2,6 +2,7 @@ dependencyResolutionManagement {
 	repositories {
 		mavenCentral()
 		maven("https://maven.simulatan.me/releases")
+		maven("https://maven.simulatan.me/snapshots")
 		gradlePluginPortal()
 	}
 }

src/main/kotlin/me/snoty/backend/scheduling/jobrunr/JobRunrConfigurer.kt

@@ -1,14 +1,14 @@
 package me.snoty.backend.scheduling.jobrunr
 
-import com.fasterxml.jackson.databind.ObjectMapper
-import com.fasterxml.jackson.module.kotlin.registerKotlinModule
 import io.micrometer.core.instrument.MeterRegistry
+import kotlinx.serialization.ExperimentalSerializationApi
+import kotlinx.serialization.InternalSerializationApi
 import org.jobrunr.configuration.JobRunr
 import org.jobrunr.configuration.JobRunrMicroMeterIntegration
 import org.jobrunr.dashboard.JobRunrDashboardWebServerConfiguration
+import org.jobrunr.kotlin.utils.mapper.KotlinxSerializationJsonMapper
 import org.jobrunr.server.JobActivator
 import org.jobrunr.storage.StorageProvider
-import org.jobrunr.utils.mapper.jackson.JacksonJsonMapper
 import org.koin.core.Koin
 import org.koin.core.annotation.Single
 
@@ -18,8 +18,9 @@ class JobRunrConfigurer(
 	private val storageProvider: StorageProvider,
 	private val koin: Koin,
 ) {
+	@OptIn(ExperimentalSerializationApi::class, InternalSerializationApi::class)
 	fun initialize() = JobRunr.configure()
-		.useJsonMapper(JacksonJsonMapper(ObjectMapper().registerKotlinModule()))
+		.useJsonMapper(KotlinxSerializationJsonMapper())
 		.useStorageProvider(storageProvider)
 		.useJobActivator(object : JobActivator {
 			override fun <T : Any> activateJob(type: Class<T>): T? = koin.getOrNull(type.kotlin)

src/main/kotlin/me/snoty/backend/scheduling/jobrunr/node/JobRunrFlowJobRequest.kt

@@ -1,10 +1,12 @@
 package me.snoty.backend.scheduling.jobrunr.node
 
+import kotlinx.serialization.Serializable
 import me.snoty.backend.integration.config.flow.NodeId
 import me.snoty.backend.scheduling.FlowTriggerReason
 import me.snoty.backend.scheduling.JobRequest
 import org.slf4j.event.Level
 
+@Serializable
 data class JobRunrFlowJobRequest(
 	val flowId: NodeId,
 	val triggeredBy: FlowTriggerReason = FlowTriggerReason.Unknown,