Chat WebSocket — events

Realtime JSON trên chat-api. CMS đi qua admin-api-gateway /api/v1/chat/ws; game vẫn nối thẳng chat-api /ws. Ping server là binary 1 byte. Gửi/xóa/react tin vẫn gọi HTTP/RPC — WS chỉ fan-out.

1. Tổng quan

2. Handshake

GET /ws?access_token=<jwt>                                    // game → chat-api
GET /api/v1/chat/ws?access_token=<cms_jwt>                    // CMS → admin-api-gateway
GET /api/v1/chat/ws?kind=cms&access_token=<cms_jwt>           // tương đương

Chat-api: kind trống parse game JWT trước, fail thì thử CMS JWT. kind=game|user chỉ game. kind=cms|admin chỉ CMS. Admin gateway luôn gắn kind=cms nếu client không gửi kind / token_kind.

3. Heartbeat

4. Client packets

Text JSON chỉ dùng cho heartbeat; field không dùng có thể bỏ.

{
  "type": "subscribe",
  "conversation_id": "p2p:social:user_1001_user_1002"
}

JSON lỗi parse bị bỏ qua. Disconnect: server unregister connection khỏi actor.

5. Event envelope

Mọi sự kiện (trừ ping/pong) cùng shape:

{
  "type": "message",
  "conversation_id": "support:1001:1757812345678901234",
  "actor_id": 1001,
  "origin": "a1b2c3d4-....",
  "message": { /* Message, optional */ },
  "conversation": { /* Conversation, optional */ }
}

6. Message events

{
  "type": "message",
  "conversation_id": "p2p:social:user_1001_user_1002",
  "actor_id": 1001,
  "origin": "...",
  "message": {
    "id": "66e1ab0c2f1a4b0012345678",
    "conversation_id": "p2p:social:user_1001_user_1002",
    "seq": 8,
    "sender_id": 1001,
    "sender_type": "user",
    "type": "text",
    "content": {
      "text": "hello",
      "attachments": [],
      "p2p_reactions": {},
      "reaction_count": {}
    },
    "deleted": false,
    "created_at": "2026-09-14T03:20:00.123Z"
  }
}

Replace bubble theo message.id (deleted/reacted). Inbox preview = content.text hoặc [image]/[audio]/…

7. Conversation events

Ba event member/settings là system message: message.content.text bằng đúng type event; metadata có actor/user liên quan.

8. Support events

Các event này kèm conversation (claimed_by, status, participants…) và được gửi tới toàn bộ admin đang online. CMS pending queue: support.started → thêm card; support.claimed → gỡ khỏi pending.

9. Game room events

conversation.metadata.game_id / room_id, reference.id = {gameID}/{roomID}. Client vào bàn nhận event theo membership, rồi gọi history RPC.

10. Payloads conversation / message

Cùng schema REST (snake_case). Timestamp ISO-8601. id message là hex ObjectId.

conversation (rút gọn):
{
  "id": "game_room:tienlen:room-9",
  "type": "group",
  "category": "game_room",
  "name": "Bàn 9",
  "owner_id": 1001,
  "participants": [{ "id": 1001, "type": "user", "role": "member" }],
  "settings": { "only_admin_send": false, "expired_at": "2026-09-14T04:00:00Z" },
  "reference": { "type": "game_room", "id": "tienlen/room-9" },
  "metadata": { "game_id": "tienlen", "room_id": "room-9" },
  "last_seq": 3,
  "status": "active",
  "created_at": "2026-09-14T03:30:00Z",
  "updated_at": "2026-09-14T03:30:00Z"
}

11. Flow client

1. Có JWT → game GET /ws?access_token=; CMS GET /api/v1/chat/ws?access_token= trên admin gateway.
2. Nếu HTTP 200 + code=4: refresh token, không giả định đã connected.
3. On open: binary pong 0x01 khi nhận 0x00.
4. Song song gọi list RPC/REST để fill inbox (WS không dump history).
5. Mở thread mới / vào bàn: conversation membership quyết định fan-out; không gửi subscribe.
6. On message: append nếu seq mới; trùng id thì ignore.
7. On message.deleted / message.edited / message.reaction.created: patch theo id.
8. On support.closed / room expired (send lỗi): khóa composer.
9. Reconnect: history before_seq=0 để bù tin miss.

12. Lỗi

WS không trả domain error của send/delete — lỗi nằm ở RPC/REST (game / cms).