cập nhật status người dùng

connexa-parent/connexa-web/docs/chat/API_DOCS_CHAT.md

@@ -136,11 +136,24 @@ Response `201 Created`: cung shape voi `ConversationResponseDTO`.
 
 Response `200 OK`: `CursorSliceResponse<ConversationResponseDTO>`.
 
+`ConversationMemberResponseDTO` trong response co kem presence fields de
+frontend khong can goi them request khi vao man chat:
+
+```json
+{
+  "userId": 12,
+  "online": true,
+  "activeSessionCount": 1,
+  "lastSeenAt": "2026-04-30T04:30:00Z"
+}
+```
+
 ### 1.4 Lay chi tiet conversation
 
 `GET /api/chat/conversations/{conversationId}`
 
-Response `200 OK`: `ConversationResponseDTO`.
+Response `200 OK`: `ConversationResponseDTO`, member list cung co presence
+fields `online`, `activeSessionCount`, `lastSeenAt`.
 
 ### 1.5 Cap nhat group conversation
 
@@ -372,6 +385,47 @@ hoac
 `messageId` is treated as a conversation checkpoint: all previous messages in
 the same conversation for the same user are also marked delivered and seen.
 
+### 2.8 My presence
+
+`GET /api/chat/presence/me`
+
+Response:
+
+```json
+{
+  "userId": 12,
+  "online": true,
+  "activeSessionCount": 1,
+  "lastSeenAt": "2026-04-30T04:30:00Z"
+}
+```
+
+### 2.9 Conversation presence
+
+`GET /api/chat/conversations/{conversationId}/presence`
+
+Response:
+
+```json
+[
+  {
+    "userId": 12,
+    "online": true,
+    "activeSessionCount": 1,
+    "lastSeenAt": "2026-04-30T04:30:00Z"
+  }
+]
+```
+
+WebSocket heartbeat destination:
+
+```text
+/app/chat.heartbeat
+```
+
+Heartbeat chi gia han Redis presence session. No khong cap nhat delivered hay
+seen.
+
 ## 3. Chat Attachment APIs
 
 ### 3.1 Presign upload

connexa-parent/connexa-web/src/main/java/org/connexa/connexaweb/chat/ConversationMemberResponseDTO.java

@@ -27,4 +27,7 @@ public class ConversationMemberResponseDTO {
     private Instant leftAt;
     private Boolean isMuted;
     private Integer lastReadMessageId;
+    private Boolean online;
+    private Integer activeSessionCount;
+    private Instant lastSeenAt;
 }

connexa-parent/connexa-web/src/main/java/org/connexa/connexaweb/chat/impl/ChatServiceImpl.java

@@ -34,6 +34,8 @@ import org.connexa.connexaweb.chat.MessageResponseDTO;
 import org.connexa.connexaweb.chat.SendMessageRequestDTO;
 import org.connexa.connexaweb.chat.UpdateGroupConversationRequestDTO;
 import org.connexa.connexaweb.chat.UpdateMessageRequestDTO;
+import org.connexa.connexaweb.chat.realtime.ChatPresenceService;
+import org.connexa.connexaweb.chat.realtime.ChatPresenceService.ChatPresenceSnapshot;
 import org.connexa.connexaweb.chat.websocket.MessageReceiptEventResponse;
 import org.connexa.connexaweb.follow.CursorSliceResponse;
 import org.connexa.connexaweb.imagekit.MediaRepository;
@@ -69,6 +71,7 @@ public class ChatServiceImpl implements ChatService {
     private final MessageReceiptRepository messageReceiptRepository;
     private final UserRepository userRepository;
     private final MediaRepository mediaRepository;
+    private final ChatPresenceService chatPresenceService;
 
     public ChatServiceImpl(
             ConversationRepository conversationRepository,
@@ -77,7 +80,8 @@ public class ChatServiceImpl implements ChatService {
             MessageAttachmentRepository messageAttachmentRepository,
             MessageReceiptRepository messageReceiptRepository,
             UserRepository userRepository,
-            MediaRepository mediaRepository
+            MediaRepository mediaRepository,
+            ChatPresenceService chatPresenceService
     ) {
         this.conversationRepository = conversationRepository;
         this.conversationMemberRepository = conversationMemberRepository;
@@ -86,6 +90,7 @@ public class ChatServiceImpl implements ChatService {
         this.messageReceiptRepository = messageReceiptRepository;
         this.userRepository = userRepository;
         this.mediaRepository = mediaRepository;
+        this.chatPresenceService = chatPresenceService;
     }
 
     @Override
@@ -739,10 +744,16 @@ public class ChatServiceImpl implements ChatService {
         Map<Integer, UserProfile> usersById = new HashMap<>();
         userRepository.findAllById(members.stream().map(ConversationMember::getUserId).toList())
                 .forEach(user -> usersById.put(user.getId(), user));
+        Map<Integer, ChatPresenceSnapshot> presenceByUserId =
+                chatPresenceService.getPresence(members.stream().map(ConversationMember::getUserId).toList());
 
         return members.stream()
                 .map(member -> {
                     UserProfile user = usersById.get(member.getUserId());
+                    ChatPresenceSnapshot presence = presenceByUserId.getOrDefault(
+                            member.getUserId(),
+                            ChatPresenceSnapshot.offline(member.getUserId())
+                    );
                     return ConversationMemberResponseDTO.builder()
                             .id(member.getId())
                             .userId(member.getUserId())
@@ -755,6 +766,9 @@ public class ChatServiceImpl implements ChatService {
                             .leftAt(member.getLeftAt())
                             .isMuted(member.getIsMuted())
                             .lastReadMessageId(member.getLastReadMessageId())
+                            .online(presence.online())
+                            .activeSessionCount(presence.activeSessionCount())
+                            .lastSeenAt(presence.lastSeenAt())
                             .build();
                 })
                 .toList();

connexa-parent/connexa-web/src/main/java/org/connexa/connexaweb/chat/realtime/ChatPresenceService.java

@@ -1,12 +1,21 @@
 package org.connexa.connexaweb.chat.realtime;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.data.redis.core.StringRedisTemplate;
 import org.springframework.stereotype.Service;
 
 import java.time.Duration;
+import java.time.Instant;
+import java.util.Collection;
+import java.util.HashMap;
+import java.util.Map;
+import java.util.Set;
 
 @Service
 public class ChatPresenceService {
+    private static final Logger LOGGER = LoggerFactory.getLogger(ChatPresenceService.class);
+
     private final StringRedisTemplate stringRedisTemplate;
     private final ChatRealtimeProperties realtimeProperties;
 
@@ -20,9 +29,17 @@ public class ChatPresenceService {
             return;
         }
 
-        Duration ttl = Duration.ofSeconds(realtimeProperties.getRedis().getSessionTtlSeconds());
-        stringRedisTemplate.opsForValue().set(sessionKey(sessionId), String.valueOf(userId), ttl);
-        stringRedisTemplate.opsForValue().set(userSessionKey(userId, sessionId), "1", ttl);
+        try {
+            Duration ttl = Duration.ofSeconds(realtimeProperties.getRedis().getSessionTtlSeconds());
+            Instant now = Instant.now();
+            stringRedisTemplate.opsForValue().set(sessionKey(sessionId), String.valueOf(userId), ttl);
+            stringRedisTemplate.opsForValue().set(userSessionKey(userId, sessionId), "1", ttl);
+            stringRedisTemplate.opsForSet().add(userSessionsKey(userId), sessionId);
+            stringRedisTemplate.expire(userSessionsKey(userId), ttl);
+            stringRedisTemplate.opsForValue().set(lastSeenKey(userId), String.valueOf(now.toEpochMilli()));
+        } catch (RuntimeException ex) {
+            LOGGER.warn("Unable to touch chat presence session: userId={}, sessionId={}", userId, sessionId, ex);
+        }
     }
 
     public void removeSession(String sessionId) {
@@ -30,12 +47,83 @@ public class ChatPresenceService {
             return;
         }
 
-        String sessionKey = sessionKey(sessionId);
-        String userId = stringRedisTemplate.opsForValue().get(sessionKey);
-        if (userId != null && !userId.isBlank()) {
-            stringRedisTemplate.delete(userSessionKey(userId, sessionId));
+        try {
+            String sessionKey = sessionKey(sessionId);
+            String userId = stringRedisTemplate.opsForValue().get(sessionKey);
+            if (userId != null && !userId.isBlank()) {
+                stringRedisTemplate.delete(userSessionKey(userId, sessionId));
+                stringRedisTemplate.opsForSet().remove(userSessionsKey(userId), sessionId);
+                stringRedisTemplate.opsForValue().set(lastSeenKey(userId), String.valueOf(Instant.now().toEpochMilli()));
+            }
+            stringRedisTemplate.delete(sessionKey);
+        } catch (RuntimeException ex) {
+            LOGGER.warn("Unable to remove chat presence session: sessionId={}", sessionId, ex);
+        }
+    }
+
+    public boolean isOnline(Integer userId) {
+        return getPresence(userId).online();
+    }
+
+    public ChatPresenceSnapshot getPresence(Integer userId) {
+        if (!realtimeProperties.getRedis().isEnabled() || userId == null) {
+            return ChatPresenceSnapshot.offline(userId);
+        }
+
+        try {
+            int activeSessionCount = countActiveSessions(userId);
+            return new ChatPresenceSnapshot(
+                    userId,
+                    activeSessionCount > 0,
+                    activeSessionCount,
+                    readLastSeenAt(userId)
+            );
+        } catch (RuntimeException ex) {
+            LOGGER.warn("Unable to read chat presence: userId={}", userId, ex);
+            return ChatPresenceSnapshot.offline(userId);
+        }
+    }
+
+    public Map<Integer, ChatPresenceSnapshot> getPresence(Collection<Integer> userIds) {
+        Map<Integer, ChatPresenceSnapshot> snapshots = new HashMap<>();
+        if (userIds == null || userIds.isEmpty()) {
+            return snapshots;
+        }
+
+        for (Integer userId : userIds) {
+            snapshots.put(userId, getPresence(userId));
+        }
+        return snapshots;
+    }
+
+    private int countActiveSessions(Integer userId) {
+        Set<String> sessionIds = stringRedisTemplate.opsForSet().members(userSessionsKey(userId));
+        if (sessionIds == null || sessionIds.isEmpty()) {
+            return 0;
+        }
+
+        int activeSessionCount = 0;
+        for (String sessionId : sessionIds) {
+            if (Boolean.TRUE.equals(stringRedisTemplate.hasKey(sessionKey(sessionId)))) {
+                activeSessionCount++;
+            } else {
+                stringRedisTemplate.opsForSet().remove(userSessionsKey(userId), sessionId);
+                stringRedisTemplate.delete(userSessionKey(userId, sessionId));
+            }
+        }
+        return activeSessionCount;
+    }
+
+    private Instant readLastSeenAt(Integer userId) {
+        String rawLastSeenAt = stringRedisTemplate.opsForValue().get(lastSeenKey(userId));
+        if (rawLastSeenAt == null || rawLastSeenAt.isBlank()) {
+            return null;
+        }
+        try {
+            return Instant.ofEpochMilli(Long.parseLong(rawLastSeenAt));
+        } catch (NumberFormatException ex) {
+            return null;
         }
-        stringRedisTemplate.delete(sessionKey);
     }
 
     private String sessionKey(String sessionId) {
@@ -49,4 +137,31 @@ public class ChatPresenceService {
     private String userSessionKey(String userId, String sessionId) {
         return realtimeProperties.getRedis().getKeyPrefix() + ":user:" + userId + ":" + sessionId;
     }
+
+    private String userSessionsKey(Integer userId) {
+        return userSessionsKey(String.valueOf(userId));
+    }
+
+    private String userSessionsKey(String userId) {
+        return realtimeProperties.getRedis().getKeyPrefix() + ":user:" + userId + ":sessions";
+    }
+
+    private String lastSeenKey(Integer userId) {
+        return lastSeenKey(String.valueOf(userId));
+    }
+
+    private String lastSeenKey(String userId) {
+        return realtimeProperties.getRedis().getKeyPrefix() + ":user:" + userId + ":last_seen";
+    }
+
+    public record ChatPresenceSnapshot(
+            Integer userId,
+            boolean online,
+            int activeSessionCount,
+            Instant lastSeenAt
+    ) {
+        public static ChatPresenceSnapshot offline(Integer userId) {
+            return new ChatPresenceSnapshot(userId, false, 0, null);
+        }
+    }
 }

doc/README.md

@@ -9,6 +9,7 @@ Cac tai lieu chinh:
 - [chat-message-media-contract.md](chat-message-media-contract.md): contract rieng cho message dang image, video, file va audio.
 - [chat-websocket-event-classification.md](chat-websocket-event-classification.md): phan loai cac luong WebSocket cho gui tin, xem tin va receipt/typing.
 - [chat-frontend-reconnect.md](chat-frontend-reconnect.md): huong dan frontend reconnect WebSocket/STOMP, sync backlog va ack delivered/seen.
+- [chat-presence-architecture.md](chat-presence-architecture.md): kien truc online/presence bang Redis session TTL, heartbeat va API query presence.
 - [chat-lexical-json-contract.md](chat-lexical-json-contract.md): chuan JSON noi dung chat theo huong Lexical, bam theo cach Post dang luu `contentJSON`.
 - [chat-test-spec.md](chat-test-spec.md): du lieu mau, input/output, vi du va test case cho toan bo phan chat.
 - [chat-frontend-integration.md](chat-frontend-integration.md): huong dan frontend web goi API, connect WebSocket/STOMP va upload attachment.
@@ -18,4 +19,4 @@ Quy uoc da chot:
 - Chat media chi dung Cloudflare R2.
 - Backend chi presign upload/access URL, client upload truc tiep len R2.
 - Noi dung text cua message dung `contentJSON` dang Lexical JSON, con `content` la plain text duoc backend trich xuat de search/preview.
-- Giai doan hien tai chua dung Redis.
+- Redis duoc dung cho chat presence/session TTL; khong dung Redis de quyet dinh delivered.

doc/chat-frontend-integration.md

@@ -89,6 +89,21 @@ User-level:
 /user/queue/receipts
 ```
 
+Conversation/member response tra kem presence:
+
+```json
+{
+  "userId": 12,
+  "online": true,
+  "activeSessionCount": 1,
+  "lastSeenAt": "2026-04-30T04:30:00Z"
+}
+```
+
+Frontend nen dung presence trong response nay khi vao man chat de tranh goi
+them request. Endpoint `/api/chat/conversations/{conversationId}/presence` chi
+can dung khi muon refresh/poll trang thai online ma khong reload conversation.
+
 ## 4. Authentication
 
 ## 4.1. REST
@@ -748,8 +763,12 @@ Frontend nen:
 /app/chat.typing
 /app/chat.delivered
 /app/chat.seen
+/app/chat.heartbeat
 ```
 
+`/app/chat.heartbeat` chi giu Redis presence session song. No khong cap nhat
+delivered/seen.
+
 ## 9.2. Client subscribe
 
 Theo room dang mo:

doc/chat-frontend-reconnect.md

@@ -85,6 +85,7 @@ GET /api/chat/conversations/{conversationId}/messages
    - subscribe `/user/queue/conversations`
    - subscribe `/user/queue/receipts`
    - subscribe room dang mo neu co
+   - start heartbeat `/app/chat.heartbeat`
    - goi REST sync cho conversation dang mo
    - flush `pendingDeliveredAck`
    - flush `pendingSeenAck` neu room van dang visible/active
@@ -107,6 +108,7 @@ Khi WebSocket disconnect bat thuong:
 4. Khi connect lai thanh cong:
    - subscribe lai user queue
    - subscribe lai active room
+   - start lai heartbeat
    - sync lai conversation dang mo bang REST
    - ack delivered cho message moi nhat da nhan/load duoc
    - ack seen neu user van dang mo room do
@@ -117,6 +119,32 @@ Backoff co jitter de tranh nhieu tab reconnect cung luc:
 delay = min(baseDelay * 2^attempt, 30000) + random(0..500)
 ```
 
+## 5.1. Heartbeat va online state
+
+Backend luu online state bang Redis session TTL. Frontend nen gui heartbeat
+dinh ky khi WebSocket connected, dac biet khi user idle khong typing/seen/send.
+
+Destination:
+
+```text
+/app/chat.heartbeat
+```
+
+Payload:
+
+```json
+{}
+```
+
+Tan suat khuyen dung:
+
+```text
+30-60s neu backend TTL = 120s
+```
+
+Heartbeat chi giu online session song. Heartbeat khong co nghia la delivered
+va khong cap nhat `delivered_at`.
+
 ## 6. Sync sau reconnect
 
 Sau reconnect, frontend can coi WebSocket event trong thoi gian mat ket noi la

doc/chat-websocket-event-classification.md

@@ -46,6 +46,7 @@ Day la nhung destination mang prefix `/app`:
 - `/app/chat.delivered`
 - `/app/chat.seen`
 - `/app/chat.typing`
+- `/app/chat.heartbeat`
 
 ### 3.2. Event backend phat xuong client
 
@@ -65,6 +66,7 @@ Day la nhung destination de client subscribe:
 | Bao da nhan tin | `/app/chat.delivered` | `/topic/conversations.{conversationId}.receipts` va `/user/queue/receipts` | `MessageReceiptEventResponse` |
 | Bao da xem tin | `/app/chat.seen` | `/topic/conversations.{conversationId}.receipts` va `/user/queue/receipts` | `MessageReceiptEventResponse` |
 | Dang go tin | `/app/chat.typing` | `/topic/conversations.{conversationId}.typing` | `TypingEventResponse` |
+| Giu online session | `/app/chat.heartbeat` | Khong co event response | none |
 
 ## 5. Luong 1: Gui tin nhan
 
@@ -430,6 +432,8 @@ Quy tac uu tien receipt:
 - `MessageResponseDTO` la event noi dung tin nhan.
 - `MessageReceiptEventResponse` la event trang thai cua tin nhan.
 - `TypingEventResponse` la event tam thoi, khong phai state luu tru ben DB.
+- `/app/chat.heartbeat` chi giu Redis presence session song, khong phai receipt
+  va khong tao delivered/seen.
 
 ## 13. Checklist tich hop
 
@@ -437,6 +441,7 @@ Quy tac uu tien receipt:
 - Subscribe duoc room topic khi mo conversation
 - Subscribe duoc user queue cho global state
 - Gui duoc message qua `/app/chat.send`
+- Gui heartbeat dinh ky qua `/app/chat.heartbeat` neu app idle lau hon TTL
 - Gui duoc delivered qua `/app/chat.delivered`
 - Gui duoc seen qua `/app/chat.seen`
 - Phan biet duoc `MessageResponseDTO` va `MessageReceiptEventResponse`