feat : expose endpoint to save post along with details, comments and tags

jpa/boot-jpa-jooq-sample/pom.xml

@@ -17,6 +17,7 @@
     <properties>
         <java.version>21</java.version>
         <springdoc-openapi.version>2.8.3</springdoc-openapi.version>
+        <org.mapstruct.version>1.6.3</org.mapstruct.version>
         <testcontainers-jooq-codegen-maven-plugin.version>0.0.4</testcontainers-jooq-codegen-maven-plugin.version>
         <spotless.version>2.44.1</spotless.version>
 
@@ -43,6 +44,10 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-web</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-validation</artifactId>
+        </dependency>
 
         <dependency>
             <groupId>org.liquibase</groupId>
@@ -59,6 +64,12 @@
             <version>1.0.6</version>
         </dependency>
 
+        <dependency>
+            <groupId>org.mapstruct</groupId>
+            <artifactId>mapstruct</artifactId>
+            <version>${org.mapstruct.version}</version>
+        </dependency>
+
         <dependency>
             <groupId>org.springdoc</groupId>
             <artifactId>springdoc-openapi-starter-webmvc-ui</artifactId>
@@ -119,6 +130,27 @@
             <plugin>
                 <groupId>org.springframework.boot</groupId>
                 <artifactId>spring-boot-maven-plugin</artifactId>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>build-info</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <configuration>
+                    <annotationProcessorPaths>
+                    <path>
+                        <groupId>org.mapstruct</groupId>
+                        <artifactId>mapstruct-processor</artifactId>
+                        <version>${org.mapstruct.version}</version>
+                    </path>
+                    </annotationProcessorPaths>
+                    <release>${java.version}</release>
+                </configuration>
             </plugin>
             <plugin>
                 <groupId>org.testcontainers</groupId>

jpa/boot-jpa-jooq-sample/src/main/java/com/example/learning/config/GlobalExceptionHandler.java

@@ -0,0 +1,57 @@
+package com.example.learning.config;
+
+import com.example.learning.exception.PostAlreadyExistsException;
+import java.net.URI;
+import java.time.Instant;
+import java.util.Comparator;
+import java.util.List;
+import java.util.Objects;
+import org.springframework.core.Ordered;
+import org.springframework.core.annotation.Order;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.HttpStatusCode;
+import org.springframework.http.ProblemDetail;
+import org.springframework.validation.FieldError;
+import org.springframework.web.bind.MethodArgumentNotValidException;
+import org.springframework.web.bind.annotation.ControllerAdvice;
+import org.springframework.web.bind.annotation.ExceptionHandler;
+import org.springframework.web.bind.annotation.ResponseStatus;
+
+@ControllerAdvice
+@Order(Ordered.HIGHEST_PRECEDENCE)
+public class GlobalExceptionHandler {
+
+    @ExceptionHandler(MethodArgumentNotValidException.class)
+    @ResponseStatus(HttpStatus.BAD_REQUEST)
+    ProblemDetail onException(MethodArgumentNotValidException methodArgumentNotValidException) {
+        ProblemDetail problemDetail =
+                ProblemDetail.forStatusAndDetail(HttpStatusCode.valueOf(400), "Invalid request content.");
+        problemDetail.setTitle("Constraint Violation");
+        List<ApiValidationError> validationErrorsList = methodArgumentNotValidException.getAllErrors().stream()
+                .map(objectError -> {
+                    FieldError fieldError = (FieldError) objectError;
+                    return new ApiValidationError(
+                            fieldError.getObjectName(),
+                            fieldError.getField(),
+                            fieldError.getRejectedValue(),
+                            Objects.requireNonNull(fieldError.getDefaultMessage(), ""));
+                })
+                .sorted(Comparator.comparing(ApiValidationError::field))
+                .toList();
+        problemDetail.setProperty("violations", validationErrorsList);
+        return problemDetail;
+    }
+
+    @ExceptionHandler(PostAlreadyExistsException.class)
+    ProblemDetail onException(PostAlreadyExistsException postAlreadyExistsException) {
+        ProblemDetail problemDetail = ProblemDetail.forStatusAndDetail(
+                postAlreadyExistsException.getHttpStatus(), postAlreadyExistsException.getMessage());
+        problemDetail.setTitle("Duplicate entry");
+        problemDetail.setType(URI.create("https://api.boot-jpa-jooq.com/errors/already-exists"));
+        problemDetail.setProperty("errorCategory", "Generic");
+        problemDetail.setProperty("timestamp", Instant.now().toString());
+        return problemDetail;
+    }
+
+    record ApiValidationError(String object, String field, Object rejectedValue, String message) {}
+}

jpa/boot-jpa-jooq-sample/src/main/java/com/example/learning/entities/PostComment.java

@@ -11,7 +11,7 @@
 import jakarta.persistence.Table;
 import java.io.Serial;
 import java.io.Serializable;
-import java.time.OffsetDateTime;
+import java.time.LocalDateTime;
 import java.util.Objects;
 import org.hibernate.Hibernate;
 
@@ -33,7 +33,7 @@ public class PostComment extends Auditable implements Serializable {
 
     private boolean published;
 
-    private OffsetDateTime publishedAt;
+    private LocalDateTime publishedAt;
 
     @ManyToOne(fetch = FetchType.LAZY)
     @JoinColumn(name = "post_id", nullable = false)
@@ -77,11 +77,11 @@ public PostComment setPublished(boolean published) {
         return this;
     }
 
-    public OffsetDateTime getPublishedAt() {
+    public LocalDateTime getPublishedAt() {
         return publishedAt;
     }
 
-    public PostComment setPublishedAt(OffsetDateTime publishedAt) {
+    public PostComment setPublishedAt(LocalDateTime publishedAt) {
         this.publishedAt = publishedAt;
         return this;
     }

jpa/boot-jpa-jooq-sample/src/main/java/com/example/learning/exception/PostAlreadyExistsException.java

@@ -0,0 +1,19 @@
+package com.example.learning.exception;
+
+import org.springframework.http.HttpStatus;
+import org.springframework.http.HttpStatusCode;
+
+public class PostAlreadyExistsException extends RuntimeException {
+
+    private static final long serialVersionUID = 1L;
+
+    private static final HttpStatus httpStatus = HttpStatus.CONFLICT;
+
+    public PostAlreadyExistsException(String title) {
+        super("Post with title : " + title + " already exists");
+    }
+
+    public HttpStatusCode getHttpStatus() {
+        return httpStatus;
+    }
+}

jpa/boot-jpa-jooq-sample/src/main/java/com/example/learning/mapper/PostMapper.java

@@ -0,0 +1,46 @@
+package com.example.learning.mapper;
+
+import com.example.learning.entities.Post;
+import com.example.learning.entities.PostComment;
+import com.example.learning.entities.Tag;
+import com.example.learning.model.request.PostCommentRequest;
+import com.example.learning.model.request.PostRequest;
+import com.example.learning.model.request.TagRequest;
+import org.mapstruct.CollectionMappingStrategy;
+import org.mapstruct.DecoratedWith;
+import org.mapstruct.InjectionStrategy;
+import org.mapstruct.Mapper;
+import org.mapstruct.Mapping;
+import org.mapstruct.MappingConstants;
+import org.mapstruct.NullValueCheckStrategy;
+
+@Mapper(
+        componentModel = MappingConstants.ComponentModel.SPRING,
+        injectionStrategy = InjectionStrategy.CONSTRUCTOR,
+        nullValueCheckStrategy = NullValueCheckStrategy.ALWAYS,
+        collectionMappingStrategy = CollectionMappingStrategy.ADDER_PREFERRED)
+@DecoratedWith(PostMapperDecorator.class)
+public interface PostMapper {
+
+    Post postRequestToEntity(PostRequest postRequest, String userName);
+
+    @Mapping(target = "modifiedAt", ignore = true)
+    @Mapping(target = "id", ignore = true)
+    @Mapping(target = "createdAt", ignore = true)
+    @Mapping(target = "comments", ignore = true)
+    @Mapping(target = "tags", ignore = true)
+    @Mapping(source = "userName", target = "details.createdBy")
+    Post postDtoToPostIgnoringChild(PostRequest postRequest, String userName);
+
+    @Mapping(target = "post", ignore = true)
+    @Mapping(target = "modifiedAt", ignore = true)
+    @Mapping(target = "id", ignore = true)
+    @Mapping(target = "createdAt", ignore = true)
+    @Mapping(source = "review", target = "content")
+    PostComment postCommentRequestToPostComment(PostCommentRequest postCommentRequest);
+
+    @Mapping(target = "id", ignore = true)
+    @Mapping(source = "name", target = "tagName")
+    @Mapping(source = "description", target = "tagDescription")
+    Tag tagRequestToTag(TagRequest tagRequest);
+}

jpa/boot-jpa-jooq-sample/src/main/java/com/example/learning/mapper/PostMapperDecorator.java

@@ -0,0 +1,66 @@
+package com.example.learning.mapper;
+
+import com.example.learning.entities.Post;
+import com.example.learning.entities.Tag;
+import com.example.learning.model.request.PostCommentRequest;
+import com.example.learning.model.request.PostRequest;
+import com.example.learning.model.request.TagRequest;
+import com.example.learning.repository.TagRepository;
+import java.util.List;
+import java.util.Map;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+import org.springframework.beans.factory.annotation.Autowired;
+
+public abstract class PostMapperDecorator implements PostMapper {
+
+    @Autowired
+    private TagRepository tagRepository;
+
+    @Override
+    public Post postRequestToEntity(PostRequest postRequest, String userName) {
+        if (postRequest == null) {
+            return null;
+        }
+
+        Post post = postDtoToPostIgnoringChild(postRequest, userName);
+        addPostCommentsToPost(postRequest.comments(), post);
+        addPostTagsToPost(postRequest.tags(), post);
+
+        return post;
+    }
+
+    private void addPostTagsToPost(List<TagRequest> tagRequests, Post post) {
+        if (tagRequests == null) {
+            return;
+        }
+
+        Map<String, TagRequest> newTagRequests =
+                tagRequests.stream().collect(Collectors.toMap(TagRequest::name, Function.identity()));
+
+        // Find existing tags in a single query
+        List<Tag> existingTags = tagRepository.findByTagNameIn(newTagRequests.keySet());
+        Map<String, Tag> tagMap = existingTags.stream().collect(Collectors.toMap(Tag::getTagName, Function.identity()));
+
+        // Create new tags in batch
+        List<Tag> newTags = newTagRequests.entrySet().stream()
+                .filter(e -> !tagMap.containsKey(e.getKey()))
+                .map(e -> tagRequestToTag(e.getValue()))
+                .collect(Collectors.toList());
+        if (!newTags.isEmpty()) {
+            tagRepository.saveAll(newTags);
+            newTags.forEach(tag -> tagMap.put(tag.getTagName(), tag));
+        }
+
+        // Associate all tags with the post
+        tagRequests.forEach(tagRequest -> post.addTag(tagMap.get(tagRequest.name())));
+    }
+
+    private void addPostCommentsToPost(List<PostCommentRequest> comments, Post post) {
+        if (comments == null) {
+            return;
+        }
+
+        comments.forEach(comment -> post.addComment(postCommentRequestToPostComment(comment)));
+    }
+}

jpa/boot-jpa-jooq-sample/src/main/java/com/example/learning/model/request/PostCommentRequest.java

@@ -0,0 +1,5 @@
+package com.example.learning.model.request;
+
+import java.time.LocalDateTime;
+
+public record PostCommentRequest(String title, String review, boolean published, LocalDateTime publishedAt) {}

jpa/boot-jpa-jooq-sample/src/main/java/com/example/learning/model/request/PostRequest.java

@@ -0,0 +1,13 @@
+package com.example.learning.model.request;
+
+import jakarta.validation.constraints.NotBlank;
+import java.time.LocalDateTime;
+import java.util.List;
+
+public record PostRequest(
+        @NotBlank(message = "Title of post is mandatory") String title,
+        @NotBlank(message = "Content of post can't be Blank") String content,
+        boolean published,
+        LocalDateTime publishedAt,
+        List<PostCommentRequest> comments,
+        List<TagRequest> tags) {}

jpa/boot-jpa-jooq-sample/src/main/java/com/example/learning/model/request/TagRequest.java

@@ -0,0 +1,3 @@
+package com.example.learning.model.request;
+
+public record TagRequest(String name, String description) {}

jpa/boot-jpa-jooq-sample/src/main/java/com/example/learning/model/response/PostResponse.java

@@ -0,0 +1,3 @@
+package com.example.learning.model.response;
+
+public class PostResponse {}

jpa/boot-jpa-jooq-sample/src/main/java/com/example/learning/repository/PostCommentRepository.java

@@ -0,0 +1,6 @@
+package com.example.learning.repository;
+
+import com.example.learning.entities.PostComment;
+import org.springframework.data.jpa.repository.JpaRepository;
+
+public interface PostCommentRepository extends JpaRepository<PostComment, Long> {}

jpa/boot-jpa-jooq-sample/src/main/java/com/example/learning/repository/PostRepository.java

@@ -1,6 +1,10 @@
 package com.example.learning.repository;
 
 import com.example.learning.entities.Post;
+import java.util.Optional;
 import org.springframework.data.jpa.repository.JpaRepository;
 
-public interface PostRepository extends JpaRepository<Post, Long> {}
+public interface PostRepository extends JpaRepository<Post, Long> {
+
+    Optional<Post> findByTitleIgnoreCase(String title);
+}

jpa/boot-jpa-jooq-sample/src/main/java/com/example/learning/repository/TagRepository.java

@@ -1,6 +1,24 @@
 package com.example.learning.repository;
 
 import com.example.learning.entities.Tag;
+import java.util.List;
+import java.util.Optional;
+import java.util.Set;
 import org.springframework.data.jpa.repository.JpaRepository;
 
-public interface TagRepository extends JpaRepository<Tag, Long> {}
+public interface TagRepository extends JpaRepository<Tag, Long> {
+
+    /**
+     * Finds a tag by its name.
+     * @param tagName the name of the tag to find
+     * @return the tag if found, empty optional otherwise
+     */
+    Optional<Tag> findByTagName(String tagName);
+
+    /**
+     * Finds all tags whose names are in the given set.
+     * @param tagNameSet set of tag names to find
+     * @return list of matching tags
+     */
+    List<Tag> findByTagNameIn(Set<String> tagNameSet);
+}

jpa/boot-jpa-jooq-sample/src/main/java/com/example/learning/service/PostService.java

@@ -0,0 +1,8 @@
+package com.example.learning.service;
+
+import com.example.learning.model.request.PostRequest;
+
+public interface PostService {
+
+    void createPost(PostRequest postRequest, String userName);
+}