persistence with postgresql

.gitignore

@@ -4,6 +4,8 @@ target/
 !**/src/main/**/target/
 !**/src/test/**/target/
 
+volumes
+
 ### STS ###
 .apt_generated
 .classpath

api/swagger.yaml

@@ -36,7 +36,7 @@ paths:
               schema:
                 $ref: '#/components/schemas/error'
     post:
-      summary: Creates a new chat group
+      summary: Creates a new group chat
       requestBody:
         content:
           application/json:
@@ -197,13 +197,11 @@ components:
     chatCreation:
       type: object
       properties:
-        dancerIds:
+        participantIds:
           type: array
           items:
             type: string
           example: [ 123, 321 ]
-        type:
-          $ref: '#/components/schemas/chatType'
     chatResponse:
       $ref: '#/components/schemas/detailedChat'
     detailedChat:

pom.xml

@@ -15,6 +15,7 @@
     <description>Demo project for Spring Boot</description>
     <properties>
         <java.version>17</java.version>
+        <liquibase.propertyFile>${project.basedir}/src/main/resources/application.yaml</liquibase.propertyFile>
     </properties>
     <dependencies>
         <dependency>
@@ -82,6 +83,35 @@
         <finalName>chat-dancer</finalName>
 
         <plugins>
+            <plugin>
+                <groupId>org.liquibase</groupId>
+                <artifactId>liquibase-maven-plugin</artifactId>
+                <version>3.8.0</version>
+                <configuration>
+                    <propertyFile>${liquibase.propertyFile}</propertyFile>
+                </configuration>
+                <dependencies>
+                    <dependency>
+                        <groupId>com.h2database</groupId>
+                        <artifactId>h2</artifactId>
+                        <version>1.4.200</version>
+                    </dependency>
+                    <dependency>
+                        <groupId>org.hibernate</groupId>
+                        <artifactId>hibernate-core</artifactId>
+                        <version>5.4.6.Final</version>
+                    </dependency>
+                    <dependency>
+                        <groupId>javax.xml.bind</groupId>
+                        <artifactId>jaxb-api</artifactId>
+                        <version>2.4.0-b180830.0359</version>
+                    </dependency>
+                </dependencies>
+            </plugin>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
             <plugin>
                 <groupId>org.springframework.boot</groupId>
                 <artifactId>spring-boot-maven-plugin</artifactId>

src/main/java/net/dancier/chatdancer/adapter/in/web/GetChatResponseDto.java

@@ -0,0 +1,47 @@
+package net.dancier.chatdancer.adapter.in.web;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.Builder;
+import lombok.Data;
+import net.dancier.chatdancer.application.domain.model.Chat;
+import net.dancier.chatdancer.application.domain.model.Message;
+
+import java.time.OffsetDateTime;
+import java.time.ZoneOffset;
+import java.util.Optional;
+import java.util.Set;
+import java.util.UUID;
+import java.util.stream.Collectors;
+
+@Data
+@Builder
+public class GetChatResponseDto {
+    public static GetChatResponseDto of(Chat chat) {
+        Optional<Message> optionalLastMessage = chat.getMessages().stream().reduce((first, second) -> second);
+        return GetChatResponseDto.builder()
+                .chatId(chat.getChatId().getId())
+                .participantIds(
+                        chat.getChatParticipants().stream()
+                                .map(Chat.ParticipantId::getId).collect(Collectors.toSet())
+                ).createdAt(OffsetDateTime.of(chat.getCreatedAt(), ZoneOffset.UTC))
+                .lastMessage(
+                        MessageDto.of(
+                                chat.getMessages().stream().reduce(
+                                        (first, second) -> second
+                                ).orElse(null)
+                        )
+                ).lastActivity(
+                        optionalLastMessage
+                                .map(m -> OffsetDateTime.of(m.getCreatedAt(), ZoneOffset.UTC))
+                                .orElse(null)
+                )
+                .build();
+    }
+
+    UUID chatId;
+    Set<String> participantIds;
+    OffsetDateTime lastActivity;
+    MessageDto lastMessage;
+    @JsonFormat(shape = JsonFormat.Shape.STRING, pattern = "yyyy-MM-dd'T'HH:mm:ss.SSSXXX")
+    OffsetDateTime createdAt;
+}

src/main/java/net/dancier/chatdancer/adapter/in/web/MessageDto.java

@@ -0,0 +1,33 @@
+package net.dancier.chatdancer.adapter.in.web;
+
+import lombok.Builder;
+import lombok.Data;
+import net.dancier.chatdancer.application.domain.model.Message;
+
+import java.time.OffsetDateTime;
+import java.time.ZoneOffset;
+import java.util.Set;
+
+@Data
+@Builder
+public class MessageDto {
+    public static MessageDto of(Message message) {
+        if (message!=null) {
+            return MessageDto.builder()
+                    .id(message.getId().getValue().toString())
+                    .text(message.getText())
+                    .authorId(message.getAuthorId().toString())
+                    .createdAt(OffsetDateTime.of(message.getCreatedAt(), ZoneOffset.UTC))
+                    .build();
+        } else {
+            return null;
+        }
+    };
+
+    private String text;
+    private String id;
+    private String authorId;
+    private Set<String> readByParticipants;
+    private OffsetDateTime createdAt;
+
+}

src/main/java/net/dancier/chatdancer/adapter/in/web/PostChatMessageRequestDto.java

@@ -0,0 +1,15 @@
+package net.dancier.chatdancer.adapter.in.web;
+
+import jakarta.validation.constraints.NotNull;
+import lombok.Builder;
+import lombok.Data;
+
+import java.util.UUID;
+
+@Data
+@Builder
+public class PostChatMessageRequestDto {
+    @NotNull(message = "The id of the author of the message must be provided")
+    private String authorId;
+    private String text;
+}

src/main/java/net/dancier/chatdancer/adapter/in/web/PostChatRequestDto.java

@@ -0,0 +1,10 @@
+package net.dancier.chatdancer.adapter.in.web;
+
+import lombok.Data;
+
+import java.util.List;
+
+@Data
+public class PostChatRequestDto {
+    private List<String> participantIds;
+}

src/main/java/net/dancier/chatdancer/adapter/in/web/controller/ChatMessageController.java

@@ -0,0 +1,49 @@
+package net.dancier.chatdancer.adapter.in.web.controller;
+
+import lombok.RequiredArgsConstructor;
+import net.dancier.chatdancer.adapter.in.web.MessageDto;
+import net.dancier.chatdancer.adapter.in.web.PostChatMessageRequestDto;
+import net.dancier.chatdancer.application.domain.model.Chat;
+import net.dancier.chatdancer.application.domain.model.Message;
+import net.dancier.chatdancer.application.port.in.MessagesByChatUseCase;
+import net.dancier.chatdancer.application.port.in.PostChatMessageCommand;
+import net.dancier.chatdancer.application.port.in.PostChatMessageUseCase;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.List;
+import java.util.UUID;
+import java.util.stream.Collectors;
+
+@RequiredArgsConstructor
+@RestController
+public class ChatMessageController {
+
+    public static final Logger log = LoggerFactory.getLogger(ChatMessageController.class);
+
+    private final PostChatMessageUseCase postChatMessageUseCase;
+
+    private final MessagesByChatUseCase messagesByChatUseCase;
+
+    @GetMapping("/h/chats/{chatId}/messages")
+    public ResponseEntity<List<MessageDto>> getMessages(@PathVariable UUID chatId) {
+        log.info("Getting all Messages");
+        List<Message> messages = messagesByChatUseCase.byChatId(new Chat.ChatId(chatId));
+        List<MessageDto> messageDtos = messages.stream().map(m -> MessageDto.of(m)).collect(Collectors.toList());
+        return ResponseEntity.ok(messageDtos);
+    }
+
+    @PostMapping("/h/chats/{chatId}/messages")
+    public ResponseEntity postChatMessage(@PathVariable UUID chatId, @Validated @RequestBody PostChatMessageRequestDto postChatMessageRequestDto) {
+        PostChatMessageCommand postChatMessageCommand = new PostChatMessageCommand(
+                postChatMessageRequestDto.getText(),
+                new Message.AuthorId(postChatMessageRequestDto.getAuthorId()),
+                new Chat.ChatId((chatId)));
+        postChatMessageUseCase.post(postChatMessageCommand);
+        return ResponseEntity.status(HttpStatus.CREATED).build();
+    }
+}

src/main/java/net/dancier/chatdancer/adapter/in/web/controller/GetChatController.java

@@ -0,0 +1,34 @@
+package net.dancier.chatdancer.adapter.in.web.controller;
+
+import lombok.RequiredArgsConstructor;
+import net.dancier.chatdancer.adapter.in.web.GetChatResponseDto;
+import net.dancier.chatdancer.application.domain.model.Chat;
+import net.dancier.chatdancer.application.port.in.GetChatUseCase;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+import java.util.UUID;
+
+@RestController
+@RequiredArgsConstructor
+public class GetChatController {
+
+    private final static Logger log = LoggerFactory.getLogger(GetChatController.class);
+    public static final String GET_ENDPOINT = "/h/chats/{id}";
+
+    private final GetChatUseCase getChatUseCase;
+
+    @GetMapping(value = GET_ENDPOINT)
+    public ResponseEntity<GetChatResponseDto> getChat(@PathVariable UUID id) {
+        Chat chat = getChatUseCase.get(new Chat.ChatId(id));
+        GetChatResponseDto getChatResponseDto = GetChatResponseDto.of(chat);
+        return new ResponseEntity(getChatResponseDto, HttpStatus.OK);
+    }
+
+}

src/main/java/net/dancier/chatdancer/adapter/in/web/controller/GetChatsByParticipantsController.java

@@ -0,0 +1,36 @@
+package net.dancier.chatdancer.adapter.in.web.controller;
+
+import lombok.RequiredArgsConstructor;
+import net.dancier.chatdancer.adapter.in.web.GetChatResponseDto;
+import net.dancier.chatdancer.application.domain.model.Chat;
+import net.dancier.chatdancer.application.domain.service.ChatsByParticipantsService;
+import net.dancier.chatdancer.application.port.in.ChatsByParticipantQuery;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.http.HttpStatus;
+import org.springframework.http.ResponseEntity;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+import java.util.stream.Collectors;
+
+@RequiredArgsConstructor
+@RestController
+public class GetChatsByParticipantsController {
+
+    public static final Logger log = LoggerFactory.getLogger(GetChatsByParticipantsController.class);
+
+    private final ChatsByParticipantsService chatsByParticipantsService;
+
+    @GetMapping("/h/chats")
+    public ResponseEntity<List<GetChatResponseDto>> getAllChats(@RequestParam String participantId) {
+        log.info("Getting all Chats for " + participantId);
+        ChatsByParticipantQuery query = new ChatsByParticipantQuery(new Chat.ParticipantId(participantId.toString()));
+        List<Chat> chats = chatsByParticipantsService.load(query);
+        List<GetChatResponseDto> responseList = chats.stream().map(c -> GetChatResponseDto.of(c)).collect(Collectors.toList());
+        return new ResponseEntity<>(responseList, HttpStatus.OK);
+    }
+
+}