Page MenuHomePhabricator
Differential D13350

[native][web] use tunnelbroker for online status of thick threaded entries instead of keyserver
ClosedPublic
Actions

Authored by will on Sep 16 2024, 1:36 AM.
Tags
None
Referenced Files
Unknown Object (File)
Wed, Mar 12, 9:21 PM
Unknown Object (File)
Mon, Mar 10, 3:39 AM
Unknown Object (File)
Mon, Mar 10, 12:09 AM
Unknown Object (File)
Fri, Feb 28, 5:46 AM
Unknown Object (File)
Fri, Feb 28, 5:46 AM
Unknown Object (File)
Fri, Feb 28, 5:46 AM
Unknown Object (File)
Fri, Feb 28, 5:02 AM
Unknown Object (File)
Thu, Feb 20, 2:34 PM
View All 57 Files
Subscribers
None

Details

Reviewers
marcin
ashoat
tomek
Commits
rCOMM264bde56ab4a: [native][web] use tunnelbroker for online status of thick threaded entries…
Summary

Entry online status shouldn't be decided by keyserver for thick threaded entries. We're changing it to use tunnelbroker status instead

Depends on D13349

Test Plan

console logged on native. Will figure out how to test this on web

Diff Detail

Repository
rCOMM Comm
Lint
Lint Not Applicable
Unit
Tests Not Applicable

Revision Contents
Changeset List

PathSize
native/
calendar/
11 lines
web/
calendar/
10 lines

Diff 44256

View Options

native/calendar/entry.react.js

Show First 20 Lines • Show All 879 Lines • ▼ Show 20 Lines): Promise<$ReadOnlyArray<RawMessageInfo>> {
if (resultRows.length === 0) { if (resultRows.length === 0) {
return []; return [];
} }
const SQLResult = await parseMessageSQLResult(resultRows, messages, viewer); const SQLResult = await parseMessageSQLResult(resultRows, messages, viewer);
return SQLResult.map(item => item.rawMessageInfo); return SQLResult.map(item => item.rawMessageInfo);
} }
async function rawMessageInfoForRowsAndRelatedMessages(
rows: $ReadOnlyArray<Object>,
viewer?: Viewer,
): Promise<$ReadOnlyArray<RawMessageInfo>> {
const parsedResults = await parseMessageSQLResult(rows, new Map(), viewer);
const rawMessageInfoMap = new Map<
string,
RawComposableMessageInfo | RawRobotextMessageInfo,
>();
for (const message of parsedResults) {
const { rawMessageInfo } = message;
if (
rawMessageInfo.type === messageTypes.SIDEBAR_SOURCE ||
rawMessageInfo.type === messageTypes.REACTION ||
rawMessageInfo.type === messageTypes.EDIT_MESSAGE
) {
continue;
}
invariant(rawMessageInfo.id, 'rawMessageInfo.id should not be null');
rawMessageInfoMap.set(rawMessageInfo.id, rawMessageInfo);
}
const rawMessageInfos = parsedResults.map(item => item.rawMessageInfo);
const rawRelatedMessageInfos = await fetchRelatedMessages(
viewer,
rawMessageInfoMap,
);
return [...rawMessageInfos, ...rawRelatedMessageInfos];
}
export { export {
fetchCollapsableNotifs, fetchCollapsableNotifs,
fetchMessageInfos, fetchMessageInfos,
fetchMessageInfosSince, fetchMessageInfosSince,
getMessageFetchResultFromRedisMessages, getMessageFetchResultFromRedisMessages,
fetchMessageInfoForLocalID, fetchMessageInfoForLocalID,
fetchMessageInfoForEntryAction, fetchMessageInfoForEntryAction,
fetchMessageInfoByID, fetchMessageInfoByID,
fetchThreadMessagesCount, fetchThreadMessagesCount,
fetchLatestEditMessageContentByID, fetchLatestEditMessageContentByID,
fetchPinnedMessageInfos, fetchPinnedMessageInfos,
fetchRelatedMessages, fetchRelatedMessages,
rawMessageInfoForRowsAndRelatedMessages,
}; };
View Options

web/calendar/entry.react.js

Show First 20 Lines • Show All 879 Lines • ▼ Show 20 Lines): Promise<$ReadOnlyArray<RawMessageInfo>> {
if (resultRows.length === 0) { if (resultRows.length === 0) {
return []; return [];
} }
const SQLResult = await parseMessageSQLResult(resultRows, messages, viewer); const SQLResult = await parseMessageSQLResult(resultRows, messages, viewer);
return SQLResult.map(item => item.rawMessageInfo); return SQLResult.map(item => item.rawMessageInfo);
} }
async function rawMessageInfoForRowsAndRelatedMessages(
rows: $ReadOnlyArray<Object>,
viewer?: Viewer,
): Promise<$ReadOnlyArray<RawMessageInfo>> {
const parsedResults = await parseMessageSQLResult(rows, new Map(), viewer);
const rawMessageInfoMap = new Map<
string,
RawComposableMessageInfo | RawRobotextMessageInfo,
>();
for (const message of parsedResults) {
const { rawMessageInfo } = message;
if (
rawMessageInfo.type === messageTypes.SIDEBAR_SOURCE ||
rawMessageInfo.type === messageTypes.REACTION ||
rawMessageInfo.type === messageTypes.EDIT_MESSAGE
) {
continue;
}
invariant(rawMessageInfo.id, 'rawMessageInfo.id should not be null');
rawMessageInfoMap.set(rawMessageInfo.id, rawMessageInfo);
}
const rawMessageInfos = parsedResults.map(item => item.rawMessageInfo);
const rawRelatedMessageInfos = await fetchRelatedMessages(
viewer,
rawMessageInfoMap,
);
return [...rawMessageInfos, ...rawRelatedMessageInfos];
}
export { export {
fetchCollapsableNotifs, fetchCollapsableNotifs,
fetchMessageInfos, fetchMessageInfos,
fetchMessageInfosSince, fetchMessageInfosSince,
getMessageFetchResultFromRedisMessages, getMessageFetchResultFromRedisMessages,
fetchMessageInfoForLocalID, fetchMessageInfoForLocalID,
fetchMessageInfoForEntryAction, fetchMessageInfoForEntryAction,
fetchMessageInfoByID, fetchMessageInfoByID,
fetchThreadMessagesCount, fetchThreadMessagesCount,
fetchLatestEditMessageContentByID, fetchLatestEditMessageContentByID,
fetchPinnedMessageInfos, fetchPinnedMessageInfos,
fetchRelatedMessages, fetchRelatedMessages,
rawMessageInfoForRowsAndRelatedMessages,
}; };