vikasontech

spring:
  data:
    mongodb:
      host: localhost
      port: 27017
      username: root
      password: example
      authentication-database: admin
      database: test

vikasontech

@Service
class LoanDetailServiceImpl(private val loanDetailRepo:  LoanDetailRepo) : LoanDetailService {

    override fun save(loanDetail: LoanDetail): Mono<LoanDetail> {
        return loanDetailRepo.save(loanDetail)

    }
}

vikasontech

@Repository
interface LoanDetailRepo : ReactiveCrudRepository<LoanDetail, String>

vikasontech

@RunWith(SpringRunner::class)
@SpringBootTest
class LoanDetailServiceImplTest {

    @Autowired
    private lateinit var loanDetailService: LoanDetailService

    @Test
    fun `save load detail service`() {
        StepVerifier.create(loanDetailService.save(LoanDetail(_id = "1", loanAmount = BigDecimal.valueOf(100000L),

vikasontech

@Configuration
class MongoContainerInitializer : ApplicationContextInitializer<ConfigurableApplicationContext> {
    val image:String =  "mongo:4.2.0-rc2-bionic"
    override fun initialize(configurableApplicationContext: ConfigurableApplicationContext) {
        val mongoContainer = MongoContainer(image)
        mongoContainer.start()
        val connectURl =  "spring.data.mongodb.uri="+ "mongodb://${mongoContainer.getContainerIpAddress()}:${mongoContainer.getMappedPort(27017)}/test"
        println(">>>>>>>>>>>>>>>>Connection url: $connectURl")
        TestPropertyValues.of(

vikasontech

@Configuration
class MongoContainerInitializer : ApplicationContextInitializer<ConfigurableApplicationContext> {
    val image:String =  "mongo:4.2.0-rc2-bionic"
    override fun initialize(configurableApplicationContext: ConfigurableApplicationContext) {
        val mongoContainer = MongoContainer(image)
        mongoContainer.start()
        val connectURl =  "spring.data.mongodb.uri="+ "mongodb://${mongoContainer.getContainerIpAddress()}:${mongoContainer.getMappedPort(27017)}/test"
        println(">>>>>>>>>>>>>>>>Connection url: $connectURl")
        TestPropertyValues.of(
                "spring.data.mongodb.uri="+ "mongodb://${mongoContainer.getContainerIpAddress()}:${mongoContainer.getMappedPort(27017)}/test"

vikasontech

@Service
class MongoContainer : DockerComposeContainer<MongoContainer>(File("src/test/resources/docker-compose-test.yml")) {
    @PostConstruct
    fun init() {
        this.start()
    }
}

vikasontech

<dependency>
    <groupId>org.testcontainers</groupId>
    <artifactId>testcontainers</artifactId>
    <version>1.12.4</version>
</dependency>

vikasontech

@Document
data class LoanDetail(var _id: String,
                      var loanAmount: BigDecimal,
                      var loanCommencedDate: LocalDate,
                      var interestRate: Float,
                      var numberOfEmi: Int,
                      var emiAmount: BigDecimal)

vikasontech

@RestController
@RequestMapping("/api/v1/loan")
class LoanDetailController () {

	@GetMapping("/detail", produces = [MediaType.TEXT_EVENT_STREAM_VALUE])
	fun getdata():Mono<LoanDetail> {
		return Mono.justOrEmpty(
				LoanDetail(_id = "dummy",
						loanAmount = BigDecimal.valueOf(100_000L),
						emiAmount = BigDecimal.valueOf(1000L),