Mountain| Первый финал, первая победа и новый старт

• Рефакторинг back-end сервисов
  
• Убрали часть легаси кода на фронте
  
• Переработали некоторый UI элементы и добавили плавности
  
• Добавили новый функционал

• Рассылка кодов авторизации
  
• Поиск серверных чатов
  
• Подписка у пользователя в сообщениях какая это роль
  
• Переработали дизайн тредов, теперь у него больше настроек
  
• Сохранение сообщений

• Мы расширили настройки на создание тредов

• Проставить теги
  
• Написать нормальное описание

• Отфильтровать по названию, даже по одному слову в середине текста названия или описания
  
• Отфильтровать по тегам, идет сортировка по часто используемым
  
• Закрепить тред (все закрепленные всегда будут вверху, только потом будут идти не закрепленные, даже при поступлении в них новых сообщений)

• Мы изменили логику проверки прав, она стала более замудренная, но в тоже время и более правильная.

{
    'chat_id':  str,          # ObjectId, 24 символа
    'version':  int,          # монотонный счётчик
    'base':     int,          # ← OR всех ролей юзера, ОДНО число
    'topics':   {tid: int},   # только топики с overrides
    'is_owner': bool,         # админ или нет
}

• Сервис топиков тоже потерпел изменения. теперь он не ходит в Permission сервис что бы уточнить права пользователя на просмотр, а Gateway: ProxyRouter приклеивает заголовки:

def build_perm_headers(self, snapshot: dict) -> dict:
    return {
        'X-Perm-Base':   str(snapshot.get('base', 0)),
        'X-Perm-Topics': json.dumps(snapshot.get('topics', {})),
        'X-Is-Owner':    '1' if snapshot.get('is_owner') else '0',
    }

def parse_perm_headers(request) -> Optional[dict]:
    base = int(request.headers.get('x-perm-base'))
    topics = json.loads(request.headers.get('x-perm-topics', '{}'))
    is_owner = request.headers.get('x-is-owner') == '1'
    return {'base': base, 'topics': topics, 'is_owner': is_owner}

{
    "success": true,
    "topics": [
        {
            "topic_id": "69ee3a46dab658745b095c27",
            "chat_id": "69ee32fba41e74b3744d6502",
            "name": "59545",
            "created_by": "69edfdf3a6343fa670fe55db",
            "topic_type": "thread",
            "position": 0,
            "created_at": "2026-04-26T16:16:06.983000",
            "updated_at": "2026-04-28T07:09:30.006000",
            "is_active": true,
            "group_id": "69f05d25335af601c7accfe7",
            "unread_count": 0
        },
        {
            "topic_id": "69ee39a4dab658745b095c26",
            "chat_id": "69ee32fba41e74b3744d6502",
            "name": "55532",
            "created_by": "69edfdf3a6343fa670fe55db",
            "topic_type": "text",
            "position": 1,
            "created_at": "2026-04-26T16:13:24.480000",
            "updated_at": "2026-04-28T07:09:30.001000",
            "is_active": true,
            "group_id": "69f05d25335af601c7accfe7",
            "unread_count": 0
        },
        {
            "topic_id": "69f05cf4335af601c7accfe6",
            "chat_id": "69ee32fba41e74b3744d6502",
            "name": "fgfhd",
            "created_by": "69edfdf3a6343fa670fe55db",
            "topic_type": "voice",
            "position": 2,
            "created_at": "2026-04-28T07:08:36.007000",
            "updated_at": "2026-04-28T07:09:30.001000",
            "is_active": true,
            "unread_count": 0,
            "group_id": null
        }
    ],
    "groups": [
        {
            "chat_id": "69ee32fba41e74b3744d6502",
            "name": "tdrfhg",
            "created_by": "69edfdf3a6343fa670fe55db",
            "position": 0,
            "created_at": "2026-04-28T07:09:25.028000",
            "updated_at": "2026-04-28T07:09:25.028000",
            "is_active": true,
            "group_id": "69f05d25335af601c7accfe7"
        }
    ]
}

• Наконец то вынесли все коллекции сервис в отдельные базы. Раньше была одна общая БД, делалось для быстрого написания кода, но пораждало много зависимостей и хождений в чужие коллекции. Теперь все сервисы имеют свою БД со своими коллециями. Отдельный инстанс имеет только сервис сообщений.
  
• 50% сервисов перевели в режим публикации событий. Т.е. раньше было много HTTP вызовов между ними, что пораждало лишние задержки в 1-4мс. Мелочь, но в рамках 1000 или 10000 пользователей это уже существенная нагрузка. Теперь HTTP вызовы служат только для получения информации от другого сервиса, все события которые раньше были переложены на Redis. Пример: Пользователь зашел в новый чат. Сервис чата сформирует событие что у него появился новый memories, сервис прав подхватит это событие и присвоит ему права и положит их в Redis, сервис Gateway увидит новые данные и заберет их к себе.
  • Мы работаем над переводом остальных сервисов, но не все так быстро))

export class TopicCache {
    constructor(store) {
        this.store = store;
        this.KEY = 'topic_messages';
    }
    getMessages(chatId, topicId) {
        return this.store.get(this.store.key(this.KEY, chatId, topicId));
    }
    setMessages(chatId, topicId, messages) {
        this.store.set(this.store.key(this.KEY, chatId, topicId), messages);
    }
    invalidateMessages(chatId, topicId) {
        if (topicId) {
            this.store.invalidate(this.store.key(this.KEY, chatId, topicId));
        } else {
            this.store.invalidateByPrefix(this.store.key(this.KEY, chatId));
        }
    }
    appendMessage(chatId, topicId, message) {
        const cacheKey = this.store.key(this.KEY, chatId, topicId);
        const cached = this.store.get(cacheKey);
        if (cached) {
            const exists = cached.some(m => m.message_id === message.message_id);
            if (!exists) {
                const updated = [...cached, message];
                this.store.set(cacheKey, updated);
                console.log(`[CACHE] Appended message to topic ${chatId}:${topicId}, total: ${updated.length}`);
            }
        }
    }
}