[lib] fix creating Identity Search socket
ClosedPublic
Actions

Show All 32 Lines	(threadInfo, messageStore) => {
if (!thread \|\| !viewerID \|\| thread.messageIDs.length === 0) {		if (!thread \|\| !viewerID \|\| thread.messageIDs.length === 0) {
return {		return {
lastUpdatedAtLeastTime: threadInfo.creationTime,		lastUpdatedAtLeastTime: threadInfo.creationTime,
lastUpdatedAtMostTime: threadInfo.creationTime,		lastUpdatedAtMostTime: threadInfo.creationTime,
lastUpdatedTime: () => Promise.resolve(threadInfo.creationTime),		lastUpdatedTime: () => Promise.resolve(threadInfo.creationTime),
};		};
}		}

		const mostRecentMessage = messageStore.messages[thread.messageIDs[0]];
		const lastUpdatedAtMostTime =
		mostRecentMessage?.time ?? threadInfo.creationTime;

// We default to the most recent message time.		// We default to the most recent message time.
// - This default will only be relevant in the case that		// - This default will only be relevant in the case that
// getLastUpdatedTime is implemented for every message in the loop		// getLastUpdatedTime is implemented for every message in the loop
// below, and doesn't return a number for any of them. Otherwise		// below, and doesn't return a number for any of them. Otherwise
// lastUpdatedAtLeastTime will be set to the most recent message that		// lastUpdatedAtLeastTime will be set to the most recent message that
// returns a number, or whose message spec doesn't implement		// returns a number, or whose message spec doesn't implement
// getLastUpdatedTime.		// getLastUpdatedTime.
// - We default to the most recent message time because the best		// - We default to the most recent message time because the best
// alternative is the thread creation time, but this is likely very		// alternative is the thread creation time, but this is likely very
// far in the past.		// far in the past.
const mostRecentMessage = messageStore.messages[thread.messageIDs[0]];		let lastUpdatedAtLeastTime = lastUpdatedAtMostTime;
let lastUpdatedAtLeastTime =
mostRecentMessage?.time ?? threadInfo.creationTime;

const getLastUpdatedTimeParams = {		const getLastUpdatedTimeParams = {
threadInfo,		threadInfo,
viewerID,		viewerID,
getMessageAuthor: (messageID: string) =>		getMessageAuthor: (messageID: string) =>
baseGetMessageAuthor(messageID, messageStore),		baseGetMessageAuthor(messageID, messageStore),
};		};

let lastUpdatedTime: ?() => Promise<?number>;		let lastUpdatedTime: ?() => Promise<?number>;
let highestTimestamp: ?number;
for (const messageID of thread.messageIDs) {		for (const messageID of thread.messageIDs) {
const messageInfo = messageStore.messages[messageID];		const messageInfo = messageStore.messages[messageID];
if (!messageInfo) {		if (!messageInfo) {
continue;		continue;
}		}

// We call getLastUpdatedTime on the message spec. It can return either		// We call getLastUpdatedTime on the message spec. It can return either
// ?number or () => Promise<?number>. If the message spec doesn't		// ?number or () => Promise<?number>. If the message spec doesn't
// implement getLastUpdatedTime, then we default to messageInfo.time.		// implement getLastUpdatedTime, then we default to messageInfo.time.
const { getLastUpdatedTime } = messageSpecs[messageInfo.type];		const { getLastUpdatedTime } = messageSpecs[messageInfo.type];
const lastUpdatedTimeResult = getLastUpdatedTime		const lastUpdatedTimeResult = getLastUpdatedTime
? getLastUpdatedTime(messageInfo, getLastUpdatedTimeParams)		? getLastUpdatedTime(messageInfo, getLastUpdatedTimeParams)
: messageInfo.time;		: messageInfo.time;

// We only need to consider the first positive number result because
// thread.messageIDs is ordered chronologically.
if (
!highestTimestamp &&
lastUpdatedTimeResult &&
typeof lastUpdatedTimeResult === 'number'
) {
highestTimestamp = lastUpdatedTimeResult;
}

// We rely on the fact that thread.messageIDs is ordered chronologically		// We rely on the fact that thread.messageIDs is ordered chronologically
// (newest first) to chain together lastUpdatedTime. An older message's		// (newest first) to chain together lastUpdatedTime. An older message's
// lastUpdatedTime is only considered if all of the newer messages		// lastUpdatedTime is only considered if all of the newer messages
// return falsey.		// return falsey.
const prevLastUpdatedTime = lastUpdatedTime;		const prevLastUpdatedTime = lastUpdatedTime;
lastUpdatedTime = async () => {		lastUpdatedTime = async () => {
if (prevLastUpdatedTime) {		if (prevLastUpdatedTime) {
const earlierChecks = await prevLastUpdatedTime();		const earlierChecks = await prevLastUpdatedTime();
Show All 27 Lines	(threadInfo, messageStore) => {
const earlierChecks = await lastUpdatedTime();		const earlierChecks = await lastUpdatedTime();
if (earlierChecks) {		if (earlierChecks) {
return earlierChecks;		return earlierChecks;
}		}
}		}
return lastUpdatedAtLeastTime;		return lastUpdatedAtLeastTime;
};		};

const lastUpdatedAtMostTime = highestTimestamp ?? threadInfo.creationTime;

return {		return {
lastUpdatedAtLeastTime,		lastUpdatedAtLeastTime,
lastUpdatedAtMostTime,		lastUpdatedAtMostTime,
lastUpdatedTime: lastUpdatedWithFallback,		lastUpdatedTime: lastUpdatedWithFallback,
};		};
},		},
[viewerID, baseGetMessageAuthor],		[viewerID, baseGetMessageAuthor],
);		);
}		}

export { useGetLastUpdatedTimes };		export { useGetLastUpdatedTimes };

[lib] fix creating Identity Search socketClosedPublicActions

Details

Diff Detail

Event Timeline

Revision ContentsChangeset List

Diff 47398

lib/identity-search/identity-search-context.js

[lib] fix creating Identity Search socket
ClosedPublic
Actions

Revision Contents
Changeset List