Page MenuHomePhabricator
Differential D12956

[lib] Apply the queued updates
ClosedPublic
Actions

Authored by tomek on Aug 1 2024, 10:15 AM.
Tags
None
Referenced Files
Unknown Object (File)
Wed, Mar 5, 4:55 PM
Unknown Object (File)
Wed, Mar 5, 3:08 PM
Unknown Object (File)
Wed, Mar 5, 3:18 AM
Unknown Object (File)
Tue, Mar 4, 11:32 PM
Unknown Object (File)
Mon, Mar 3, 3:46 PM
Unknown Object (File)
Mon, Mar 3, 3:46 PM
Unknown Object (File)
Thu, Feb 20, 2:04 AM
Unknown Object (File)
Thu, Feb 20, 2:04 AM
View All Files
Subscribers
ashoat

Details

Reviewers
kamil
inka
Commits
rCOMMff536cc87f89: [lib] Apply the queued updates
Summary

When a thread appears in the store, we should process all the operations that were queued for it.

https://linear.app/comm/issue/ENG-8769/apply-the-queued-updates

Depends on D12954

Test Plan

Processed an operation that updates thread name, with a thread ID that isn't present in the store. Then processed another operation that creates a thread with this ID. Checked that the name of the created thread matched the value from the first operation. Also checked that the queue no longer contains the operations.

Diff Detail

Repository
rCOMM Comm
Lint
Lint Not Applicable
Unit
Tests Not Applicable

Event Timeline

tomek created this revision.Aug 1 2024, 10:15 AM
Herald added a subscriber: ashoat. · View Herald TranscriptAug 1 2024, 10:15 AM
tomek added inline comments.Aug 1 2024, 10:17 AM
lib/shared/dm-ops/dm-ops-queue-handler.react.js
45 ↗(On Diff #43024)

We don't want to process operations multiple times. This ref allows us to process the operations in the first render where the thread is present.

Harbormaster returned this revision to the author for changes because remote builds failed.Aug 1 2024, 10:38 AM
Harbormaster failed remote builds in B30857: Diff 43024!
Harbormaster completed remote builds in B30857: Diff 43024.Aug 2 2024, 1:51 AM
tomek requested review of this revision.Aug 2 2024, 1:51 AM
tomek updated this revision to Diff 43035.Aug 2 2024, 2:50 AM

Rebase

Harbormaster completed remote builds in B30868: Diff 43035.Aug 2 2024, 3:07 AM
tomek added a child revision: D12957: [lib] Correctly handle generating ops from multiple updates.Aug 2 2024, 4:35 AM
tomek edited the test plan for this revision. (Show Details)Aug 2 2024, 6:37 AM
tomek edited the test plan for this revision. (Show Details)
inka accepted this revision.Aug 2 2024, 7:31 AM
inka added inline comments.
lib/shared/dm-ops/dm-ops-queue-handler.react.js
62 ↗(On Diff #43035)

can't we iterate over queuedOperations entries?
for (const threadID in queuedOperations)

66–68 ↗(On Diff #43035)

Can't we run ops in parallel?

lib/types/dm-ops.js
330 ↗(On Diff #43035)

This name is very hard for me to understand. Can it be 'CLEAR_QUEUED_THREAD_DM_OPS'?

This revision is now accepted and ready to land.Aug 2 2024, 7:31 AM
tomek updated this revision to Diff 43039.Aug 2 2024, 7:44 AM

Rename. Run ops in parallel.

Harbormaster completed remote builds in B30872: Diff 43039.Aug 2 2024, 8:05 AM
tomek updated this revision to Diff 43040.Aug 2 2024, 8:10 AM

Run ops in parallel

Harbormaster completed remote builds in B30873: Diff 43040.Aug 2 2024, 8:27 AM
Closed by commit rCOMMff536cc87f89: [lib] Apply the queued updates (authored by tomek). · Explain WhyAug 2 2024, 8:38 AM
This revision was automatically updated to reflect the committed changes.
tomek added a commit: rCOMMff536cc87f89: [lib] Apply the queued updates.

Revision Contents
Changeset List

PathSize
lib/
reducers/
8 lines
shared/
dm-ops/
77 lines
tunnelbroker/
4 lines
types/
5 lines
7 lines

Diff 43053

View Options

lib/reducers/dm-operations-queue-reducer.js

Show First 20 Lines • Show All 149 Lines • ▼ Show 20 Lines +uploadMultimedia: (
extras: MultimediaUploadExtras, extras: MultimediaUploadExtras,
callbacks: MultimediaUploadCallbacks, callbacks: MultimediaUploadCallbacks,
) => Promise<UploadMultimediaResult>, ) => Promise<UploadMultimediaResult>,
+blobServiceUpload: BlobServiceUploadAction, +blobServiceUpload: BlobServiceUploadAction,
+sendMultimediaMessage: ( +sendMultimediaMessage: (
input: SendMultimediaMessageInput, input: SendMultimediaMessageInput,
) => Promise<SendMessageResult>, ) => Promise<SendMessageResult>,
+sendTextMessage: (input: SendTextMessageInput) => Promise<SendMessageResult>, +sendTextMessage: (input: SendTextMessageInput) => Promise<SendMessageResult>,
+newThread: (request: ClientNewThreadRequest) => Promise<NewThreadResult>, +newThinThread: (request: ClientNewThreadRequest) => Promise<NewThreadResult>,
+textMessageCreationSideEffectsFunc: CreationSideEffectsFunc<RawTextMessageInfo>, +textMessageCreationSideEffectsFunc: CreationSideEffectsFunc<RawTextMessageInfo>,
}; };
type State = { type State = {
+pendingUploads: PendingMultimediaUploads, +pendingUploads: PendingMultimediaUploads,
}; };
class InputStateContainer extends React.PureComponent<Props, State> { class InputStateContainer extends React.PureComponent<Props, State> {
state: State = { state: State = {
▲ Show 20 Lines • Show All 380 Lines • ▼ Show 20 Lines if (!threadIsPending(threadInfo.id)) {
return Promise.resolve(threadInfo.id); return Promise.resolve(threadInfo.id);
} }
let threadCreationPromise = this.pendingThreadCreations.get(threadInfo.id); let threadCreationPromise = this.pendingThreadCreations.get(threadInfo.id);
if (!threadCreationPromise) { if (!threadCreationPromise) {
const calendarQuery = this.props.calendarQuery(); const calendarQuery = this.props.calendarQuery();
threadCreationPromise = createRealThreadFromPendingThread({ threadCreationPromise = createRealThreadFromPendingThread({
threadInfo, threadInfo,
dispatchActionPromise: this.props.dispatchActionPromise, dispatchActionPromise: this.props.dispatchActionPromise,
createNewThread: this.props.newThread, createNewThinThread: this.props.newThinThread,
sourceMessageID: threadInfo.sourceMessageID, sourceMessageID: threadInfo.sourceMessageID,
viewerID: this.props.viewerID, viewerID: this.props.viewerID,
calendarQuery, calendarQuery,
}); });
this.pendingThreadCreations.set(threadInfo.id, threadCreationPromise); this.pendingThreadCreations.set(threadInfo.id, threadCreationPromise);
} }
return threadCreationPromise; return threadCreationPromise;
} }
▲ Show 20 Lines • Show All 1,165 Lines • ▼ Show 20 Lines const ongoingMessageCreation = useSelector(
) === 'loading', ) === 'loading',
); );
const hasWiFi = useSelector(state => state.connectivity.hasWiFi); const hasWiFi = useSelector(state => state.connectivity.hasWiFi);
const calendarQuery = useCalendarQuery(); const calendarQuery = useCalendarQuery();
const callUploadMultimedia = useLegacyAshoatKeyserverCall(uploadMultimedia); const callUploadMultimedia = useLegacyAshoatKeyserverCall(uploadMultimedia);
const callBlobServiceUpload = useBlobServiceUpload(); const callBlobServiceUpload = useBlobServiceUpload();
const callSendMultimediaMessage = useSendMultimediaMessage(); const callSendMultimediaMessage = useSendMultimediaMessage();
const callSendTextMessage = useSendTextMessage(); const callSendTextMessage = useSendTextMessage();
const callNewThread = useNewThread(); const callNewThinThread = useNewThread();
const dispatchActionPromise = useDispatchActionPromise(); const dispatchActionPromise = useDispatchActionPromise();
const dispatch = useDispatch(); const dispatch = useDispatch();
const mediaReportsEnabled = useIsReportEnabled('mediaReports'); const mediaReportsEnabled = useIsReportEnabled('mediaReports');
const staffCanSee = useStaffCanSee(); const staffCanSee = useStaffCanSee();
const textMessageCreationSideEffectsFunc = const textMessageCreationSideEffectsFunc =
useMessageCreationSideEffectsFunc<RawTextMessageInfo>(messageTypes.TEXT); useMessageCreationSideEffectsFunc<RawTextMessageInfo>(messageTypes.TEXT);
return ( return (
<InputStateContainer <InputStateContainer
{...props} {...props}
viewerID={viewerID} viewerID={viewerID}
messageStoreMessages={messageStoreMessages} messageStoreMessages={messageStoreMessages}
ongoingMessageCreation={ongoingMessageCreation} ongoingMessageCreation={ongoingMessageCreation}
hasWiFi={hasWiFi} hasWiFi={hasWiFi}
mediaReportsEnabled={mediaReportsEnabled} mediaReportsEnabled={mediaReportsEnabled}
calendarQuery={calendarQuery} calendarQuery={calendarQuery}
uploadMultimedia={callUploadMultimedia} uploadMultimedia={callUploadMultimedia}
blobServiceUpload={callBlobServiceUpload} blobServiceUpload={callBlobServiceUpload}
sendMultimediaMessage={callSendMultimediaMessage} sendMultimediaMessage={callSendMultimediaMessage}
sendTextMessage={callSendTextMessage} sendTextMessage={callSendTextMessage}
newThread={callNewThread} newThinThread={callNewThinThread}
dispatchActionPromise={dispatchActionPromise} dispatchActionPromise={dispatchActionPromise}
dispatch={dispatch} dispatch={dispatch}
staffCanSee={staffCanSee} staffCanSee={staffCanSee}
textMessageCreationSideEffectsFunc={textMessageCreationSideEffectsFunc} textMessageCreationSideEffectsFunc={textMessageCreationSideEffectsFunc}
/> />
); );
}); });
export default ConnectedInputStateContainer; export default ConnectedInputStateContainer;
View Options

lib/shared/dm-ops/dm-ops-queue-handler.react.js

Show First 20 Lines • Show All 149 Lines • ▼ Show 20 Lines +uploadMultimedia: (
extras: MultimediaUploadExtras, extras: MultimediaUploadExtras,
callbacks: MultimediaUploadCallbacks, callbacks: MultimediaUploadCallbacks,
) => Promise<UploadMultimediaResult>, ) => Promise<UploadMultimediaResult>,
+blobServiceUpload: BlobServiceUploadAction, +blobServiceUpload: BlobServiceUploadAction,
+sendMultimediaMessage: ( +sendMultimediaMessage: (
input: SendMultimediaMessageInput, input: SendMultimediaMessageInput,
) => Promise<SendMessageResult>, ) => Promise<SendMessageResult>,
+sendTextMessage: (input: SendTextMessageInput) => Promise<SendMessageResult>, +sendTextMessage: (input: SendTextMessageInput) => Promise<SendMessageResult>,
+newThread: (request: ClientNewThreadRequest) => Promise<NewThreadResult>, +newThinThread: (request: ClientNewThreadRequest) => Promise<NewThreadResult>,
+textMessageCreationSideEffectsFunc: CreationSideEffectsFunc<RawTextMessageInfo>, +textMessageCreationSideEffectsFunc: CreationSideEffectsFunc<RawTextMessageInfo>,
}; };
type State = { type State = {
+pendingUploads: PendingMultimediaUploads, +pendingUploads: PendingMultimediaUploads,
}; };
class InputStateContainer extends React.PureComponent<Props, State> { class InputStateContainer extends React.PureComponent<Props, State> {
state: State = { state: State = {
▲ Show 20 Lines • Show All 380 Lines • ▼ Show 20 Lines if (!threadIsPending(threadInfo.id)) {
return Promise.resolve(threadInfo.id); return Promise.resolve(threadInfo.id);
} }
let threadCreationPromise = this.pendingThreadCreations.get(threadInfo.id); let threadCreationPromise = this.pendingThreadCreations.get(threadInfo.id);
if (!threadCreationPromise) { if (!threadCreationPromise) {
const calendarQuery = this.props.calendarQuery(); const calendarQuery = this.props.calendarQuery();
threadCreationPromise = createRealThreadFromPendingThread({ threadCreationPromise = createRealThreadFromPendingThread({
threadInfo, threadInfo,
dispatchActionPromise: this.props.dispatchActionPromise, dispatchActionPromise: this.props.dispatchActionPromise,
createNewThread: this.props.newThread, createNewThinThread: this.props.newThinThread,
sourceMessageID: threadInfo.sourceMessageID, sourceMessageID: threadInfo.sourceMessageID,
viewerID: this.props.viewerID, viewerID: this.props.viewerID,
calendarQuery, calendarQuery,
}); });
this.pendingThreadCreations.set(threadInfo.id, threadCreationPromise); this.pendingThreadCreations.set(threadInfo.id, threadCreationPromise);
} }
return threadCreationPromise; return threadCreationPromise;
} }
▲ Show 20 Lines • Show All 1,165 Lines • ▼ Show 20 Lines const ongoingMessageCreation = useSelector(
) === 'loading', ) === 'loading',
); );
const hasWiFi = useSelector(state => state.connectivity.hasWiFi); const hasWiFi = useSelector(state => state.connectivity.hasWiFi);
const calendarQuery = useCalendarQuery(); const calendarQuery = useCalendarQuery();
const callUploadMultimedia = useLegacyAshoatKeyserverCall(uploadMultimedia); const callUploadMultimedia = useLegacyAshoatKeyserverCall(uploadMultimedia);
const callBlobServiceUpload = useBlobServiceUpload(); const callBlobServiceUpload = useBlobServiceUpload();
const callSendMultimediaMessage = useSendMultimediaMessage(); const callSendMultimediaMessage = useSendMultimediaMessage();
const callSendTextMessage = useSendTextMessage(); const callSendTextMessage = useSendTextMessage();
const callNewThread = useNewThread(); const callNewThinThread = useNewThread();
const dispatchActionPromise = useDispatchActionPromise(); const dispatchActionPromise = useDispatchActionPromise();
const dispatch = useDispatch(); const dispatch = useDispatch();
const mediaReportsEnabled = useIsReportEnabled('mediaReports'); const mediaReportsEnabled = useIsReportEnabled('mediaReports');
const staffCanSee = useStaffCanSee(); const staffCanSee = useStaffCanSee();
const textMessageCreationSideEffectsFunc = const textMessageCreationSideEffectsFunc =
useMessageCreationSideEffectsFunc<RawTextMessageInfo>(messageTypes.TEXT); useMessageCreationSideEffectsFunc<RawTextMessageInfo>(messageTypes.TEXT);
return ( return (
<InputStateContainer <InputStateContainer
{...props} {...props}
viewerID={viewerID} viewerID={viewerID}
messageStoreMessages={messageStoreMessages} messageStoreMessages={messageStoreMessages}
ongoingMessageCreation={ongoingMessageCreation} ongoingMessageCreation={ongoingMessageCreation}
hasWiFi={hasWiFi} hasWiFi={hasWiFi}
mediaReportsEnabled={mediaReportsEnabled} mediaReportsEnabled={mediaReportsEnabled}
calendarQuery={calendarQuery} calendarQuery={calendarQuery}
uploadMultimedia={callUploadMultimedia} uploadMultimedia={callUploadMultimedia}
blobServiceUpload={callBlobServiceUpload} blobServiceUpload={callBlobServiceUpload}
sendMultimediaMessage={callSendMultimediaMessage} sendMultimediaMessage={callSendMultimediaMessage}
sendTextMessage={callSendTextMessage} sendTextMessage={callSendTextMessage}
newThread={callNewThread} newThinThread={callNewThinThread}
dispatchActionPromise={dispatchActionPromise} dispatchActionPromise={dispatchActionPromise}
dispatch={dispatch} dispatch={dispatch}
staffCanSee={staffCanSee} staffCanSee={staffCanSee}
textMessageCreationSideEffectsFunc={textMessageCreationSideEffectsFunc} textMessageCreationSideEffectsFunc={textMessageCreationSideEffectsFunc}
/> />
); );
}); });
export default ConnectedInputStateContainer; export default ConnectedInputStateContainer;
View Options

lib/shared/dm-ops/dm-ops-queue-pruner.react.js

Show First 20 Lines • Show All 149 Lines • ▼ Show 20 Lines +uploadMultimedia: (
extras: MultimediaUploadExtras, extras: MultimediaUploadExtras,
callbacks: MultimediaUploadCallbacks, callbacks: MultimediaUploadCallbacks,
) => Promise<UploadMultimediaResult>, ) => Promise<UploadMultimediaResult>,
+blobServiceUpload: BlobServiceUploadAction, +blobServiceUpload: BlobServiceUploadAction,
+sendMultimediaMessage: ( +sendMultimediaMessage: (
input: SendMultimediaMessageInput, input: SendMultimediaMessageInput,
) => Promise<SendMessageResult>, ) => Promise<SendMessageResult>,
+sendTextMessage: (input: SendTextMessageInput) => Promise<SendMessageResult>, +sendTextMessage: (input: SendTextMessageInput) => Promise<SendMessageResult>,
+newThread: (request: ClientNewThreadRequest) => Promise<NewThreadResult>, +newThinThread: (request: ClientNewThreadRequest) => Promise<NewThreadResult>,
+textMessageCreationSideEffectsFunc: CreationSideEffectsFunc<RawTextMessageInfo>, +textMessageCreationSideEffectsFunc: CreationSideEffectsFunc<RawTextMessageInfo>,
}; };
type State = { type State = {
+pendingUploads: PendingMultimediaUploads, +pendingUploads: PendingMultimediaUploads,
}; };
class InputStateContainer extends React.PureComponent<Props, State> { class InputStateContainer extends React.PureComponent<Props, State> {
state: State = { state: State = {
▲ Show 20 Lines • Show All 380 Lines • ▼ Show 20 Lines if (!threadIsPending(threadInfo.id)) {
return Promise.resolve(threadInfo.id); return Promise.resolve(threadInfo.id);
} }
let threadCreationPromise = this.pendingThreadCreations.get(threadInfo.id); let threadCreationPromise = this.pendingThreadCreations.get(threadInfo.id);
if (!threadCreationPromise) { if (!threadCreationPromise) {
const calendarQuery = this.props.calendarQuery(); const calendarQuery = this.props.calendarQuery();
threadCreationPromise = createRealThreadFromPendingThread({ threadCreationPromise = createRealThreadFromPendingThread({
threadInfo, threadInfo,
dispatchActionPromise: this.props.dispatchActionPromise, dispatchActionPromise: this.props.dispatchActionPromise,
createNewThread: this.props.newThread, createNewThinThread: this.props.newThinThread,
sourceMessageID: threadInfo.sourceMessageID, sourceMessageID: threadInfo.sourceMessageID,
viewerID: this.props.viewerID, viewerID: this.props.viewerID,
calendarQuery, calendarQuery,
}); });
this.pendingThreadCreations.set(threadInfo.id, threadCreationPromise); this.pendingThreadCreations.set(threadInfo.id, threadCreationPromise);
} }
return threadCreationPromise; return threadCreationPromise;
} }
▲ Show 20 Lines • Show All 1,165 Lines • ▼ Show 20 Lines const ongoingMessageCreation = useSelector(
) === 'loading', ) === 'loading',
); );
const hasWiFi = useSelector(state => state.connectivity.hasWiFi); const hasWiFi = useSelector(state => state.connectivity.hasWiFi);
const calendarQuery = useCalendarQuery(); const calendarQuery = useCalendarQuery();
const callUploadMultimedia = useLegacyAshoatKeyserverCall(uploadMultimedia); const callUploadMultimedia = useLegacyAshoatKeyserverCall(uploadMultimedia);
const callBlobServiceUpload = useBlobServiceUpload(); const callBlobServiceUpload = useBlobServiceUpload();
const callSendMultimediaMessage = useSendMultimediaMessage(); const callSendMultimediaMessage = useSendMultimediaMessage();
const callSendTextMessage = useSendTextMessage(); const callSendTextMessage = useSendTextMessage();
const callNewThread = useNewThread(); const callNewThinThread = useNewThread();
const dispatchActionPromise = useDispatchActionPromise(); const dispatchActionPromise = useDispatchActionPromise();
const dispatch = useDispatch(); const dispatch = useDispatch();
const mediaReportsEnabled = useIsReportEnabled('mediaReports'); const mediaReportsEnabled = useIsReportEnabled('mediaReports');
const staffCanSee = useStaffCanSee(); const staffCanSee = useStaffCanSee();
const textMessageCreationSideEffectsFunc = const textMessageCreationSideEffectsFunc =
useMessageCreationSideEffectsFunc<RawTextMessageInfo>(messageTypes.TEXT); useMessageCreationSideEffectsFunc<RawTextMessageInfo>(messageTypes.TEXT);
return ( return (
<InputStateContainer <InputStateContainer
{...props} {...props}
viewerID={viewerID} viewerID={viewerID}
messageStoreMessages={messageStoreMessages} messageStoreMessages={messageStoreMessages}
ongoingMessageCreation={ongoingMessageCreation} ongoingMessageCreation={ongoingMessageCreation}
hasWiFi={hasWiFi} hasWiFi={hasWiFi}
mediaReportsEnabled={mediaReportsEnabled} mediaReportsEnabled={mediaReportsEnabled}
calendarQuery={calendarQuery} calendarQuery={calendarQuery}
uploadMultimedia={callUploadMultimedia} uploadMultimedia={callUploadMultimedia}
blobServiceUpload={callBlobServiceUpload} blobServiceUpload={callBlobServiceUpload}
sendMultimediaMessage={callSendMultimediaMessage} sendMultimediaMessage={callSendMultimediaMessage}
sendTextMessage={callSendTextMessage} sendTextMessage={callSendTextMessage}
newThread={callNewThread} newThinThread={callNewThinThread}
dispatchActionPromise={dispatchActionPromise} dispatchActionPromise={dispatchActionPromise}
dispatch={dispatch} dispatch={dispatch}
staffCanSee={staffCanSee} staffCanSee={staffCanSee}
textMessageCreationSideEffectsFunc={textMessageCreationSideEffectsFunc} textMessageCreationSideEffectsFunc={textMessageCreationSideEffectsFunc}
/> />
); );
}); });
export default ConnectedInputStateContainer; export default ConnectedInputStateContainer;
View Options

lib/tunnelbroker/tunnelbroker-context.js

Show First 20 Lines • Show All 149 Lines • ▼ Show 20 Lines +uploadMultimedia: (
extras: MultimediaUploadExtras, extras: MultimediaUploadExtras,
callbacks: MultimediaUploadCallbacks, callbacks: MultimediaUploadCallbacks,
) => Promise<UploadMultimediaResult>, ) => Promise<UploadMultimediaResult>,
+blobServiceUpload: BlobServiceUploadAction, +blobServiceUpload: BlobServiceUploadAction,
+sendMultimediaMessage: ( +sendMultimediaMessage: (
input: SendMultimediaMessageInput, input: SendMultimediaMessageInput,
) => Promise<SendMessageResult>, ) => Promise<SendMessageResult>,
+sendTextMessage: (input: SendTextMessageInput) => Promise<SendMessageResult>, +sendTextMessage: (input: SendTextMessageInput) => Promise<SendMessageResult>,
+newThread: (request: ClientNewThreadRequest) => Promise<NewThreadResult>, +newThinThread: (request: ClientNewThreadRequest) => Promise<NewThreadResult>,
+textMessageCreationSideEffectsFunc: CreationSideEffectsFunc<RawTextMessageInfo>, +textMessageCreationSideEffectsFunc: CreationSideEffectsFunc<RawTextMessageInfo>,
}; };
type State = { type State = {
+pendingUploads: PendingMultimediaUploads, +pendingUploads: PendingMultimediaUploads,
}; };
class InputStateContainer extends React.PureComponent<Props, State> { class InputStateContainer extends React.PureComponent<Props, State> {
state: State = { state: State = {
▲ Show 20 Lines • Show All 380 Lines • ▼ Show 20 Lines if (!threadIsPending(threadInfo.id)) {
return Promise.resolve(threadInfo.id); return Promise.resolve(threadInfo.id);
} }
let threadCreationPromise = this.pendingThreadCreations.get(threadInfo.id); let threadCreationPromise = this.pendingThreadCreations.get(threadInfo.id);
if (!threadCreationPromise) { if (!threadCreationPromise) {
const calendarQuery = this.props.calendarQuery(); const calendarQuery = this.props.calendarQuery();
threadCreationPromise = createRealThreadFromPendingThread({ threadCreationPromise = createRealThreadFromPendingThread({
threadInfo, threadInfo,
dispatchActionPromise: this.props.dispatchActionPromise, dispatchActionPromise: this.props.dispatchActionPromise,
createNewThread: this.props.newThread, createNewThinThread: this.props.newThinThread,
sourceMessageID: threadInfo.sourceMessageID, sourceMessageID: threadInfo.sourceMessageID,
viewerID: this.props.viewerID, viewerID: this.props.viewerID,
calendarQuery, calendarQuery,
}); });
this.pendingThreadCreations.set(threadInfo.id, threadCreationPromise); this.pendingThreadCreations.set(threadInfo.id, threadCreationPromise);
} }
return threadCreationPromise; return threadCreationPromise;
} }
▲ Show 20 Lines • Show All 1,165 Lines • ▼ Show 20 Lines const ongoingMessageCreation = useSelector(
) === 'loading', ) === 'loading',
); );
const hasWiFi = useSelector(state => state.connectivity.hasWiFi); const hasWiFi = useSelector(state => state.connectivity.hasWiFi);
const calendarQuery = useCalendarQuery(); const calendarQuery = useCalendarQuery();
const callUploadMultimedia = useLegacyAshoatKeyserverCall(uploadMultimedia); const callUploadMultimedia = useLegacyAshoatKeyserverCall(uploadMultimedia);
const callBlobServiceUpload = useBlobServiceUpload(); const callBlobServiceUpload = useBlobServiceUpload();
const callSendMultimediaMessage = useSendMultimediaMessage(); const callSendMultimediaMessage = useSendMultimediaMessage();
const callSendTextMessage = useSendTextMessage(); const callSendTextMessage = useSendTextMessage();
const callNewThread = useNewThread(); const callNewThinThread = useNewThread();
const dispatchActionPromise = useDispatchActionPromise(); const dispatchActionPromise = useDispatchActionPromise();
const dispatch = useDispatch(); const dispatch = useDispatch();
const mediaReportsEnabled = useIsReportEnabled('mediaReports'); const mediaReportsEnabled = useIsReportEnabled('mediaReports');
const staffCanSee = useStaffCanSee(); const staffCanSee = useStaffCanSee();
const textMessageCreationSideEffectsFunc = const textMessageCreationSideEffectsFunc =
useMessageCreationSideEffectsFunc<RawTextMessageInfo>(messageTypes.TEXT); useMessageCreationSideEffectsFunc<RawTextMessageInfo>(messageTypes.TEXT);
return ( return (
<InputStateContainer <InputStateContainer
{...props} {...props}
viewerID={viewerID} viewerID={viewerID}
messageStoreMessages={messageStoreMessages} messageStoreMessages={messageStoreMessages}
ongoingMessageCreation={ongoingMessageCreation} ongoingMessageCreation={ongoingMessageCreation}
hasWiFi={hasWiFi} hasWiFi={hasWiFi}
mediaReportsEnabled={mediaReportsEnabled} mediaReportsEnabled={mediaReportsEnabled}
calendarQuery={calendarQuery} calendarQuery={calendarQuery}
uploadMultimedia={callUploadMultimedia} uploadMultimedia={callUploadMultimedia}
blobServiceUpload={callBlobServiceUpload} blobServiceUpload={callBlobServiceUpload}
sendMultimediaMessage={callSendMultimediaMessage} sendMultimediaMessage={callSendMultimediaMessage}
sendTextMessage={callSendTextMessage} sendTextMessage={callSendTextMessage}
newThread={callNewThread} newThinThread={callNewThinThread}
dispatchActionPromise={dispatchActionPromise} dispatchActionPromise={dispatchActionPromise}
dispatch={dispatch} dispatch={dispatch}
staffCanSee={staffCanSee} staffCanSee={staffCanSee}
textMessageCreationSideEffectsFunc={textMessageCreationSideEffectsFunc} textMessageCreationSideEffectsFunc={textMessageCreationSideEffectsFunc}
/> />
); );
}); });
export default ConnectedInputStateContainer; export default ConnectedInputStateContainer;
View Options

lib/types/dm-ops.js

Loading...
View Options

lib/types/redux-types.js

Loading...