Opened /api/catalog/books/{book_id} endpoint for deleting book

pom.xml

@@ -70,6 +70,18 @@
 			<version>2.6.3</version>
 			<scope>test</scope>
 		</dependency>
+		<dependency>
+			<groupId>com.squareup.okhttp3</groupId>
+			<artifactId>okhttp</artifactId>
+			<version>4.0.1</version>
+			<scope>test</scope>
+		</dependency>
+		<dependency>
+			<groupId>com.squareup.okhttp3</groupId>
+			<artifactId>mockwebserver</artifactId>
+			<version>4.0.1</version>
+			<scope>test</scope>
+		</dependency>
 		<dependency>
 			<groupId>org.projectlombok</groupId>
 			<artifactId>lombok</artifactId>

src/main/java/com/productdock/adapter/in/web/DeleteBookApi.java

@@ -0,0 +1,20 @@
+package com.productdock.adapter.in.web;
+
+import com.productdock.application.port.in.DeleteBookUseCase;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.web.bind.annotation.DeleteMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@Slf4j
+@RestController
+@RequestMapping("/api/catalog/books")
+public record DeleteBookApi(DeleteBookUseCase deleteBookUseCase) {
+
+    @DeleteMapping("/{bookId}")
+    public void deleteBook(@PathVariable("bookId") Long bookId){
+        log.debug("DELETE request recieved with book id: {}", bookId);
+        deleteBookUseCase.deleteBook(bookId);
+    }
+}

src/main/java/com/productdock/adapter/in/web/dto/BookRentalStateDto.java

@@ -0,0 +1,8 @@
+package com.productdock.adapter.in.web.dto;
+
+import com.productdock.domain.RentalStatus;
+
+import java.util.Date;
+
+public record BookRentalStateDto (UserProfileDto user, RentalStatus status, Date date){}
+

src/main/java/com/productdock/adapter/in/web/dto/UserProfileDto.java

@@ -0,0 +1,4 @@
+package com.productdock.adapter.in.web.dto;
+
+
+public record UserProfileDto (String fullName, String image, String email) {}

src/main/java/com/productdock/adapter/out/kafka/DeletedBookMessagePublisher.java

@@ -0,0 +1,25 @@
+package com.productdock.adapter.out.kafka;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.productdock.adapter.out.kafka.publisher.KafkaPublisher;
+import com.productdock.application.port.out.messaging.DeleteBookMessagingOutPort;
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Component;
+
+import java.util.concurrent.ExecutionException;
+
+@Component
+@RequiredArgsConstructor
+public class DeletedBookMessagePublisher implements DeleteBookMessagingOutPort {
+
+    @Value("${spring.kafka.topic.delete-book}")
+    private String kafkaTopic;
+    private final KafkaPublisher publisher;
+
+    @Override
+    public void sendMessage(Long bookId) throws ExecutionException, InterruptedException, JsonProcessingException {
+        publisher.sendMessage(bookId, kafkaTopic);
+    }
+
+}

src/main/java/com/productdock/adapter/out/sql/BookPersistenceAdapter.java

@@ -45,6 +45,11 @@ public Book save(Book book) {
         return bookMapper.toDomain(bookRepository.save(bookJpaEntity));
     }
 
+    @Override
+    public void deleteById(Long bookId) {
+        bookRepository.deleteById(bookId);
+    }
+
     private Set<TopicJpaEntity> populateBookTopics(List<Book.Topic> topics) {
         var topicEntities = topicRepository.findByIds(topics.stream().map(Book.Topic::getId).toList());
         if (topics.size() != topicEntities.size())

src/main/java/com/productdock/adapter/out/web/RentalsApi.java

@@ -0,0 +1,55 @@
+package com.productdock.adapter.out.web;
+
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.productdock.adapter.in.web.dto.BookRentalStateDto;
+import com.productdock.application.port.out.web.RentalsClient;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.HttpHeaders;
+import org.springframework.security.core.context.SecurityContextHolder;
+import org.springframework.security.oauth2.jwt.Jwt;
+import org.springframework.stereotype.Component;
+import org.springframework.web.util.DefaultUriBuilderFactory;
+
+import java.io.IOException;
+import java.net.http.HttpClient;
+import java.net.http.HttpRequest;
+import java.net.http.HttpResponse;
+import java.util.Collection;
+import java.util.List;
+
+@Slf4j
+@Component
+public class RentalsApi implements RentalsClient {
+
+    private String rentalsServiceUrl;
+    private HttpClient client = HttpClient.newHttpClient();
+
+    private ObjectMapper objectMapper = new ObjectMapper();
+    @Autowired
+    public RentalsApi(@Value("http://localhost:8083/api/rental/book/") String rentalsServiceUrl) {
+        this.rentalsServiceUrl = rentalsServiceUrl;
+    }
+
+    @Override
+    public Collection<BookRentalStateDto> getRentals(Long bookId) throws IOException, InterruptedException {
+        var jwt = ((Jwt) SecurityContextHolder.getContext().getAuthentication().getCredentials()).getTokenValue();
+        var uri = new DefaultUriBuilderFactory(rentalsServiceUrl)
+                .builder()
+                .path(bookId.toString())
+                .path("/rentals")
+                .build();
+        HttpRequest request = HttpRequest.newBuilder()
+                .uri(uri)
+                .header(HttpHeaders.AUTHORIZATION, "Bearer " + jwt)
+                .GET()
+                .build();
+        HttpResponse<String> response = client.send(request, HttpResponse.BodyHandlers.ofString());
+
+        log.debug("{}", response.body());
+        return objectMapper.readValue(response.body(), new TypeReference<Collection<BookRentalStateDto>>() {
+        });
+    }
+}

src/main/java/com/productdock/application/port/in/DeleteBookUseCase.java

@@ -0,0 +1,6 @@
+package com.productdock.application.port.in;
+
+public interface DeleteBookUseCase {
+
+    void deleteBook(Long bookId);
+}

src/main/java/com/productdock/application/port/out/messaging/DeleteBookMessagingOutPort.java

@@ -0,0 +1,10 @@
+package com.productdock.application.port.out.messaging;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+
+import java.util.concurrent.ExecutionException;
+
+public interface DeleteBookMessagingOutPort {
+    void sendMessage(Long bookId) throws ExecutionException, InterruptedException, JsonProcessingException;
+
+}

src/main/java/com/productdock/application/port/out/persistence/BookPersistenceOutPort.java

@@ -11,4 +11,6 @@ public interface BookPersistenceOutPort {
     Optional<Book> findByTitleAndAuthor(String title, String author);
 
     Book save(Book book);
+
+    void deleteById(Long bookId);
 }

src/main/java/com/productdock/application/port/out/web/RentalsClient.java

@@ -0,0 +1,11 @@
+package com.productdock.application.port.out.web;
+
+import com.productdock.adapter.in.web.dto.BookRentalStateDto;
+
+import java.io.IOException;
+import java.util.Collection;
+
+public interface RentalsClient {
+
+    Collection<BookRentalStateDto> getRentals(Long bookId) throws IOException, InterruptedException;
+}

src/main/java/com/productdock/application/service/DeleteBookService.java

@@ -0,0 +1,50 @@
+package com.productdock.application.service;
+
+import com.productdock.adapter.in.web.dto.BookRentalStateDto;
+import com.productdock.application.port.in.DeleteBookUseCase;
+import com.productdock.application.port.out.messaging.DeleteBookMessagingOutPort;
+import com.productdock.application.port.out.persistence.BookPersistenceOutPort;
+import com.productdock.application.port.out.web.RentalsClient;
+import com.productdock.domain.exception.BookNotFoundException;
+import com.productdock.domain.exception.DeleteBookException;
+import lombok.RequiredArgsConstructor;
+import lombok.SneakyThrows;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class DeleteBookService implements DeleteBookUseCase {
+
+    private final BookPersistenceOutPort bookRepository;
+
+    private final DeleteBookMessagingOutPort deleteBookMessagingOutPort;
+
+    private final RentalsClient rentalsClient;
+
+    @Override
+    @SneakyThrows
+    public void deleteBook(Long bookId) {
+
+        if (bookRepository.findById(bookId).isEmpty()) {
+            throw new BookNotFoundException("Book not found.");
+        }
+        var bookRentals = rentalsClient.getRentals(bookId);
+        if (!bookRentals.isEmpty()) {
+            throw new DeleteBookException(createRentalMessage(bookRentals.stream().findFirst().get()));
+        }
+        bookRepository.deleteById(bookId);
+        deleteBookMessagingOutPort.sendMessage(bookId);
+        log.debug("deleted book with id: {}", bookId);
+    }
+
+    private String createRentalMessage(BookRentalStateDto bookRentals){
+        if(bookRentals.status() == null || bookRentals.user() == null){
+            return "Cannot read rental status.";
+        }
+        String status = bookRentals.status().toString().toLowerCase();
+        String userName = bookRentals.user().fullName();
+        return "Book is " + status + " by " + userName + ".";
+    }
+}

src/main/java/com/productdock/domain/RentalStatus.java

@@ -0,0 +1,6 @@
+package com.productdock.domain;
+
+public enum RentalStatus {
+    RENTED,
+    RESERVED
+}

src/main/java/com/productdock/domain/exception/BookNotFoundException.java

@@ -0,0 +1,10 @@
+package com.productdock.domain.exception;
+
+import org.springframework.http.HttpStatus;
+import org.springframework.web.bind.annotation.ResponseStatus;
+
+@ResponseStatus(code = HttpStatus.NOT_FOUND)
+public class BookNotFoundException extends RuntimeException{
+
+    public BookNotFoundException(String message){ super(message);}
+}

src/main/java/com/productdock/domain/exception/DeleteBookException.java

@@ -0,0 +1,10 @@
+package com.productdock.domain.exception;
+
+import org.springframework.http.HttpStatus;
+import org.springframework.web.bind.annotation.ResponseStatus;
+
+@ResponseStatus(code = HttpStatus.BAD_REQUEST)
+public class DeleteBookException  extends RuntimeException {
+
+    public DeleteBookException(String message){ super(message);}
+}

src/main/resources/application.yaml

@@ -22,6 +22,7 @@ spring:
     topic:
       book-rating: book-rating
       insert-book: insert-book
+      delete-book: delete-book
 
   jpa:
     hibernate:

src/test/java/com/productdock/adapter/in/web/DeleteBookApiShould.java

@@ -0,0 +1,29 @@
+package com.productdock.adapter.in.web;
+
+import com.productdock.application.port.in.DeleteBookUseCase;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+
+import static org.mockito.Mockito.verify;
+
+@ExtendWith(MockitoExtension.class)
+public class DeleteBookApiShould {
+
+    @InjectMocks
+    private DeleteBookApi deleteBookApi;
+    @Mock
+    private DeleteBookUseCase deleteBookUseCase;
+
+    public static final long DEFAULT_BOOK_ID = 1;
+
+    @Test
+    void deleteBook(){
+
+        deleteBookApi.deleteBook(DEFAULT_BOOK_ID);
+
+        verify(deleteBookUseCase).deleteBook(DEFAULT_BOOK_ID);
+    }
+}

src/test/java/com/productdock/adapter/out/kafka/DeleteBookMessagePublisherShould.java

@@ -0,0 +1,31 @@
+package com.productdock.adapter.out.kafka;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.productdock.adapter.out.kafka.publisher.KafkaPublisher;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+
+import java.util.concurrent.ExecutionException;
+
+import static org.mockito.Mockito.verify;
+
+@ExtendWith(MockitoExtension.class)
+public class DeleteBookMessagePublisherShould {
+    public static final long BOOK_ID = 1;
+
+    @InjectMocks
+    private DeletedBookMessagePublisher deletedBookMessagePublisher;
+    @Mock
+    private KafkaPublisher publisher;
+
+    @Test
+    void sendMessage() throws ExecutionException, InterruptedException, JsonProcessingException {
+
+        deletedBookMessagePublisher.sendMessage(BOOK_ID);
+
+        verify(publisher).sendMessage(BOOK_ID, null);
+    }
+}