FunctionalReactiveHttpApplication.kt

FunctionalReactiveHttpApplication.kt

package com.example.reactive

import org.reactivestreams.Publisher
import org.springframework.boot.autoconfigure.SpringBootApplication
import org.springframework.boot.builder.SpringApplicationBuilder
import org.springframework.cloud.gateway.handler.predicate.RoutePredicates.path
import org.springframework.cloud.gateway.route.gateway
import org.springframework.context.support.beans
import org.springframework.data.annotation.Id
import org.springframework.data.mongodb.core.mapping.Document
import org.springframework.data.mongodb.repository.ReactiveMongoRepository
import org.springframework.web.reactive.function.server.ServerResponse
import org.springframework.web.reactive.function.server.body
import org.springframework.web.reactive.function.server.router
import reactor.core.publisher.toFlux

@SpringBootApplication
class FunctionalReactiveHttpApplication

fun main(args: Array<String>) {
    SpringApplicationBuilder()
            .sources(FunctionalReactiveHttpApplication::class.java)
            .initializers(beans {
                bean {
                    router {
                        val customerRepository = ref<CustomerRepository>()
                        GET("/customers") { ServerResponse.ok().body(customerRepository.findAll()) }
                        GET("/customers/{id}") { ServerResponse.ok().body(customerRepository.findById(it.pathVariable("id"))) }
                    }
                }
            })
            .run(*args)
}


interface CustomerRepository : ReactiveMongoRepository<Customer, String>

@Document
data class Customer(@Id val id: String, val name: String)