Page MenuHomePhabricator
Files F2753578

D13328.id44141.diff
No OneTemporary
Actions

D13328.id44141.diff
View Options

diff --git a/lib/hooks/input-state-container-hooks.js b/lib/hooks/input-state-container-hooks.js
new file mode 100644
--- /dev/null
+++ b/lib/hooks/input-state-container-hooks.js
@@ -0,0 +1,102 @@
+// @flow
+
+import invariant from 'invariant';
+import * as React from 'react';
+import uuid from 'uuid';
+
+import { useSendTextMessage } from '../actions/message-actions.js';
+import { dmOperationSpecificationTypes } from '../shared/dm-ops/dm-op-utils.js';
+import { useSendComposableDMOperation } from '../shared/dm-ops/process-dm-ops.js';
+import type { SendMessagePayload } from '../types/message-types.js';
+import type { RawTextMessageInfo } from '../types/messages/text.js';
+import type { ThreadInfo } from '../types/minimally-encoded-thread-permissions-types.js';
+import {
+ thickThreadTypes,
+ threadTypeIsThick,
+} from '../types/thread-types-enum.js';
+
+function useInputStateContainerSendTextMessage(): (
+ messageInfo: RawTextMessageInfo,
+ threadInfo: ThreadInfo,
+ parentThreadInfo: ?ThreadInfo,
+ sidebarCreation: boolean,
+) => Promise<SendMessagePayload> {
+ const sendTextMessage = useSendTextMessage();
+ const sendComposableDMOperation = useSendComposableDMOperation();
+
+ return React.useCallback(
+ async (
+ messageInfo: RawTextMessageInfo,
+ threadInfo: ThreadInfo,
+ parentThreadInfo: ?ThreadInfo,
+ sidebarCreation: boolean,
+ ) => {
+ const { localID } = messageInfo;
+ invariant(
+ localID !== null && localID !== undefined,
+ 'localID should be set',
+ );
+ if (!threadTypeIsThick(threadInfo.type)) {
+ const result = await sendTextMessage({
+ threadID: messageInfo.threadID,
+ localID,
+ text: messageInfo.text,
+ sidebarCreation,
+ });
+ return {
+ localID,
+ serverID: result.id,
+ threadID: messageInfo.threadID,
+ time: result.time,
+ interface: result.interface,
+ };
+ }
+
+ const messageID = uuid.v4();
+ const time = Date.now();
+
+ const recipients =
+ threadInfo.type === thickThreadTypes.THICK_SIDEBAR && parentThreadInfo
+ ? parentThreadInfo.members
+ : threadInfo.members;
+ const recipientsIDs = recipients.map(recipient => recipient.id);
+
+ const messageIDs = await sendComposableDMOperation({
+ type: dmOperationSpecificationTypes.OUTBOUND,
+ op: {
+ type: 'send_text_message',
+ threadID: threadInfo.id,
+ creatorID: messageInfo.creatorID,
+ time,
+ messageID,
+ text: messageInfo.text,
+ },
+ // We need to use a different mechanism than `all_thread_members`
+ // because when creating a sidebar, the thread might not yet
+ // be in the store.
+ recipients: {
+ type: 'some_users',
+ userIDs: recipientsIDs,
+ },
+ sendOnly: true,
+ composableMessageID: localID,
+ });
+
+ if (messageIDs.length > 0) {
+ const e: any = new Error('Failed to send message to all peers');
+ e.messageIDs = messageIDs;
+ throw e;
+ }
+ return {
+ localID,
+ serverID: messageID,
+ threadID: messageInfo.threadID,
+ time,
+ interface: 'none',
+ };
+ },
+ [sendComposableDMOperation, sendTextMessage],
+ );
+}
+
+export { useInputStateContainerSendTextMessage };

File Metadata

Mime Type
text/plain
Expires
Thu, Sep 19, 5:40 PM (3 h, 18 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2141308
Default Alt Text
D13328.id44141.diff (3 KB)

Event Timeline