Chat System

Схема данных (Cassandra)

-- Таблица сообщений (partitioned by chat_id)
CREATE TABLE messages (
    chat_id       UUID,
    message_id    TIMEUUID,  -- Snowflake ID или TIMEUUID
    sender_id     UUID,
    content       TEXT,
    created_at    TIMESTAMP,
    PRIMARY KEY ((chat_id), message_id)
) WITH CLUSTERING ORDER BY (message_id DESC);

-- Быстрый доступ к последним сообщениям чата
SELECT * FROM messages 
WHERE chat_id = ? 
ORDER BY message_id DESC 
LIMIT 50;

Sync Protocol

Каждое устройство хранит last_synced_message_id. При подключении:

1. 1Клиент отправляет свой last_synced_message_id
2. 2Сервер возвращает все сообщения после этого ID
3. 3Клиент применяет изменения и обновляет last_synced_message_id

Offline Message Queue

Для офлайн-пользователей сообщения накапливаются:

-- Очередь непрочитанных сообщений
CREATE TABLE offline_messages (
    user_id     UUID,
    message_id  TIMEUUID,
    chat_id     UUID,
    sender_id   UUID,
    content     TEXT,
    PRIMARY KEY ((user_id), message_id)
) WITH default_time_to_live = 2592000; -- 30 дней TTL

-- При подключении пользователя
SELECT * FROM offline_messages WHERE user_id = ?;
-- После синхронизации — удаляем доставленные