diff --git a/lib/reducers/master-reducer.js b/lib/reducers/master-reducer.js --- a/lib/reducers/master-reducer.js +++ b/lib/reducers/master-reducer.js @@ -39,6 +39,7 @@ type ReplaceKeyserverOperation, } from '../ops/keyserver-store-ops.js'; import { isStaff } from '../shared/staff-utils.js'; +import { processDMOpsActionType } from '../types/dm-ops.js'; import type { BaseNavInfo } from '../types/nav-types.js'; import type { BaseAppState, BaseAction } from '../types/redux-types.js'; import { @@ -186,6 +187,31 @@ const { threadActivityStore, threadActivityStoreOperations } = reduceThreadActivity(state.threadActivityStore, action); + let storeOperations = { + draftStoreOperations, + threadStoreOperations, + messageStoreOperations, + reportStoreOperations, + userStoreOperations, + keyserverStoreOperations, + communityStoreOperations, + integrityStoreOperations, + syncedMetadataStoreOperations, + auxUserStoreOperations, + threadActivityStoreOperations, + entryStoreOperations, + }; + + if ( + action.type === processDMOpsActionType && + action.payload.outboundP2PMessages + ) { + storeOperations = { + ...storeOperations, + outboundP2PMessages: action.payload.outboundP2PMessages, + }; + } + return { state: { ...state, @@ -227,19 +253,6 @@ action, ), }, - storeOperations: { - draftStoreOperations, - threadStoreOperations, - messageStoreOperations, - reportStoreOperations, - userStoreOperations, - keyserverStoreOperations, - communityStoreOperations, - integrityStoreOperations, - syncedMetadataStoreOperations, - auxUserStoreOperations, - threadActivityStoreOperations, - entryStoreOperations, - }, + storeOperations, }; } diff --git a/lib/shared/dm-ops/process-dm-ops.js b/lib/shared/dm-ops/process-dm-ops.js --- a/lib/shared/dm-ops/process-dm-ops.js +++ b/lib/shared/dm-ops/process-dm-ops.js @@ -148,6 +148,7 @@ payload: { rawMessageInfos, updateInfos, + outboundP2PMessages: null, }, }, metadata, diff --git a/lib/types/dm-ops.js b/lib/types/dm-ops.js --- a/lib/types/dm-ops.js +++ b/lib/types/dm-ops.js @@ -351,6 +351,7 @@ export type ProcessDMOpsPayload = { +rawMessageInfos: $ReadOnlyArray, +updateInfos: $ReadOnlyArray, + +outboundP2PMessages: ?$ReadOnlyArray, }; export const queueDMOpsActionType = 'QUEUE_DM_OPS';