[lib] fix generating DM messages to peers
ClosedPublic
Actions

Show First 20 Lines • Show All 218 Lines • ▼ Show 20 Lines	function generateOpsForUserUpdates(payload: {
return payload.updatesResult.newUpdates		return payload.updatesResult.newUpdates
.map(update =>		.map(update =>
updateSpecs[update.type].generateOpsForUserInfoUpdates?.(update),		updateSpecs[update.type].generateOpsForUserInfoUpdates?.(update),
)		)
.filter(Boolean)		.filter(Boolean)
.flat();		.flat();
}		}

		function discardKeyserverUsernames(
		newUserInfos: UserInfos,
		stateUserInfos: UserInfos,
		): UserInfos {
		let result: UserInfos = {};
		for (const id in newUserInfos) {
		const username = stateUserInfos[id] ? stateUserInfos[id].username : null;
		result = {
		...result,
		[id]: {
		...newUserInfos[id],
		username,
		},
		};
		}
		return result;
		}

type ReduceUserInfosResult = [		type ReduceUserInfosResult = [
UserStore,		UserStore,
$ReadOnlyArray<ClientUserInconsistencyReportCreationRequest>,		$ReadOnlyArray<ClientUserInconsistencyReportCreationRequest>,
$ReadOnlyArray<UserStoreOperation>,		$ReadOnlyArray<UserStoreOperation>,
];		];

function handleUserInfoUpdates(		function handleUserInfoUpdates(
state: UserStore,		state: UserStore,
▲ Show 20 Lines • Show All 74 Lines • ▼ Show 20 Lines	) {
if (action.type === joinThreadActionTypes.success) {		if (action.type === joinThreadActionTypes.success) {
keyserverID = action.payload.keyserverID;		keyserverID = action.payload.keyserverID;
} else {		} else {
keyserverID = extractKeyserverIDFromID(action.payload.newThreadID);		keyserverID = extractKeyserverIDFromID(action.payload.newThreadID);
}		}
if (keyserverID !== authoritativeKeyserverID()) {		if (keyserverID !== authoritativeKeyserverID()) {
return [state, [], []];		return [state, [], []];
}		}
const newUserInfos: UserInfos = _keyBy(userInfo => userInfo.id)(		const keyserverUserInfos: UserInfos = _keyBy(userInfo => userInfo.id)(
action.payload.userInfos,		action.payload.userInfos,
);		);

		const newUserInfos = discardKeyserverUsernames(
		keyserverUserInfos,
		state.userInfos,
		);

const userStoreOps: $ReadOnlyArray<UserStoreOperation> =		const userStoreOps: $ReadOnlyArray<UserStoreOperation> =
convertUserInfosToReplaceUserOps(newUserInfos);		convertUserInfosToReplaceUserOps(newUserInfos);
const processedUserInfos: UserInfos = processUserStoreOps(		const processedUserInfos: UserInfos = processUserStoreOps(
state.userInfos,		state.userInfos,
userStoreOps,		userStoreOps,
);		);

if (!_isEqual(state.userInfos)(processedUserInfos)) {		if (!_isEqual(state.userInfos)(processedUserInfos)) {
▲ Show 20 Lines • Show All 236 Lines • Show Last 20 Lines

[lib] fix generating DM messages to peersClosedPublicActions

Details

Diff Detail

Event Timeline

Revision ContentsChangeset List

Diff 43215

lib/shared/dm-ops/dm-op-utils.js

[lib] fix generating DM messages to peers
ClosedPublic
Actions

Revision Contents
Changeset List