[sqlite] [lib] refactor integrity reducer full state sync action type to use sqlite ops
ClosedPublic
Actions

	Show First 20 Lines • Show All 93 Lines • ▼ Show 20 Lines
	import {			import {
	fullStateSyncActionType,			fullStateSyncActionType,
	incrementalStateSyncActionType,			incrementalStateSyncActionType,
	} from '../types/socket-types.js';			} from '../types/socket-types.js';
	import { threadPermissions } from '../types/thread-permission-types.js';			import { threadPermissions } from '../types/thread-permission-types.js';
	import type {			import type {
	LegacyRawThreadInfo,			LegacyRawThreadInfo,
	MinimallyEncodedRawThreadInfos,			MinimallyEncodedRawThreadInfos,
	RawThreadInfos,			MixedRawThreadInfos,
	} from '../types/thread-types.js';			} from '../types/thread-types.js';
	import {			import {
	type ClientUpdateInfo,			type ClientUpdateInfo,
	processUpdatesActionType,			processUpdatesActionType,
	} from '../types/update-types.js';			} from '../types/update-types.js';
	import { translateClientDBThreadMessageInfos } from '../utils/message-ops-utils.js';			import { translateClientDBThreadMessageInfos } from '../utils/message-ops-utils.js';

	const _mapValuesWithKeys = _mapValues.convert({ cap: false });			const _mapValuesWithKeys = _mapValues.convert({ cap: false });
	Show All 35 Lines
	type FreshMessageStoreResult = {			type FreshMessageStoreResult = {
	+messageStoreOperations: $ReadOnlyArray<MessageStoreOperation>,			+messageStoreOperations: $ReadOnlyArray<MessageStoreOperation>,
	+messageStore: MessageStore,			+messageStore: MessageStore,
	};			};
	function freshMessageStore(			function freshMessageStore(
	messageInfos: $ReadOnlyArray<RawMessageInfo>,			messageInfos: $ReadOnlyArray<RawMessageInfo>,
	truncationStatus: { [threadID: string]: MessageTruncationStatus },			truncationStatus: { [threadID: string]: MessageTruncationStatus },
	currentAsOf: { +[keyserverID: string]: number },			currentAsOf: { +[keyserverID: string]: number },
	threadInfos: RawThreadInfos,			threadInfos: MixedRawThreadInfos,
	): FreshMessageStoreResult {			): FreshMessageStoreResult {
	const unshimmed = unshimMessageInfos(messageInfos);			const unshimmed = unshimMessageInfos(messageInfos);
	const orderedMessageInfos = sortMessageInfoList(unshimmed);			const orderedMessageInfos = sortMessageInfoList(unshimmed);
	const messages = _keyBy(messageID)(orderedMessageInfos);			const messages = _keyBy(messageID)(orderedMessageInfos);

	const messageStoreReplaceOperations = orderedMessageInfos.map(			const messageStoreReplaceOperations = orderedMessageInfos.map(
	messageInfo => ({			messageInfo => ({
	type: 'replace',			type: 'replace',
	▲ Show 20 Lines • Show All 1,511 Lines • Show Last 20 Lines

[sqlite] [lib] refactor integrity reducer full state sync action type to use sqlite opsClosedPublicActions

Details

Diff Detail

Event Timeline

Revision ContentsChangeset List

Diff 38312

lib/reducers/integrity-reducer.js

[sqlite] [lib] refactor integrity reducer full state sync action type to use sqlite ops
ClosedPublic
Actions

Revision Contents
Changeset List