Chat 229 typing event

src/main/java/com/chat/yourway/controller/AuthenticationController.java

@@ -15,7 +15,7 @@
 import com.chat.yourway.config.openapi.OpenApiExamples;
 import com.chat.yourway.dto.request.AuthRequestDto;
 import com.chat.yourway.dto.request.ContactRequestDto;
-import com.chat.yourway.dto.response.ApiErrorResponseDto;
+import com.chat.yourway.dto.response.error.ApiErrorResponseDto;
 import com.chat.yourway.dto.response.AuthResponseDto;
 import com.chat.yourway.security.LogoutService;
 import com.chat.yourway.service.interfaces.ActivateAccountService;

src/main/java/com/chat/yourway/controller/ChangePasswordController.java

@@ -3,7 +3,7 @@
 import com.chat.yourway.config.openapi.OpenApiExamples;
 import com.chat.yourway.dto.request.ChangePasswordDto;
 import com.chat.yourway.dto.request.RestorePasswordDto;
-import com.chat.yourway.dto.response.ApiErrorResponseDto;
+import com.chat.yourway.dto.response.error.ApiErrorResponseDto;
 import com.chat.yourway.service.interfaces.ChangePasswordService;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.media.Content;

src/main/java/com/chat/yourway/controller/ContactController.java

@@ -5,7 +5,7 @@
 
 import com.chat.yourway.config.openapi.OpenApiExamples;
 import com.chat.yourway.dto.request.EditContactProfileRequestDto;
-import com.chat.yourway.dto.response.ApiErrorResponseDto;
+import com.chat.yourway.dto.response.error.ApiErrorResponseDto;
 import com.chat.yourway.dto.response.ContactProfileResponseDto;
 import com.chat.yourway.service.interfaces.ContactService;
 import io.swagger.v3.oas.annotations.Operation;

src/main/java/com/chat/yourway/controller/MessageController.java

@@ -4,7 +4,7 @@
 import static com.chat.yourway.config.openapi.OpenApiMessages.MESSAGE_NOT_FOUND;
 import static com.chat.yourway.config.openapi.OpenApiMessages.SUCCESSFULLY_REPORTED_MESSAGE;
 
-import com.chat.yourway.dto.response.ApiErrorResponseDto;
+import com.chat.yourway.dto.response.error.ApiErrorResponseDto;
 import com.chat.yourway.service.interfaces.MessageService;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.media.Content;

src/main/java/com/chat/yourway/controller/TopicController.java

@@ -6,7 +6,7 @@
 
 import com.chat.yourway.dto.request.TopicPrivateRequestDto;
 import com.chat.yourway.dto.request.TopicRequestDto;
-import com.chat.yourway.dto.response.ApiErrorResponseDto;
+import com.chat.yourway.dto.response.error.ApiErrorResponseDto;
 import com.chat.yourway.dto.response.ContactResponseDto;
 import com.chat.yourway.dto.response.TopicInfoResponseDto;
 import com.chat.yourway.dto.response.TopicResponseDto;

src/main/java/com/chat/yourway/controller/TypingController.java

@@ -0,0 +1,21 @@
+package com.chat.yourway.controller;
+
+import com.chat.yourway.service.interfaces.ChatTypingEventService;
+import java.security.Principal;
+import lombok.RequiredArgsConstructor;
+import org.springframework.messaging.handler.annotation.DestinationVariable;
+import org.springframework.messaging.handler.annotation.MessageMapping;
+import org.springframework.stereotype.Controller;
+
+@Controller
+@RequiredArgsConstructor
+public class TypingController {
+
+  private final ChatTypingEventService chatTypingEventService;
+
+  @MessageMapping("/typing/{isTyping}")
+  public void updateTypingEvent(@DestinationVariable boolean isTyping, Principal principal) {
+    String email = principal.getName();
+    chatTypingEventService.updateTypingEvent(isTyping, email);
+  }
+}

src/main/java/com/chat/yourway/dto/response/ApiErrorResponseDto.java → src/main/java/com/chat/yourway/dto/response/error/ApiErrorResponseDto.java

@@ -1,4 +1,4 @@
-package com.chat.yourway.dto.response;
+package com.chat.yourway.dto.response.error;
 
 import io.swagger.v3.oas.annotations.media.Schema;
 import lombok.Getter;

src/main/java/com/chat/yourway/dto/response/MessageErrorResponseDto.java → src/main/java/com/chat/yourway/dto/response/error/MessageErrorResponseDto.java

@@ -1,4 +1,4 @@
-package com.chat.yourway.dto.response;
+package com.chat.yourway.dto.response.error;
 
 import java.time.LocalDateTime;
 import lombok.AllArgsConstructor;

src/main/java/com/chat/yourway/dto/response/LastMessageResponseDto.java → src/main/java/com/chat/yourway/dto/response/notification/LastMessageResponseDto.java

@@ -1,4 +1,4 @@
-package com.chat.yourway.dto.response;
+package com.chat.yourway.dto.response.notification;
 
 import java.time.LocalDateTime;
 import lombok.Getter;

src/main/java/com/chat/yourway/dto/response/MessageNotificationResponseDto.java → src/main/java/com/chat/yourway/dto/response/notification/MessageNotificationResponseDto.java

@@ -1,4 +1,4 @@
-package com.chat.yourway.dto.response;
+package com.chat.yourway.dto.response.notification;
 
 import com.chat.yourway.model.event.EventType;
 import java.time.LocalDateTime;

src/main/java/com/chat/yourway/dto/response/TopicNotificationResponseDto.java → src/main/java/com/chat/yourway/dto/response/notification/TopicNotificationResponseDto.java

@@ -1,4 +1,4 @@
-package com.chat.yourway.dto.response;
+package com.chat.yourway.dto.response.notification;
 
 import lombok.AllArgsConstructor;
 import lombok.Getter;
@@ -19,5 +19,6 @@ public class TopicNotificationResponseDto {
 
   private LastMessageResponseDto lastMessage;
 
+  private TypingEventResponseDto typingEvent;
 
 }

src/main/java/com/chat/yourway/dto/response/notification/TypingEventResponseDto.java

@@ -0,0 +1,20 @@
+package com.chat.yourway.dto.response.notification;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+import lombok.Setter;
+import lombok.ToString;
+
+@AllArgsConstructor
+@NoArgsConstructor
+@Setter
+@Getter
+@ToString
+public class TypingEventResponseDto {
+
+  private String email;
+
+  private boolean isTyping;
+
+}

src/main/java/com/chat/yourway/exception/handler/ApiExceptionHandler.java

@@ -6,7 +6,7 @@
 import static org.springframework.http.HttpStatus.NOT_FOUND;
 import static org.springframework.http.HttpStatus.UNAUTHORIZED;
 
-import com.chat.yourway.dto.response.ApiErrorResponseDto;
+import com.chat.yourway.dto.response.error.ApiErrorResponseDto;
 import com.chat.yourway.exception.ContactAlreadySubscribedToTopicException;
 import com.chat.yourway.exception.ContactEmailNotExist;
 import com.chat.yourway.exception.ContactNotFoundException;

src/main/java/com/chat/yourway/exception/handler/WebsocketExceptionHandler.java

@@ -1,6 +1,6 @@
 package com.chat.yourway.exception.handler;
 
-import com.chat.yourway.dto.response.MessageErrorResponseDto;
+import com.chat.yourway.dto.response.error.MessageErrorResponseDto;
 import com.chat.yourway.exception.MessagePermissionDeniedException;
 import com.chat.yourway.exception.TopicNotFoundException;
 import com.chat.yourway.exception.TopicSubscriberNotFoundException;

src/main/java/com/chat/yourway/listener/StompSubscriptionListener.java

@@ -4,7 +4,8 @@
 import static com.chat.yourway.model.event.EventType.SUBSCRIBED;
 
 import com.chat.yourway.config.websocket.WebsocketProperties;
-import com.chat.yourway.dto.response.LastMessageResponseDto;
+import com.chat.yourway.dto.response.notification.LastMessageResponseDto;
+import com.chat.yourway.dto.response.notification.TypingEventResponseDto;
 import com.chat.yourway.model.event.ContactEvent;
 import com.chat.yourway.service.interfaces.ChatNotificationService;
 import com.chat.yourway.service.interfaces.ContactEventService;
@@ -31,6 +32,7 @@ public class StompSubscriptionListener {
   private final ChatNotificationService chatNotificationService;
 
   private static LastMessageResponseDto lastMessageDto;
+  private static TypingEventResponseDto typingEvent;
   private static final String USER_DESTINATION = "/user";
   private static final String TOPICS_DESTINATION = "/topics";
   private static final String SLASH = "/";
@@ -46,9 +48,11 @@ public void handleWebSocketSubscribeListener(SessionSubscribeEvent event) {
             .getLastMessage();
         int unreadMessages = contactEventService.getByTopicIdAndEmail(getTopicId(event), email)
             .getUnreadMessages();
+        typingEvent = contactEventService.getByTopicIdAndEmail(
+            getTopicId(event), email).getTypingEvent();
 
         var contactEvent = new ContactEvent(email, getTopicId(event), SUBSCRIBED,
-            getTimestamp(event), unreadMessages, lastMessageDto);
+            getTimestamp(event), unreadMessages, lastMessageDto, typingEvent);
         contactEventService.updateEventTypeByEmail(ONLINE, email);
         contactEventService.save(contactEvent);
       }
@@ -75,7 +79,7 @@ public void handleWebSocketUnsubscribeListener(SessionUnsubscribeEvent event) {
     try {
       if (isTopicDestination(destination)) {
         var contactEvent = new ContactEvent(email, getTopicId(event), ONLINE,
-            getTimestamp(event), 0, lastMessageDto);
+            getTimestamp(event), 0, lastMessageDto, typingEvent);
         contactEventService.save(contactEvent);
       }
 

src/main/java/com/chat/yourway/mapper/NotificationMapper.java

@@ -1,7 +1,7 @@
 package com.chat.yourway.mapper;
 
-import com.chat.yourway.dto.response.MessageNotificationResponseDto;
-import com.chat.yourway.dto.response.TopicNotificationResponseDto;
+import com.chat.yourway.dto.response.notification.MessageNotificationResponseDto;
+import com.chat.yourway.dto.response.notification.TopicNotificationResponseDto;
 import com.chat.yourway.model.event.ContactEvent;
 import org.mapstruct.Mapper;
 import org.mapstruct.Mapping;
@@ -17,6 +17,7 @@ public interface NotificationMapper {
   @Mapping(target = "topicId", source = "topicId")
   @Mapping(target = "unreadMessages", source = "unreadMessages")
   @Mapping(target = "lastMessage", source = "lastMessage")
+  @Mapping(target = "typingEvent", source = "typingEvent")
   TopicNotificationResponseDto toTopicNotificationResponseDto(ContactEvent event);
 
 }

src/main/java/com/chat/yourway/model/event/ContactEvent.java

@@ -1,6 +1,7 @@
 package com.chat.yourway.model.event;
 
-import com.chat.yourway.dto.response.LastMessageResponseDto;
+import com.chat.yourway.dto.response.notification.LastMessageResponseDto;
+import com.chat.yourway.dto.response.notification.TypingEventResponseDto;
 import java.time.LocalDateTime;
 import lombok.Getter;
 import lombok.NoArgsConstructor;
@@ -28,17 +29,19 @@ public class ContactEvent {
   private LocalDateTime timestamp;
   private int unreadMessages;
   private LastMessageResponseDto lastMessage;
+  private TypingEventResponseDto typingEvent;
 
 
   public ContactEvent(String email, Integer topicId, EventType eventType, LocalDateTime timestamp,
-      int unreadMessages, LastMessageResponseDto lastMessage) {
+      int unreadMessages, LastMessageResponseDto lastMessage, TypingEventResponseDto typingEvent) {
     this.id = email + "_" + topicId;
     this.email = email;
     this.topicId = topicId;
     this.eventType = eventType;
     this.timestamp = timestamp;
     this.unreadMessages = unreadMessages;
     this.lastMessage = lastMessage;
+    this.typingEvent = typingEvent;
   }
 
 }

src/main/java/com/chat/yourway/service/ChatMessageServiceImpl.java

@@ -4,7 +4,7 @@
 import com.chat.yourway.dto.request.MessagePrivateRequestDto;
 import com.chat.yourway.dto.request.MessagePublicRequestDto;
 import com.chat.yourway.dto.request.PageRequestDto;
-import com.chat.yourway.dto.response.LastMessageResponseDto;
+import com.chat.yourway.dto.response.notification.LastMessageResponseDto;
 import com.chat.yourway.dto.response.MessageResponseDto;
 import com.chat.yourway.service.interfaces.ChatMessageService;
 import com.chat.yourway.service.interfaces.ChatNotificationService;

src/main/java/com/chat/yourway/service/ChatTypingEventServiceImpl.java

@@ -0,0 +1,32 @@
+package com.chat.yourway.service;
+
+import com.chat.yourway.model.event.EventType;
+import com.chat.yourway.service.interfaces.ChatNotificationService;
+import com.chat.yourway.service.interfaces.ChatTypingEventService;
+import com.chat.yourway.service.interfaces.ContactEventService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Service;
+
+@Service
+@RequiredArgsConstructor
+@Slf4j
+public class ChatTypingEventServiceImpl implements ChatTypingEventService {
+
+  private final ContactEventService contactEventService;
+  private final ChatNotificationService chatNotificationService;
+
+  @Override
+  public void updateTypingEvent(Boolean isTyping, String email) {
+    log.info("Start updateTypingEvent isTyping={}, email={}", isTyping, email);
+    contactEventService.updateTypingEvent(email, isTyping);
+
+    Integer topicId = contactEventService.getAllByEmail(email).stream()
+        .filter(e -> e.getEventType().equals(EventType.SUBSCRIBED))
+        .findFirst()
+        .orElseThrow()
+        .getTopicId();
+
+    chatNotificationService.updateNotificationForAllWhoSubscribedToTopic(topicId);
+  }
+}

src/main/java/com/chat/yourway/service/ContactEventServiceImpl.java

@@ -3,7 +3,8 @@
 import static com.chat.yourway.model.event.EventType.ONLINE;
 import static com.chat.yourway.model.event.EventType.SUBSCRIBED;
 
-import com.chat.yourway.dto.response.LastMessageResponseDto;
+import com.chat.yourway.dto.response.notification.LastMessageResponseDto;
+import com.chat.yourway.dto.response.notification.TypingEventResponseDto;
 import com.chat.yourway.model.event.ContactEvent;
 import com.chat.yourway.model.event.EventType;
 import com.chat.yourway.repository.ContactEventRedisRepository;
@@ -32,7 +33,7 @@ public ContactEvent getByTopicIdAndEmail(Integer topicId, String email) {
     log.trace("Started getByTopicIdAndEmail, topicId [{}], email [{}]", topicId, email);
 
     return contactEventRedisRepository.findById(email + "_" + topicId)
-        .orElse(new ContactEvent(email, topicId, ONLINE, LocalDateTime.now(), 0, null));
+        .orElse(new ContactEvent(email, topicId, ONLINE, LocalDateTime.now(), 0, null, null));
   }
 
   @Override
@@ -81,4 +82,22 @@ public void updateMessageInfoForAllTopicSubscribers(Integer topicId,
     contactEventRedisRepository.saveAll(events);
   }
 
+  @Override
+  public void updateTypingEvent(String email, boolean isTyping) {
+
+    Integer topicId = getAllByEmail(email).stream()
+        .filter(e -> e.getEventType().equals(EventType.SUBSCRIBED))
+        .findFirst()
+        .orElseThrow()
+        .getTopicId();
+
+    getAllByTopicId(topicId)
+        .forEach(event -> {
+          event.setTypingEvent(new TypingEventResponseDto(email, isTyping));
+          contactEventRedisRepository.save(event);
+        });
+
+
+  }
+
 }

src/main/java/com/chat/yourway/service/NotificationServiceImpl.java

@@ -1,7 +1,7 @@
 package com.chat.yourway.service;
 
-import com.chat.yourway.dto.response.MessageNotificationResponseDto;
-import com.chat.yourway.dto.response.TopicNotificationResponseDto;
+import com.chat.yourway.dto.response.notification.MessageNotificationResponseDto;
+import com.chat.yourway.dto.response.notification.TopicNotificationResponseDto;
 import com.chat.yourway.mapper.NotificationMapper;
 import com.chat.yourway.model.event.ContactEvent;
 import com.chat.yourway.service.interfaces.ContactEventService;

src/main/java/com/chat/yourway/service/interfaces/ChatTypingEventService.java

@@ -0,0 +1,13 @@
+package com.chat.yourway.service.interfaces;
+
+public interface ChatTypingEventService {
+
+  /**
+   * Update typing event by user email.
+   *
+   * @param isTyping typing status.
+   * @param email    user email.
+   */
+  void updateTypingEvent(Boolean isTyping, String email);
+
+}

src/main/java/com/chat/yourway/service/interfaces/ContactEventService.java

@@ -1,6 +1,6 @@
 package com.chat.yourway.service.interfaces;
 
-import com.chat.yourway.dto.response.LastMessageResponseDto;
+import com.chat.yourway.dto.response.notification.LastMessageResponseDto;
 import com.chat.yourway.model.event.ContactEvent;
 import com.chat.yourway.model.event.EventType;
 import java.util.List;
@@ -18,7 +18,7 @@ public interface ContactEventService {
    * Get contact event by topic id and contact email.
    *
    * @param topicId topic id.
-   * @param email contact email.
+   * @param email   contact email.
    * @return contact event.
    */
   ContactEvent getByTopicIdAndEmail(Integer topicId, String email);
@@ -44,9 +44,18 @@ public interface ContactEventService {
   /**
    * Set last message to all topic subscribers events.
    *
-   * @param topicId topic id.
+   * @param topicId        topic id.
    * @param lastMessageDto last message Dto.
    */
-  void updateMessageInfoForAllTopicSubscribers(Integer topicId, LastMessageResponseDto lastMessageDto);
+  void updateMessageInfoForAllTopicSubscribers(Integer topicId,
+      LastMessageResponseDto lastMessageDto);
+
+  /**
+   * Update typing status.
+   *
+   * @param email    user email.
+   * @param isTyping typing status.
+   */
+  void updateTypingEvent(String email, boolean isTyping);
 
 }

src/main/java/com/chat/yourway/service/interfaces/NotificationService.java

@@ -1,7 +1,7 @@
 package com.chat.yourway.service.interfaces;
 
-import com.chat.yourway.dto.response.MessageNotificationResponseDto;
-import com.chat.yourway.dto.response.TopicNotificationResponseDto;
+import com.chat.yourway.dto.response.notification.MessageNotificationResponseDto;
+import com.chat.yourway.dto.response.notification.TopicNotificationResponseDto;
 import java.util.List;
 
 public interface NotificationService {