Changeset View

Standalone View

	// @flow			// @flow

	import { opsProcessingFinishedActionType } from '../actions/db-ops-actions.js';			import { opsProcessingFinishedActionType } from '../actions/db-ops-actions.js';
	import type { DBOpsStore } from '../types/db-ops-types.js';			import type { MessageID, DBOpsStore } from '../types/db-ops-types.js';
	import type { BaseAction } from '../types/redux-types.js';			import type { BaseAction } from '../types/redux-types.js';
				import type { StoreOperations } from '../types/store-ops-types.js';
				import { values } from '../utils/objects.js';

	function reduceDBOpsStore(store: DBOpsStore, action: BaseAction): DBOpsStore {			function reduceDBOpsStore(store: DBOpsStore, action: BaseAction): DBOpsStore {
	if (action.type === opsProcessingFinishedActionType) {			if (action.type === opsProcessingFinishedActionType) {
	const [, ...rest] = store.queuedOps;			const [, ...rest] = store.queuedOps;
	return {			return {
	...store,			...store,
	queuedOps: rest,			queuedOps: rest,
	};			};
	}			}

				return store;
				}

				function queueDBOps(
				store: DBOpsStore,
				messageID: ?MessageID,
				ops: StoreOperations,
				): DBOpsStore {
				const areNewOpsPresent = values(ops).some(opsArray => opsArray.length > 0);
				let newEntry = null;
				if (messageID && areNewOpsPresent) {
				newEntry = {
				messageID,
				ops,
				};
				} else if (areNewOpsPresent) {
				newEntry = {
				ops,
				};
				} else if (messageID) {
				newEntry = {
				messageID,
				};
				}

				if (!newEntry) {
	return store;			return store;
	}			}

	export { reduceDBOpsStore };			return {
				...store,
				queuedOps: [...store.queuedOps, newEntry],
				};
				}

				export { reduceDBOpsStore, queueDBOps };