Changeset View
Changeset View
Standalone View
Standalone View
lib/reducers/message-reducer.js
| Show All 21 Lines | import { | ||||
| restoreEntryActionTypes, | restoreEntryActionTypes, | ||||
| } from '../actions/entry-actions.js'; | } from '../actions/entry-actions.js'; | ||||
| import { | import { | ||||
| fetchMessagesBeforeCursorActionTypes, | fetchMessagesBeforeCursorActionTypes, | ||||
| fetchMostRecentMessagesActionTypes, | fetchMostRecentMessagesActionTypes, | ||||
| sendTextMessageActionTypes, | sendTextMessageActionTypes, | ||||
| sendMultimediaMessageActionTypes, | sendMultimediaMessageActionTypes, | ||||
| sendReactionMessageActionTypes, | sendReactionMessageActionTypes, | ||||
| sendEditMessageActionTypes, | |||||
| saveMessagesActionType, | saveMessagesActionType, | ||||
| processMessagesActionType, | processMessagesActionType, | ||||
| messageStorePruneActionType, | messageStorePruneActionType, | ||||
| createLocalMessageActionType, | createLocalMessageActionType, | ||||
| fetchSingleMostRecentMessagesFromThreadsActionTypes, | fetchSingleMostRecentMessagesFromThreadsActionTypes, | ||||
| } from '../actions/message-actions.js'; | } from '../actions/message-actions.js'; | ||||
| import { sendMessageReportActionTypes } from '../actions/message-report-actions.js'; | import { sendMessageReportActionTypes } from '../actions/message-report-actions.js'; | ||||
| import { siweAuthActionTypes } from '../actions/siwe-actions.js'; | import { siweAuthActionTypes } from '../actions/siwe-actions.js'; | ||||
| ▲ Show 20 Lines • Show All 835 Lines • ▼ Show 20 Lines | const messagesResult = mergeUpdatesWithMessageInfos( | ||||
| action.payload.updatesResult.newUpdates, | action.payload.updatesResult.newUpdates, | ||||
| ); | ); | ||||
| return mergeNewMessages( | return mergeNewMessages( | ||||
| messageStore, | messageStore, | ||||
| messagesResult.rawMessageInfos, | messagesResult.rawMessageInfos, | ||||
| messagesResult.truncationStatuses, | messagesResult.truncationStatuses, | ||||
| newThreadInfos, | newThreadInfos, | ||||
| ); | ); | ||||
| } else if (action.type === sendEditMessageActionTypes.success) { | |||||
| const { newMessageInfos } = action.payload; | |||||
| const truncationStatuses = {}; | |||||
| for (const messageInfo of newMessageInfos) { | |||||
| truncationStatuses[messageInfo.threadID] = | |||||
| messageTruncationStatus.UNCHANGED; | |||||
| } | |||||
| return mergeNewMessages( | |||||
| messageStore, | |||||
| newMessageInfos, | |||||
| truncationStatuses, | |||||
| newThreadInfos, | |||||
| ); | |||||
| } else if ( | } else if ( | ||||
| action.type === sendTextMessageActionTypes.started || | action.type === sendTextMessageActionTypes.started || | ||||
| action.type === sendMultimediaMessageActionTypes.started || | action.type === sendMultimediaMessageActionTypes.started || | ||||
| action.type === sendReactionMessageActionTypes.started | action.type === sendReactionMessageActionTypes.started | ||||
| ) { | ) { | ||||
| const payload = ensureRealizedThreadIDIsUsedWhenPossible( | const payload = ensureRealizedThreadIDIsUsedWhenPossible( | ||||
| action.payload, | action.payload, | ||||
| newThreadInfos, | newThreadInfos, | ||||
| ▲ Show 20 Lines • Show All 560 Lines • Show Last 20 Lines | |||||