matty/ncd-fe
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

pl-fe: WIP migrate settings store to zustand

Browse Source 
Signed-off-by: marcin mikołajczak <git@mkljczk.pl>
This commit is contained in:
marcin mikołajczak
2024-10-07 01:32:55 +02:00
parent 419877adcc
commit e4615b70f7
31 changed files with 351 additions and 306 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
packages/pl-fe/src/api/hooks/streaming/useUserStream.ts
View File

@ -4,7 +4,7 @@ import { updateConversations } from 'pl-fe/actions/conversations';
import { fetchFilters } from 'pl-fe/actions/filters';
import { MARKER_FETCH_SUCCESS } from 'pl-fe/actions/markers';
import { updateNotificationsQueue } from 'pl-fe/actions/notifications';
import { getLocale, getSettings } from 'pl-fe/actions/settings';
import { getLocale } from 'pl-fe/actions/settings';
import { updateStatus } from 'pl-fe/actions/statuses';
import { deleteFromTimelines, processTimelineUpdate } from 'pl-fe/actions/timelines';
import { useStatContext } from 'pl-fe/contexts/stat-context';
@ -14,6 +14,7 @@ import { selectEntity } from 'pl-fe/entity-store/selectors';
import { useAppDispatch, useLoggedIn } from 'pl-fe/hooks';
import messages from 'pl-fe/messages';
import { queryClient } from 'pl-fe/queries/client';
import { useSettingsStore } from 'pl-fe/stores/settings';
import { getUnreadChatsCount, updateChatListItem } from 'pl-fe/utils/chats';
import { play, soundCache } from 'pl-fe/utils/sounds';
@ -101,6 +102,7 @@ const useUserStream = () => {
const { isLoggedIn } = useLoggedIn();
const dispatch = useAppDispatch();
const statContext = useStatContext();
const { settings } = useSettingsStore();
const listener = useCallback((event: StreamingEvent) => {
switch (event.event) {
@ -114,20 +116,17 @@ const useUserStream = () => {
dispatch(deleteFromTimelines(event.payload));
break;
case 'notification':
dispatch((dispatch, getState) => {
const locale = getLocale(getState());
messages[locale]().then(messages => {
dispatch(
updateNotificationsQueue(
event.payload,
messages,
locale,
window.location.pathname,
),
);
}).catch(error => {
console.error(error);
});
messages[getLocale()]().then(messages => {
dispatch(
updateNotificationsQueue(
event.payload,
messages,
getLocale(),
window.location.pathname,
),
);
}).catch(error => {
console.error(error);
});
break;
case 'conversation':
@ -141,13 +140,12 @@ const useUserStream = () => {
const chat = event.payload;
const me = getState().me;
const messageOwned = chat.last_message?.account_id === me;
const settings = getSettings(getState());
// Don't update own messages from streaming
if (!messageOwned) {
updateChatListItem(chat);
if (settings.getIn(['chats', 'sound'])) {
if (settings.chats.sound) {
play(soundCache.chat);
}