FEATURE: Film delete API added #4

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

@@ -17,4 +17,7 @@ interface FilmController {
 
     @PostMapping("/save")
     fun saveFilm(@Valid @RequestBody toBeSavedFilm : Film) : Mono<Film>
+
+    @DeleteMapping("/delete/{filmId}")
+    fun deleteFilm(@PathVariable filmId : Int) : Mono<Void>
 }

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

@@ -8,7 +8,6 @@ import org.springframework.web.bind.annotation.ResponseBody
 import org.springframework.web.bind.annotation.RestControllerAdvice
 import org.springframework.web.bind.support.WebExchangeBindException
 import org.springframework.web.server.ServerWebExchange
-import reactor.core.publisher.Flux
 import reactor.core.publisher.Mono
 import reactor.kotlin.core.publisher.toMono
 import java.util.stream.Collectors
@@ -32,4 +31,7 @@ class GlobalExceptionHandler {
         ).toMono()
     }
     // need to implement error logging publish to kafka
+    // detail message = WebExchangeBindException.message
+
+
 }

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

@@ -26,4 +26,8 @@ class FilmControllerImpl(
             .flatMap { toBeSavedFilm.toMono() }
     }
 
+    override fun deleteFilm(filmId : Int) : Mono<Void> {
+        return filmService.deleteFilm(filmId)
+    }
+
 }

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

@@ -22,4 +22,12 @@ class FilmService(
     fun saveFilm(toBeSavedFilm : FilmEntity) : Mono<FilmEntity> {
         return filmRepository.save(toBeSavedFilm);
     }
+
+    fun deleteFilm(filmId : Int) : Mono<Void> {
+        // need to implement cascade delete for table data that set foreign key
+        return filmRepository.findById(filmId)
+            .switchIfEmpty(Mono.error(RuntimeException("Not registered film")))
+            .flatMap { filmRepository.deleteById(filmId) }
+            .then()
+    }
 }