Differential D7112 Diff 24998 lib/actions/message-actions.js

Changeset View

Standalone View

lib/actions/message-actions.js

// @flow		// @flow

import invariant from 'invariant';		import invariant from 'invariant';

import type {		import type {
FetchMessageInfosPayload,		FetchMessageInfosPayload,
SendMessageResult,		SendMessageResult,
SendEditMessageResult,		SendEditMessageResult,
SendReactionMessageRequest,		SendReactionMessageRequest,
SimpleMessagesPayload,		SimpleMessagesPayload,
SendEditMessageRequest,		SendEditMessageRequest,
		FetchPinnedMessagesRequest,
		FetchPinnedMessagesResult,
} from '../types/message-types.js';		} from '../types/message-types.js';
import type { MediaMessageServerDBContent } from '../types/messages/media.js';		import type { MediaMessageServerDBContent } from '../types/messages/media.js';
import type {		import type {
CallServerEndpoint,		CallServerEndpoint,
CallServerEndpointResultInfo,		CallServerEndpointResultInfo,
} from '../utils/call-server-endpoint.js';		} from '../utils/call-server-endpoint.js';

const fetchMessagesBeforeCursorActionTypes = Object.freeze({		const fetchMessagesBeforeCursorActionTypes = Object.freeze({
▲ Show 20 Lines • Show All 239 Lines • ▼ Show 20 Lines	return {
newMessageInfos: response.newMessageInfos,		newMessageInfos: response.newMessageInfos,
};		};
};		};

const saveMessagesActionType = 'SAVE_MESSAGES';		const saveMessagesActionType = 'SAVE_MESSAGES';
const processMessagesActionType = 'PROCESS_MESSAGES';		const processMessagesActionType = 'PROCESS_MESSAGES';
const messageStorePruneActionType = 'MESSAGE_STORE_PRUNE';		const messageStorePruneActionType = 'MESSAGE_STORE_PRUNE';

		const fetchPinnedMessages =
		(
		callServerEndpoint: CallServerEndpoint,
		): ((
		request: FetchPinnedMessagesRequest,
		) => Promise<FetchPinnedMessagesResult>) =>
		async request => {
		const response = await callServerEndpoint('fetch_pinned_messages', request);
		return { pinnedMessages: response.pinnedMessages };
		};

export {		export {
fetchMessagesBeforeCursorActionTypes,		fetchMessagesBeforeCursorActionTypes,
fetchMessagesBeforeCursor,		fetchMessagesBeforeCursor,
fetchMostRecentMessagesActionTypes,		fetchMostRecentMessagesActionTypes,
fetchMostRecentMessages,		fetchMostRecentMessages,
fetchSingleMostRecentMessagesFromThreadsActionTypes,		fetchSingleMostRecentMessagesFromThreadsActionTypes,
fetchSingleMostRecentMessagesFromThreads,		fetchSingleMostRecentMessagesFromThreads,
sendTextMessageActionTypes,		sendTextMessageActionTypes,
sendTextMessage,		sendTextMessage,
createLocalMessageActionType,		createLocalMessageActionType,
sendMultimediaMessageActionTypes,		sendMultimediaMessageActionTypes,
sendMultimediaMessage,		sendMultimediaMessage,
legacySendMultimediaMessage,		legacySendMultimediaMessage,
sendReactionMessageActionTypes,		sendReactionMessageActionTypes,
sendReactionMessage,		sendReactionMessage,
saveMessagesActionType,		saveMessagesActionType,
processMessagesActionType,		processMessagesActionType,
messageStorePruneActionType,		messageStorePruneActionType,
sendEditMessageActionTypes,		sendEditMessageActionTypes,
sendEditMessage,		sendEditMessage,
		fetchPinnedMessages,
};		};