rezozo / reactive-hotel-application Goto Github PK

https://github.com/Rezozo/reactive-hotel-application/blob/55629b7ae059f6d0dfd42625f2ebefbccde79302/src/main/kotlin/com/hotel/app/controller/ProfileController.kt#LL24C34-L24C34
/update не нужен, PUT и так подразумевает апдейт

https://github.com/Rezozo/reactive-hotel-application/blob/55629b7ae059f6d0dfd42625f2ebefbccde79302/src/main/kotlin/com/hotel/app/controller/BookingController.kt#LL39C47-L39C47
Не стоит использовать блокирующие операции в реакторе, а .toFuture().get() блокирующая операция, хоть и скрывает это. Пропадает смысл реактивности.
Можно немного переделать метод BookingService#getCost, что бы он принимал в качестве аргументов price, arrivalDate и departureDate и заполнять цену после создания Booking.
Также можно избавиться от вложенности flatMap'ов, воспользовавшись методом Mono.Zip и скопмить ему все методы, которые можно сделать параллельно

https://github.com/Rezozo/reactive-hotel-application/blob/55629b7ae059f6d0dfd42625f2ebefbccde79302/src/main/java/com/hotel/app/repository/ReviewRepository.java#LL32C36-L32C36
Не стоит лишний раз использовать стринг. У тебя всего 3 возможных состояния, ASC,DESC и UNDEFINED, так, что напрашивается енам. Более того, у спринга уже есть все это, смотри Pageable
И еще, спринг дата умеет сам генерить запросы. Т.е. если ты создашь метод Flux<ReviewInfoDto> findAllByRate(long rate,Pageable page) спринг сам создаст нужный запрос и добавит к нему пагинацию. Также можно сделать и Flux<ReviewInfoDto> findAllByRate(long rate,Sort sort)

https://github.com/Rezozo/reactive-hotel-application/blob/55629b7ae059f6d0dfd42625f2ebefbccde79302/src/main/kotlin/com/hotel/app/controller/ProfileController.kt#LL25C1-L25C1
customerService.updateCustomer возвращает мону, которая не будет вызываться, так как на нее некто не подписан. Мона срабатывает только тогда, когда у нее есть хотя бы 1 подписчик. Как правило спринг сам это разруливает и подписывается на контроллере. Внутри контроллеров у спринга уже нет власти и ты должен ему помочь. Т.е. сделать что-то вроде

 usersService.updateById(customer.id, customer.email, customer.fullName)
.then(customerService.updateCustomer(customer))
.thenReturn(ResponseEntity.ok("Success"))

или даже

 Mono.Zip(usersService.updateById(customer.id, customer.email, customer.fullName),
                 customerService.updateCustomer(customer))
                 (unused,unused2)->ResponseEntity.ok("Success"))