Я тебя понял, копай сам)

Всем привет! Работаю над чатом, где на вебсокетах реализован функционал типа Фетч последних сообщений (обычно это рест-апи запрос с массивом в ответе).

Следовательно последние сообщения приходят и рендерятся по одному, такая вот апиха.

В редьюсере обновляю состояние чата и добавляю сообщения фильтром по timestamp (чтобы не перерисовывать каждый раз все сообщения разом), когда соединение ws по какой-либо причине падает и при передподключении приходят те же сообщения. (Такая вот апиха 😀)

Вопрос: существует ли какой бэст вей работы с состоянием, кроме как фильтр в моем случае, чтобы добавлять только новые сообщения ?

Пример:

Сообщения:

1
2
3

-соединение оборвалось
Подключились заново-

1
2
3
1
2
3

Когда приходит новое сообщение нужно при вставке проверять что его ещё нет.

А вообще должен быть реализован курсор и приходить только новые сообщения.

Так и делаю

Но решение выглядит костыльным

Потому что курсора нет

Вот тут не совсем понял..

Соединение оборвалось (по любой из причин, например сеть легла). После мы его восстановили, отправляем на сервер типа connectToRoom и в ответ приходят последние, например 50 сообщений, которые нужны.

Какие последние сообщения ты имеешь ввиду?

А, по вебсокету

Тогда не надо просто отравлять последние сообщения

Ещё можно при коннекте на вебсокет отравлять время с которой нужно получить сообщения. Это время - время обрыва соединения.

Тогда придут только новые сообщения и правильно вставятся

Ну примерно тот же эффект  на клиенте и запилил))

👍

проблема такова
1. октрытая страница isOnline=true
2. перезагружаем страницу
3. isOnline=false
4. страница перезагрузилась
5. isOnline=true
6. фронт дергает graphql запрос currentUser и isOnline=false, а должно быть тру

что то не так приходит или что то не то с кодом

Код

async function processConnection(container, user, ws) {
   const mutex = container.resolve('mutex')
   const { id: sessId } = await container.resolve('wsSessionParser').parse(ws);

   await mutex.lock();
   await updateUserStatus(user.id, sessId, true, container)
   mutex.release();

   ws.on('close', async () => {
       await mutex.lock();
       await updateUserStatus(user.id, sessId, false, container)
       ws.close()
       mutex.release();
   });
}

Подписка отрабатывает после апдейта

updateUser => notifyAboutChangedStatus

считываются тут
   const { data, loading, refetch, error } = useQuery(TEAM_MEMBERS, { variables: { teamId } });

а дальше передается в другую компоненту                         members={data.teamMembers}

потом в цикле перебираются юзера и выводится
                               active={member.user.isOnline}
которое фолс