spotless

Author: osoykan

projects/kediatr-core/src/main/kotlin/com/trendyol/kediatr/AggregateException.kt

@@ -5,6 +5,8 @@ package com.trendyol.kediatr
  *
  * @since 1.0.9
  */
-class AggregateException(val exceptions: Collection<Throwable>) : RuntimeException() {
+class AggregateException(
+  val exceptions: Collection<Throwable>
+) : RuntimeException() {
   constructor(exceptions: Array<Throwable>) : this(exceptions.toList())
 }

projects/kediatr-core/src/main/kotlin/com/trendyol/kediatr/CommandProvider.kt

@@ -9,9 +9,7 @@ internal class CommandProvider<H : CommandHandler<*>>(
   private val dependencyProvider: DependencyProvider,
   private val type: Class<H>
 ) {
-  fun get(): H {
-    return dependencyProvider.getSingleInstanceOf(type)
-  }
+  fun get(): H = dependencyProvider.getSingleInstanceOf(type)
 }
 
 /**
@@ -24,7 +22,5 @@ internal class CommandWithResultProvider<H : CommandWithResultHandler<*, *>>(
   private val dependencyProvider: DependencyProvider,
   private val type: Class<H>
 ) {
-  fun get(): H {
-    return dependencyProvider.getSingleInstanceOf(type)
-  }
+  fun get(): H = dependencyProvider.getSingleInstanceOf(type)
 }

projects/kediatr-core/src/main/kotlin/com/trendyol/kediatr/Container.kt

@@ -1,7 +1,9 @@
 package com.trendyol.kediatr
 
 @Suppress("UNCHECKED_CAST")
-internal class Container(dependencyProvider: DependencyProvider) : Registrar() {
+internal class Container(
+  dependencyProvider: DependencyProvider
+) : Registrar() {
   val commandMap = HashMap<Class<*>, CommandProvider<CommandHandler<Command>>>()
   val queryMap = HashMap<Class<*>, QueryProvider<QueryHandler<*, *>>>()
   val notificationMap = HashMap<Class<*>, MutableList<NotificationProvider<NotificationHandler<*>>>>()
@@ -27,7 +29,8 @@ internal class Container(dependencyProvider: DependencyProvider) : Registrar() {
     }
 
     registerFor<NotificationHandler<Notification>, Notification>(dependencyProvider) { key, value ->
-      notificationMap.getOrPut(key) { mutableListOf() }
+      notificationMap
+        .getOrPut(key) { mutableListOf() }
         .add(NotificationProvider(dependencyProvider, value as Class<NotificationHandler<*>>))
     }
 

projects/kediatr-core/src/main/kotlin/com/trendyol/kediatr/HandlerNotFoundException.kt

@@ -1,3 +1,5 @@
 package com.trendyol.kediatr
 
-class HandlerNotFoundException(message: String) : Exception(message)
+class HandlerNotFoundException(
+  message: String
+) : Exception(message)

projects/kediatr-core/src/main/kotlin/com/trendyol/kediatr/MediatorBuilder.kt

@@ -22,7 +22,5 @@ class MediatorBuilder(
     return this
   }
 
-  fun build(registry: Registry = RegistryImpl(dependencyProvider)): Mediator {
-    return MediatorImpl(registry, defaultPublishStrategy)
-  }
+  fun build(registry: Registry = RegistryImpl(dependencyProvider)): Mediator = MediatorImpl(registry, defaultPublishStrategy)
 }

projects/kediatr-core/src/main/kotlin/com/trendyol/kediatr/NotificationProvider.kt

@@ -4,7 +4,5 @@ internal class NotificationProvider<H : NotificationHandler<*>>(
   private val dependencyProvider: DependencyProvider,
   private val type: Class<H>
 ) {
-  fun get(): H {
-    return dependencyProvider.getSingleInstanceOf(type)
-  }
+  fun get(): H = dependencyProvider.getSingleInstanceOf(type)
 }

projects/kediatr-core/src/main/kotlin/com/trendyol/kediatr/PipelineProvider.kt

@@ -9,7 +9,5 @@ internal class PipelineProvider<H : PipelineBehavior>(
   private val dependencyProvider: DependencyProvider,
   private val type: Class<H>
 ) {
-  fun get(): H {
-    return dependencyProvider.getSingleInstanceOf(type)
-  }
+  fun get(): H = dependencyProvider.getSingleInstanceOf(type)
 }

projects/kediatr-core/src/main/kotlin/com/trendyol/kediatr/QueryProvider.kt

@@ -9,7 +9,5 @@ internal class QueryProvider<H : QueryHandler<*, *>>(
   private val dependencyProvider: DependencyProvider,
   private val type: Class<H>
 ) {
-  fun get(): H {
-    return dependencyProvider.getSingleInstanceOf(type)
-  }
+  fun get(): H = dependencyProvider.getSingleInstanceOf(type)
 }

projects/kediatr-core/src/main/kotlin/com/trendyol/kediatr/RegistryImpl.kt

@@ -26,7 +26,8 @@ class RegistryImpl(
   override fun <TNotification : Notification> resolveNotificationHandlers(
     classOfNotification: Class<TNotification>
   ): Collection<NotificationHandler<TNotification>> =
-    registry.notificationMap.filter { (k, _) -> k.isAssignableFrom(classOfNotification) }
+    registry.notificationMap
+      .filter { (k, _) -> k.isAssignableFrom(classOfNotification) }
       .flatMap { (_, v) -> v.map { it.get() as NotificationHandler<TNotification> } }
 
   override fun <TQuery : Query<TResult>, TResult> resolveQueryHandler(classOfQuery: Class<TQuery>): QueryHandler<TQuery, TResult> {

projects/kediatr-core/src/testFixtures/kotlin/com/trendyol/kediatr/testing/models.kt

@@ -37,7 +37,9 @@ abstract class EnrichedWithMetadata {
   }
 }
 
-class Result(val value: Int = 0)
+class Result(
+  val value: Int = 0
+)
 
 class TestNonExistCommand : Command
 
@@ -49,7 +51,9 @@ class NonExistQuery : Query<String>
  * Notifications
  */
 
-class TestNotification : Notification, EnrichedWithMetadata()
+class TestNotification :
+  EnrichedWithMetadata(),
+  Notification
 
 class TestNotificationHandler(
   private val mediator: MediatorAccessor
@@ -60,7 +64,9 @@ class TestNotificationHandler(
   }
 }
 
-open class Ping : Notification, EnrichedWithMetadata()
+open class Ping :
+  EnrichedWithMetadata(),
+  Notification
 
 class ExtendedPing : Ping()
 
@@ -76,7 +82,9 @@ class AnotherPingHandler : NotificationHandler<Ping> {
   }
 }
 
-class NotificationForMultipleHandlers : Notification, EnrichedWithMetadata()
+class NotificationForMultipleHandlers :
+  EnrichedWithMetadata(),
+  Notification
 
 class Handler1ForNotificationOfMultipleHandlers : NotificationHandler<NotificationForMultipleHandlers> {
   override suspend fun handle(notification: NotificationForMultipleHandlers) {
@@ -90,7 +98,9 @@ class Handler2ForNotificationOfMultipleHandlers : NotificationHandler<Notificati
   }
 }
 
-class PingForInherited : Notification, EnrichedWithMetadata()
+class PingForInherited :
+  EnrichedWithMetadata(),
+  Notification
 
 abstract class NotificationHandlerBase<TNotification : Notification> : NotificationHandler<TNotification>
 
@@ -100,7 +110,10 @@ class InheritedNotificationHandler : NotificationHandlerBase<PingForInherited>()
   }
 }
 
-class ParameterizedNotification<T>(val param: T) : Notification, EnrichedWithMetadata()
+class ParameterizedNotification<T>(
+  val param: T
+) : EnrichedWithMetadata(),
+  Notification
 
 class ParameterizedNotificationHandler<A> : NotificationHandler<ParameterizedNotification<A>> {
   override suspend fun handle(notification: ParameterizedNotification<A>) {
@@ -109,7 +122,10 @@ class ParameterizedNotificationHandler<A> : NotificationHandler<ParameterizedNot
   }
 }
 
-class ParameterizedNotificationForInheritance<T>(val param: T) : Notification, EnrichedWithMetadata()
+class ParameterizedNotificationForInheritance<T>(
+  val param: T
+) : EnrichedWithMetadata(),
+  Notification
 
 class ParameterizedNotificationHandlerForInheritance<T> : NotificationHandlerBase<ParameterizedNotificationForInheritance<T>>() {
   override suspend fun handle(notification: ParameterizedNotificationForInheritance<T>) {
@@ -122,15 +138,19 @@ class ParameterizedNotificationHandlerForInheritance<T> : NotificationHandlerBas
  * Commands
  */
 
-class TestCommandForWithoutInjection : Command, EnrichedWithMetadata()
+class TestCommandForWithoutInjection :
+  EnrichedWithMetadata(),
+  Command
 
 class TestCommandHandlerWithoutInjection : CommandHandler<TestCommandForWithoutInjection> {
   override suspend fun handle(command: TestCommandForWithoutInjection) {
     command.incrementInvocationCount()
   }
 }
 
-class TestCommand : Command, EnrichedWithMetadata()
+class TestCommand :
+  EnrichedWithMetadata(),
+  Command
 
 class TestCommandHandler(
   private val mediator: MediatorAccessor
@@ -141,9 +161,14 @@ class TestCommandHandler(
   }
 }
 
-data class TestCommandWithResult(val invoked: Int = 0) : CommandWithResult<Result>, EnrichedWithMetadata()
+data class TestCommandWithResult(
+  val invoked: Int = 0
+) : EnrichedWithMetadata(),
+  CommandWithResult<Result>
 
-class TestCommandWithResultCommandHandler(val mediator: MediatorAccessor) : CommandWithResultHandler<TestCommandWithResult, Result> {
+class TestCommandWithResultCommandHandler(
+  val mediator: MediatorAccessor
+) : CommandWithResultHandler<TestCommandWithResult, Result> {
   override suspend fun handle(
     command: TestCommandWithResult
   ): Result = Result(command.invoked + 1).also {
@@ -153,8 +178,8 @@ class TestCommandWithResultCommandHandler(val mediator: MediatorAccessor) : Comm
 }
 
 class CommandThatPassesThroughPipelineBehaviours :
-  Command,
   EnrichedWithMetadata(),
+  Command,
   CanPassLoggingPipelineBehaviour,
   CanPassExceptionPipelineBehaviour,
   CanPassInheritedPipelineBehaviour
@@ -169,8 +194,8 @@ class TestPipelineCommandHandler(
 }
 
 class CommandForWithoutInjectionThatPassesThroughPipelineBehaviours :
-  Command,
   EnrichedWithMetadata(),
+  Command,
   CanPassLoggingPipelineBehaviour,
   CanPassExceptionPipelineBehaviour,
   CanPassInheritedPipelineBehaviour
@@ -181,7 +206,9 @@ class TestPipelineCommandHandlerWithoutInjection : CommandHandler<CommandForWith
   }
 }
 
-class CommandThatFailsWhilePassingThroughPipelineBehaviours : Command, EnrichedWithMetadata()
+class CommandThatFailsWhilePassingThroughPipelineBehaviours :
+  EnrichedWithMetadata(),
+  Command
 
 class TestPipelineCommandHandlerThatFails : CommandHandler<CommandThatFailsWhilePassingThroughPipelineBehaviours> {
   override suspend fun handle(command: CommandThatFailsWhilePassingThroughPipelineBehaviours) {
@@ -190,7 +217,9 @@ class TestPipelineCommandHandlerThatFails : CommandHandler<CommandThatFailsWhile
   }
 }
 
-class TestCommandThatFailsWithException : Command, EnrichedWithMetadata()
+class TestCommandThatFailsWithException :
+  EnrichedWithMetadata(),
+  Command
 
 class TestBrokenCommandHandler(
   private val mediator: MediatorAccessor
@@ -202,7 +231,9 @@ class TestBrokenCommandHandler(
   }
 }
 
-class TestCommandForInheritance : Command, EnrichedWithMetadata()
+class TestCommandForInheritance :
+  EnrichedWithMetadata(),
+  Command
 
 abstract class MyCommandHandlerBaseForSpecificCommand : CommandHandler<TestCommandForInheritance>
 
@@ -212,7 +243,9 @@ class TestInheritedCommandHandlerForSpecificCommand : MyCommandHandlerBaseForSpe
   }
 }
 
-class TestCommandForTypeLimitedInheritance : Command, EnrichedWithMetadata()
+class TestCommandForTypeLimitedInheritance :
+  EnrichedWithMetadata(),
+  Command
 
 abstract class TestBaseCommandHandlerForTypeLimitedInheritance<TCommand : Command> : CommandHandler<TCommand>
 
@@ -223,7 +256,10 @@ class TestCommandHandlerForTypeLimitedInheritance :
   }
 }
 
-class ParameterizedCommand<T>(val param: T) : Command, EnrichedWithMetadata()
+class ParameterizedCommand<T>(
+  val param: T
+) : EnrichedWithMetadata(),
+  Command
 
 class ParameterizedCommandHandler<T> : CommandHandler<ParameterizedCommand<T>> {
   override suspend fun handle(command: ParameterizedCommand<T>) {
@@ -232,7 +268,10 @@ class ParameterizedCommandHandler<T> : CommandHandler<ParameterizedCommand<T>> {
   }
 }
 
-class ParameterizedCommandForInheritedCommandHandler<T>(val param: T) : Command, EnrichedWithMetadata()
+class ParameterizedCommandForInheritedCommandHandler<T>(
+  val param: T
+) : EnrichedWithMetadata(),
+  Command
 
 abstract class ParameterizedCommandHandlerBaseForInheritedCommandHandler<A> :
   CommandHandler<ParameterizedCommandForInheritedCommandHandler<A>>
@@ -247,7 +286,8 @@ class ParameterizedCommandHandlerForInheritance<A> : ParameterizedCommandHandler
 class ParameterizedCommandWithResult<TParam, TReturn>(
   val param: TParam,
   val retFn: suspend (TParam) -> TReturn
-) : CommandWithResult<TReturn>, EnrichedWithMetadata()
+) : EnrichedWithMetadata(),
+  CommandWithResult<TReturn>
 
 class ParameterizedCommandWithResultHandler<TParam, TReturn> :
   CommandWithResultHandler<ParameterizedCommandWithResult<TParam, TReturn>, TReturn> {
@@ -258,7 +298,10 @@ class ParameterizedCommandWithResultHandler<TParam, TReturn> :
   }
 }
 
-data class ParameterizedCommandWithResultForInheritance<TParam>(val param: TParam) : CommandWithResult<String>, EnrichedWithMetadata()
+data class ParameterizedCommandWithResultForInheritance<TParam>(
+  val param: TParam
+) : EnrichedWithMetadata(),
+  CommandWithResult<String>
 
 abstract class ParameterizedCommandWithResultHandlerBase<TParam : CommandWithResult<String>> : CommandWithResultHandler<TParam, String>
 
@@ -275,7 +318,10 @@ class ParameterizedCommandWithResultHandlerOfInheritedHandler<TParam> :
  * Queries
  */
 
-class TestQuery(val id: Int) : Query<String>, EnrichedWithMetadata()
+class TestQuery(
+  val id: Int
+) : EnrichedWithMetadata(),
+  Query<String>
 
 class TestQueryHandler(
   private val mediator: MediatorAccessor
@@ -290,7 +336,8 @@ class TestQueryHandler(
 class ParameterizedQuery<TParam, TResponse>(
   val param: TParam,
   val retFn: suspend (TParam) -> TResponse
-) : Query<TResponse>, EnrichedWithMetadata()
+) : EnrichedWithMetadata(),
+  Query<TResponse>
 
 class ParameterizedQueryHandler<TParam, TResponse> : QueryHandler<ParameterizedQuery<TParam, TResponse>, TResponse> {
   override suspend fun handle(query: ParameterizedQuery<TParam, TResponse>): TResponse {
@@ -360,11 +407,20 @@ class InheritedPipelineBehaviour : MyBasePipelineBehaviour() {
 
 interface OrderedPipelineUseCase
 
-class CommandThatPassesThroughOrderedPipelineBehaviours : Command, EnrichedWithMetadata(), OrderedPipelineUseCase
+class CommandThatPassesThroughOrderedPipelineBehaviours :
+  EnrichedWithMetadata(),
+  Command,
+  OrderedPipelineUseCase
 
-class QueryThatPassesThroughOrderedPipelineBehaviours : Query<String>, EnrichedWithMetadata(), OrderedPipelineUseCase
+class QueryThatPassesThroughOrderedPipelineBehaviours :
+  EnrichedWithMetadata(),
+  Query<String>,
+  OrderedPipelineUseCase
 
-class NotificationThatPassesThroughOrderedPipelineBehaviours : Notification, EnrichedWithMetadata(), OrderedPipelineUseCase
+class NotificationThatPassesThroughOrderedPipelineBehaviours :
+  EnrichedWithMetadata(),
+  Notification,
+  OrderedPipelineUseCase
 
 class CommandHandlerThatPassesThroughOrderedPipelineBehaviours : CommandHandler<CommandThatPassesThroughOrderedPipelineBehaviours> {
   override suspend fun handle(command: CommandThatPassesThroughOrderedPipelineBehaviours) {