FEATURE : add pagination for load film informations #4

Author: stephano-tri

docker-compose.yml

@@ -45,7 +45,7 @@ services:
     environment:
       - POSTGRESQL_REPLICATION_MODE=slave
       - POSTGRESQL_REPLICATION_USER=repl_user
-      - POSTGRESQL_REPLICATION_PASSWORD=repl_password
+      - POSTGRESQL_REPLICATION_PASSWORD=repl_cpassword
       - POSTGRESQL_MASTER_HOST=postgresql-main
       - POSTGRESQL_MASTER_PORT_NUMBER=5432
       - POSTGRESQL_USERNAME=my_user

hs_err_pid20680.log

@@ -14,7 +14,7 @@ interface FilmController {
     fun getAllFilms() : Mono<List<Film>>
 
     @GetMapping("/list/{page}/{limit}")
-    fun getFilms(@PathVariable page: Long, @PathVariable limit: Long) : Mono<PaginatedResponse<List<Film>>>
+    fun getFilms(@PathVariable page: Long, @PathVariable limit: Long) : Mono<PaginatedResponse<Film>>
 
     @PutMapping("/modify")
     fun modifyFilm(@RequestBody updatedFilm : Film) : Mono<Film>

replay_pid20680.log

@@ -3,6 +3,7 @@ package eom.improve.kafkaboot.service
 import eom.improve.kafkaboot.common.PaginatedResponse
 import eom.improve.kafkaboot.controller.FilmController
 import eom.improve.kafkaboot.dto.Film
+import org.springframework.data.domain.PageRequest
 import org.springframework.stereotype.Service
 import reactor.core.publisher.Mono
 import reactor.kotlin.core.publisher.toMono
@@ -17,7 +18,17 @@ class FilmControllerImpl(
             .collectSortedList((Comparator<Film> { o1, o2 -> o1.filmId.compareTo(o2.filmId) }))
     }
 
-    override fun getFilms(page: Long, limit: Long): Mono<PaginatedResponse<List<Film>>> {
+    override fun getFilms(page: Long, limit: Long): Mono<PaginatedResponse<Film>> {
+        return filmService.findAllByPageable(PageRequest.of(page.toInt(), limit.toInt()))
+            .map { it.convert2Pojo() }
+            .collectList()
+            .flatMap { films ->
+                PaginatedResponse(
+                    response = films,
+                    currentPage = page,
+                    totalPages = (films.size / limit).toLong()
+                ).toMono()
+            }
     }
 
     override fun modifyFilm(updatedFilm : Film) : Mono<Film> {

src/main/kotlin/eom/improve/kafkaboot/controller/FilmController.kt

@@ -1,7 +1,10 @@
 package eom.improve.kafkaboot.service
 
 import eom.improve.kafkaboot.model.FilmEntity
+import eom.improve.kafkaboot.model.InventoryEntity
+import eom.improve.kafkaboot.model.RentalEntity
 import eom.improve.kafkaboot.repository.*
+import org.springframework.data.domain.Pageable
 import org.springframework.stereotype.Service
 import reactor.core.publisher.Flux
 import reactor.core.publisher.Mono
@@ -17,6 +20,9 @@ class FilmService(
     private val filmActorRepository: FilmActorRepository,
     private val filmCategoryRepository: FilmCategoryRepository
 ) {
+
+    fun findAllByPageable(pageable: Pageable) : Flux<FilmEntity> = filmRepository.findAllBy(pageable)
+
     fun findAll() : Flux<FilmEntity> = filmRepository.findAllBy()
 
     fun updateFilm(updatedFilm : FilmEntity) : Mono<FilmEntity> {
@@ -34,31 +40,31 @@ class FilmService(
         return filmRepository.findById(filmId)
             .switchIfEmpty(RuntimeException("Not registered film").toMono())
             .flatMap { filmEn ->
-                 inventoryRepository.findAllByFilmId(filmEn.filmId)
-                     .flatMap { inventoryEn ->
-                         rentalRepository.findAllByInventoryId(inventoryEn.inventoryId)
-                             .flatMap { rentalEn ->
-                                 paymentRepository.findAllByRentalId(rentalEn.rentalId)
-                                     .flatMap { paymentEn ->
-                                            paymentRepository.deleteByPaymentId(paymentEn.paymentId)
-                                     }
-                                     .then(rentalEn.toMono())
-                             }
-                             .flatMap { rentalEn ->
+                inventoryRepository.findAllByFilmId(filmEn.filmId)
+                    .flatMap { inventoryEn ->
+                        rentalRepository.findAllByInventoryId(inventoryEn.inventoryId)
+                            .flatMap { rentalEn ->
+                                paymentRepository.findAllByRentalId(rentalEn.rentalId)
+                                    .flatMap { paymentEn ->
+                                        paymentRepository.deleteByPaymentId(paymentEn.paymentId)
+                                    }
+                                    .then(rentalEn.toMono())
+                            }
+                            .flatMap { rentalEn ->
                                 rentalRepository.deleteByRentalId(rentalEn.rentalId)
-                             }.then(inventoryEn.toMono())
-                     }
-                     .flatMap { inventoryEn ->
-                         inventoryRepository.deleteByInventoryId(inventoryEn.inventoryId)
-                     }
-                     .then(filmEn.toMono())
+                            }.then(inventoryEn.toMono())
+                    }
+                    .flatMap { inventoryEn ->
+                        inventoryRepository.deleteByInventoryId(inventoryEn.inventoryId)
+                    }
+                    .then(filmEn.toMono())
             }
             .flatMap { filmEn ->
                 Mono.zip(
                     filmActorRepository.findAllByFilmId(filmEn.filmId)
                         .flatMap { filmActorRepository.deleteByFilmId(it.filmId) }
                         .then()
-                        ,
+                    ,
                     filmCategoryRepository.findAllByFilmId(filmEn.filmId)
                         .flatMap { filmCategoryRepository.deleteByFilmId(it.filmId) }
                         .then()

src/main/kotlin/eom/improve/kafkaboot/service/FilmControllerImpl.kt

@@ -1,8 +1,8 @@
 spring:
   r2dbc:
     url: r2dbc:postgresql://localhost:5432/dvdrental
-    username: postgres
-    password: example
+    username: my_user
+    password: my_password
 
 #kafka
   kafka:
@@ -20,3 +20,6 @@ spring:
         spring.json.use.type.headers: false
     properties:
       spring.json.trusted.packages: '*'
+
+server:
+  port: 7477