add support for spring-boot 4x #480

Author: osoykan

gradle/libs.versions.toml

@@ -9,6 +9,7 @@ quarkus = "3.30.0"
 jakarta = "4.1.0"
 spring-boot-2x = "2.7.18"
 spring-boot-3x = "3.5.8"
+spring-boot-4x = "4.0.0"
 ktlint = "1.8.0"
 
 [libraries]
@@ -20,6 +21,10 @@ quarkusBom = { module = "io.quarkus:quarkus-bom", version.ref = "quarkus" }
 quarkus-arc = { module = "io.quarkus:quarkus-arc", version.ref = "quarkus" }
 jakarta-enterpise-cdi-api = { module = "jakarta.enterprise:jakarta.enterprise.cdi-api", version.ref = "jakarta" }
 
+spring-boot-4x-starter = { module = "org.springframework.boot:spring-boot-starter", version.ref = "spring-boot-4x" }
+spring-boot-4x-autoconfigure = { module = "org.springframework.boot:spring-boot-autoconfigure", version.ref = "spring-boot-4x" }
+spring-boot-4x-starter-test = { module = "org.springframework.boot:spring-boot-starter-test", version.ref = "spring-boot-4x" }
+
 spring-boot-3x-starter = { module = "org.springframework.boot:spring-boot-starter", version.ref = "spring-boot-3x" }
 spring-boot-3x-autoconfigure = { module = "org.springframework.boot:spring-boot-autoconfigure", version.ref = "spring-boot-3x" }
 spring-boot-3x-starter-test = { module = "org.springframework.boot:spring-boot-starter-test", version.ref = "spring-boot-3x" }

projects/kediatr-spring-boot-3x-starter/build.gradle.kts

@@ -1,7 +1,6 @@
 dependencies {
   api(projects.projects.kediatrCore)
   implementation(libs.spring.boot.get3x().starter)
-  implementation(libs.spring.boot.get3x().autoconfigure)
 }
 
 dependencies {

projects/kediatr-spring-boot-4x-starter/build.gradle.kts

@@ -0,0 +1,9 @@
+dependencies {
+  api(projects.projects.kediatrCore)
+  implementation(libs.spring.boot.get4x().starter)
+}
+
+dependencies {
+  testImplementation(testFixtures(projects.projects.kediatrCore))
+  testImplementation(libs.spring.boot.get4x().starter.test)
+}

projects/kediatr-spring-boot-4x-starter/src/main/kotlin/com/trendyol/kediatr/spring/KediatRAutoConfiguration.kt

@@ -0,0 +1,22 @@
+package com.trendyol.kediatr.spring
+
+import com.trendyol.kediatr.Mediator
+import org.springframework.boot.autoconfigure.AutoConfiguration
+import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean
+import org.springframework.context.ApplicationContext
+import org.springframework.context.annotation.Bean
+
+@AutoConfiguration
+open class KediatRAutoConfiguration {
+  @Bean
+  @ConditionalOnMissingBean
+  open fun kediatRSpringBeanProvider(
+    applicationContext: ApplicationContext
+  ): KediatRSpringBeanProvider = KediatRSpringBeanProvider(applicationContext)
+
+  @Bean
+  @ConditionalOnMissingBean
+  open fun mediator(
+    kediatRSpringBeanProvider: KediatRSpringBeanProvider
+  ): Mediator = Mediator.build(kediatRSpringBeanProvider)
+}

projects/kediatr-spring-boot-4x-starter/src/main/kotlin/com/trendyol/kediatr/spring/KediatRSpringBeanProvider.kt

@@ -0,0 +1,21 @@
+@file:Suppress("UNCHECKED_CAST")
+
+package com.trendyol.kediatr.spring
+
+import com.trendyol.kediatr.DependencyProvider
+import org.springframework.context.ApplicationContext
+
+class KediatRSpringBeanProvider(
+  private val applicationContext: ApplicationContext
+) : DependencyProvider {
+  override fun <T> getSingleInstanceOf(clazz: Class<T>): T = applicationContext
+    .getBeanNamesForType(clazz)
+    .map { applicationContext.getBean(it) as T }
+    .single()
+
+  override fun <T> getSubTypesOf(
+    clazz: Class<T>
+  ): Collection<Class<T>> = applicationContext
+    .getBeanNamesForType(clazz)
+    .map { applicationContext.getType(it) as Class<T> }
+}

projects/kediatr-spring-boot-4x-starter/src/main/resources/META-INF/spring/org.springframework.boot.autoconfigure.AutoConfiguration.imports

@@ -0,0 +1 @@
+com.trendyol.kediatr.spring.KediatRAutoConfiguration

projects/kediatr-spring-boot-4x-starter/src/test/kotlin/com/trendyol/kediatr/spring/MediatorTests.kt

@@ -0,0 +1,89 @@
+package com.trendyol.kediatr.spring
+
+import com.trendyol.kediatr.Mediator
+import com.trendyol.kediatr.testing.*
+import org.springframework.beans.factory.annotation.Autowired
+import org.springframework.boot.test.context.SpringBootTest
+import org.springframework.context.annotation.*
+
+@SpringBootTest(
+  classes = [
+    KediatRAutoConfiguration::class,
+    MediatorTests.TestConfiguration::class,
+    TestRequestHandler::class,
+    ExceptionPipelineBehavior::class,
+    LoggingPipelineBehavior::class,
+    TestQueryHandler::class,
+    TestNotificationHandler::class,
+    TestBrokenRequestHandler::class,
+    TestPipelineRequestHandler::class,
+    TestCommandWithResultRequestHandler::class,
+    TestInheritedRequestHandlerForSpecificCommand::class,
+    TestRequestHandlerWithoutInjection::class,
+    TestRequestHandlerForTypeLimitedInheritance::class,
+    ParameterizedRequestHandler::class,
+    ParameterizedRequestHandlerForInheritance::class,
+    ParameterizedCommandWithResultHandler::class,
+    ParameterizedCommandWithResultHandlerOfInheritedHandler::class,
+    APingHandler::class,
+    AnotherPingHandler::class,
+    Handler1ForNotificationOfMultipleHandlers::class,
+    Handler2ForNotificationOfMultipleHandlers::class,
+    InheritedNotificationHandler::class,
+    InheritedNotificationHandler2::class,
+    ParameterizedNotificationHandler::class,
+    ParameterizedNotificationHandlerForInheritance::class,
+    TestPipelineRequestHandlerWithoutInjection::class,
+    TestPipelineRequestHandlerThatFails::class,
+    InheritedPipelineBehaviour::class,
+    ParameterizedQueryHandler::class,
+    FirstPipelineBehaviour::class,
+    SecondPipelineBehaviour::class,
+    ThirdPipelineBehaviour::class,
+    RequestHandlerThatPassesThroughOrderedPipelineBehaviours::class,
+    QueryHandlerThatPassesThroughOrderedPipelineBehaviours::class,
+    NotificationHandlerThatPassesThroughOrderedPipelineBehaviours::class,
+    TestCommandBaseHandler::class,
+    TestQueryBaseHandler::class,
+    TestCommandWithResultBaseHandler::class,
+    TestCommandForInheritanceWithFallbackHandlerHandler::class,
+    TestRequestHandlerForCommandInherited2::class,
+    ModifyingPipelineBehavior::class,
+    TimingPipelineBehavior::class,
+    ConditionalPipelineBehavior::class,
+    RequestWithNullableResultHandler::class,
+    RequestWithNullParameterHandler::class,
+    NestedGenericRequestHandler::class,
+    WildcardGenericRequestHandler::class,
+    ConcurrentRequestHandler::class,
+    LongRunningRequestHandler::class,
+    MultiInterfaceRequestHandler::class,
+    EmptyRequestHandler::class,
+    VoidResultRequestHandler::class,
+    CollectionRequestHandler::class,
+    RequestThatThrowsSpecificExceptionHandler::class,
+    RequestThatThrowsRuntimeExceptionHandler::class,
+    ComplexPipelineRequestHandler::class,
+    ComplexDataRequestHandler::class,
+    NotificationThatThrowsExceptionHandler1::class,
+    NotificationThatThrowsExceptionHandler2::class,
+    NotificationThatThrowsExceptionHandler3::class,
+    SlowNotificationHandler1::class,
+    SlowNotificationHandler2::class,
+    SlowNotificationHandler3::class,
+    SelfReferencingRequestHandler::class,
+    CatchAllNotificationsHandler::class
+  ]
+)
+class MediatorTests : MediatorUseCases() {
+  @Autowired
+  lateinit var mediator: Mediator
+
+  override fun provideMediator(): Mediator = mediator
+
+  @Configuration
+  open class TestConfiguration {
+    @Bean
+    open fun mediatorAccessor(mediator: Mediator): MediatorAccessor = { mediator }
+  }
+}

settings.gradle.kts

@@ -10,6 +10,7 @@ include(
   "projects:kediatr-quarkus-starter",
   "projects:kediatr-spring-boot-2x-starter",
   "projects:kediatr-spring-boot-3x-starter",
+  "projects:kediatr-spring-boot-4x-starter",
 )
 
 enableFeaturePreview("TYPESAFE_PROJECT_ACCESSORS")