AKTLN-587 reformated the code

Author: mipo256

kotlin-dsl/src/main/kotlin/com/baeldung/functional_dsl/bean_declaration/BeanDeclration.kt

@@ -10,19 +10,19 @@ import org.springframework.context.support.beans
 open class Application
 
 fun main(vararg args: String) {
-  runApplication<Application>(*args) {
-    addInitializers(
-      beans {
-        bean(
-          name = "functionallyDeclaredBean",
-          scope = BeanDefinitionDsl.Scope.SINGLETON,
-          isLazyInit = false,
-          isPrimary = false,
-          function = {
-            BigDecimal(1.0)
-          }
+    runApplication<Application>(*args) {
+        addInitializers(
+            beans {
+                bean(
+                    name = "functionallyDeclaredBean",
+                    scope = BeanDefinitionDsl.Scope.SINGLETON,
+                    isLazyInit = false,
+                    isPrimary = false,
+                    function = {
+                        BigDecimal(1.0)
+                    }
+                )
+            }
         )
-      }
-    )
-  }
+    }
 }

kotlin-dsl/src/main/kotlin/com/baeldung/functional_dsl/regular_controller/RegularController.kt

@@ -11,16 +11,16 @@ import org.springframework.web.bind.annotation.RestController
 @RestController
 class RegularController {
 
-  @GetMapping(path = ["/endpoint/{country}"])
-  fun getPerson(
-    @RequestParam name: String,
-    @RequestHeader(name = "X-age") age: String,
-    @PathVariable country: String
-  ) : Map<*, *> {
-    return mapOf(
-      "name" to name,
-      "age" to age,
-      "country" to country
-    )
-  }
+    @GetMapping(path = ["/endpoint/{country}"])
+    fun getPerson(
+        @RequestParam name: String,
+        @RequestHeader(name = "X-age") age: String,
+        @PathVariable country: String
+    ): Map<*, *> {
+        return mapOf(
+            "name" to name,
+            "age" to age,
+            "country" to country
+        )
+    }
 }

kotlin-dsl/src/main/kotlin/com/baeldung/functional_dsl/router_function/RouterFunction.kt

@@ -11,22 +11,22 @@ import org.springframework.web.servlet.function.ServerResponse
 @SpringBootApplication
 open class Application {
 
-  @Bean
-  open fun configure() : RouterFunction<ServerResponse> {
-    return RouterFunctions.route()
-      .GET("/endpoint/{country}") {
-        ServerResponse.ok().body(
-          mapOf(
-            "name" to it.param("name"),
-            "age" to it.headers().header("X-age")[0],
-            "country" to it.pathVariable("country")
-          )
-        )
-      }
-      .build()
-  }
+    @Bean
+    open fun configure(): RouterFunction<ServerResponse> {
+        return RouterFunctions.route()
+            .GET("/endpoint/{country}") {
+                ServerResponse.ok().body(
+                    mapOf(
+                        "name" to it.param("name"),
+                        "age" to it.headers().header("X-age")[0],
+                        "country" to it.pathVariable("country")
+                    )
+                )
+            }
+            .build()
+    }
 }
 
 fun main(vararg args: String) {
-  runApplication<Application>(*args)
+    runApplication<Application>(*args)
 }

kotlin-dsl/src/main/kotlin/com/baeldung/functional_dsl/router_function_dsl/RouterDsl.kt

@@ -11,24 +11,24 @@ import org.springframework.web.servlet.function.router
 open class Application
 
 fun main(vararg args: String) {
-  runApplication<Application>(*args)
-  {
-    addInitializers(
-      beans {
-        bean {
-          router {
-            GET("/endpoint/{country}") { it : ServerRequest ->
-              ServerResponse.ok().body(
-                mapOf(
-                  "name" to it.param("name"),
-                  "age" to it.headers().header("X-age")[0],
-                  "country" to it.pathVariable("country")
-                )
-              )
+    runApplication<Application>(*args)
+    {
+        addInitializers(
+            beans {
+                bean {
+                    router {
+                        GET("/endpoint/{country}") { it: ServerRequest ->
+                            ServerResponse.ok().body(
+                                mapOf(
+                                    "name" to it.param("name"),
+                                    "age" to it.headers().header("X-age")[0],
+                                    "country" to it.pathVariable("country")
+                                )
+                            )
+                        }
+                    }
+                }
             }
-          }
-        }
-      }
-    )
-  }
+        )
+    }
 }

kotlin-reactive-dsl/src/main/kotlin/com/baeldung/functional_dsl/User.kt

@@ -1,8 +1,8 @@
 package com.baeldung.functional_dsl
 
 class User(
-  var userId: Long,
-  var name: String,
-  var age: Int,
-  var country: String,
+    var userId: Long,
+    var name: String,
+    var age: Int,
+    var country: String,
 )

kotlin-reactive-dsl/src/main/kotlin/com/baeldung/functional_dsl/UsersRepository.kt

@@ -10,38 +10,38 @@ import reactor.core.publisher.Mono
 @Component
 class UsersRepository {
 
-  private val userStorage: MutableMap<Long, User>
+    private val userStorage: MutableMap<Long, User>
 
-  init {
-    userStorage = mutableMapOf(
-      1L to User(1L, "Alex", 18, "Malta"),
-      2L to User(2L, "Eugen", 36, "Austria"),
-      3L to User(3L, "Jenny", 12, "Canada")
-    )
-  }
+    init {
+        userStorage = mutableMapOf(
+            1L to User(1L, "Alex", 18, "Malta"),
+            2L to User(2L, "Eugen", 36, "Austria"),
+            3L to User(3L, "Jenny", 12, "Canada")
+        )
+    }
 
-  fun findUserById(id: Long) : Mono<User> {
-    return Mono
-      .fromCallable { userStorage[id] }
-      .handle { value, sink ->
-        if (value == null) {
-          sink.error(IllegalArgumentException())
-        } else {
-          sink.next(value)
-        }
-      }
-  }
+    fun findUserById(id: Long): Mono<User> {
+        return Mono
+            .fromCallable { userStorage[id] }
+            .handle { value, sink ->
+                if (value == null) {
+                    sink.error(IllegalArgumentException())
+                } else {
+                    sink.next(value)
+                }
+            }
+    }
 
-  fun createUsers(user: Mono<User>) {
-    user.doOnNext {
-      userStorage[it.userId] = it
-    }.subscribe()
-  }
+    fun createUsers(user: Mono<User>) {
+        user.doOnNext {
+            userStorage[it.userId] = it
+        }.subscribe()
+    }
 
-  suspend fun findUserByIdForCoroutines(id: Long) : Flow<User> {
-    return flow {
-      val user = userStorage[id] ?: User(0L, "Name", 0, "USA")
-      emit(user)
+    suspend fun findUserByIdForCoroutines(id: Long): Flow<User> {
+        return flow {
+            val user = userStorage[id] ?: User(0L, "Name", 0, "USA")
+            emit(user)
+        }
     }
-  }
 }

kotlin-reactive-dsl/src/main/kotlin/com/baeldung/functional_dsl/coroutines/CoroutinesConfig.kt

@@ -16,22 +16,22 @@ import org.springframework.web.reactive.function.server.coRouter
 @SpringBootApplication
 open class AppCoroutines {
 
-  @Autowired
-  private lateinit var usersRepository: UsersRepository
+    @Autowired
+    private lateinit var usersRepository: UsersRepository
 
-  @Bean
-  open fun registerForCo() =
-    coRouter {
-      GET("/users/{id}") {
-        println("here we are!")
-        val customers : Flow<User> = usersRepository.findUserByIdForCoroutines(
-          it.pathVariable("id").toLong()
-        )
-        ServerResponse.ok().bodyAndAwait(customers)
-      }
-    }
+    @Bean
+    open fun registerForCo() =
+        coRouter {
+            GET("/users/{id}") {
+                println("here we are!")
+                val customers: Flow<User> = usersRepository.findUserByIdForCoroutines(
+                    it.pathVariable("id").toLong()
+                )
+                ServerResponse.ok().bodyAndAwait(customers)
+            }
+        }
 }
 
 fun main(vararg args: String) {
-  runApplication<AppCoroutines>(*args) {}
+    runApplication<AppCoroutines>(*args) {}
 }

kotlin-reactive-dsl/src/main/kotlin/com/baeldung/functional_dsl/router_function/ReactiveConfig.kt

@@ -17,27 +17,27 @@ import org.springframework.web.reactive.function.server.router
 @SpringBootApplication
 open class ReactiveConfig {
 
-  @Autowired
-  private lateinit var usersRepository: UsersRepository
+    @Autowired
+    private lateinit var usersRepository: UsersRepository
 
-  @Bean
-  open fun configure() : RouterFunction<ServerResponse> {
-    return RouterFunctions.route()
-      .GET("/users/{id}") {
-        ServerResponse
-          .ok()
-          .body(usersRepository.findUserById(it.pathVariable("id").toLong()))
-      }
-      .POST("/create") {
-        usersRepository.createUsers(it.bodyToMono(User::class.java))
-        return@POST ServerResponse
-          .ok()
-          .build()
-      }
-      .build()
-  }
+    @Bean
+    open fun configure(): RouterFunction<ServerResponse> {
+        return RouterFunctions.route()
+            .GET("/users/{id}") {
+                ServerResponse
+                    .ok()
+                    .body(usersRepository.findUserById(it.pathVariable("id").toLong()))
+            }
+            .POST("/create") {
+                usersRepository.createUsers(it.bodyToMono(User::class.java))
+                return@POST ServerResponse
+                    .ok()
+                    .build()
+            }
+            .build()
+    }
 }
 
 fun main(vararg args: String) {
-  runApplication<ReactiveConfig>(*args) {}
+    runApplication<ReactiveConfig>(*args) {}
 }

kotlin-reactive-dsl/src/main/kotlin/com/baeldung/functional_dsl/router_function_dsl/ReactiveDslConfig.kt

@@ -17,26 +17,26 @@ import org.springframework.web.reactive.function.server.router
 @SpringBootApplication
 open class ReactiveDslConfig {
 
-  @Autowired
-  private lateinit var usersRepository: UsersRepository
+    @Autowired
+    private lateinit var usersRepository: UsersRepository
 
-  @Bean
-  open fun endpoints() = router {
-    GET("/users/{id}") {
-      ServerResponse
-        .ok()
-        .body(usersRepository.findUserById(it.pathVariable("id").toLong()))
-    }
+    @Bean
+    open fun endpoints() = router {
+        GET("/users/{id}") {
+            ServerResponse
+                .ok()
+                .body(usersRepository.findUserById(it.pathVariable("id").toLong()))
+        }
 
-    POST("/create") {
-      usersRepository.createUsers(it.bodyToMono(User::class.java))
-      return@POST ServerResponse
-        .ok()
-        .build()
+        POST("/create") {
+            usersRepository.createUsers(it.bodyToMono(User::class.java))
+            return@POST ServerResponse
+                .ok()
+                .build()
+        }
     }
-  }
 }
 
 fun main(vararg args: String) {
-  runApplication<ReactiveDslConfig>(*args) {}
+    runApplication<ReactiveDslConfig>(*args) {}
 }