Page MenuHomePhorge
Files F32215063

D7562.1765157668.diff
No OneTemporary
Actions

Size
2 KB
Referenced Files
None
Subscribers
None

D7562.1765157668.diff
View Options

diff --git a/keyserver/src/fetchers/message-fetchers.js b/keyserver/src/fetchers/message-fetchers.js
--- a/keyserver/src/fetchers/message-fetchers.js
+++ b/keyserver/src/fetchers/message-fetchers.js
@@ -823,6 +823,68 @@
return content;
}
+async function fetchRelatedMessages(
+ viewer?: Viewer,
+ messages: $ReadOnlyMap<
+ string,
+ RawComposableMessageInfo | RawRobotextMessageInfo,
+ >,
+): Promise<$ReadOnlyArray<RawMessageInfo>> {
+ if (messages.size === 0) {
+ return [];
+ }
+ const originalMessageIDs = [...messages.keys()];
+
+ const sidebarSourceAndReactionsQuery = SQL`
+ SELECT m.id, m.thread AS threadID, m.content, m.time, m.type, m.creation,
+ m.user AS creatorID, m.target_message as targetMessageID,
+ stm.permissions AS subthread_permissions, up.id AS uploadID,
+ up.type AS uploadType, up.secret AS uploadSecret, up.extra AS uploadExtra
+ FROM messages m
+ LEFT JOIN uploads up ON up.container = m.id
+ LEFT JOIN memberships stm ON m.type = ${messageTypes.CREATE_SUB_THREAD}
+ AND stm.thread = m.content AND stm.user = m.user
+ WHERE m.target_message IN (${originalMessageIDs})
+ AND (
+ m.type = ${messageTypes.SIDEBAR_SOURCE}
+ OR m.type = ${messageTypes.REACTION}
+ )
+ `;
+
+ const editsQuery = SQL`
+ SELECT m.id, m.thread AS threadID, m.content, m.time, m.type, m.creation,
+ m.user AS creatorID, m.target_message as targetMessageID,
+ stm.permissions AS subthread_permissions, up.id AS uploadID,
+ up.type AS uploadType, up.secret AS uploadSecret, up.extra AS uploadExtra
+ FROM messages m2
+ INNER JOIN messages m ON m.id = (
+ SELECT m3.id FROM messages m3
+ WHERE m3.target_message = m2.id
+ AND m3.thread = m2.thread
+ AND m3.type = ${messageTypes.EDIT_MESSAGE}
+ ORDER BY time DESC, id DESC
+ LIMIT 1
+ )
+ LEFT JOIN uploads up ON up.container = m2.id
+ LEFT JOIN memberships stm ON m2.type = ${messageTypes.CREATE_SUB_THREAD}
+ AND stm.thread = m2.content AND stm.user = m2.user
+ WHERE m2.id IN (${originalMessageIDs})
+ `;
+
+ const [sidebarSourceAndReactions, edits] = await Promise.all([
+ dbQuery(sidebarSourceAndReactionsQuery),
+ dbQuery(editsQuery),
+ ]);
+
+ const resultRows = [...sidebarSourceAndReactions[0], ...edits[0]];
+
+ if (resultRows.length === 0) {
+ return [];
+ }
+ const SQLResult = await parseMessageSQLResult(resultRows, messages, viewer);
+ return SQLResult.map(item => item.rawMessageInfo);
+}
+
export {
fetchCollapsableNotifs,
fetchMessageInfos,
@@ -834,4 +896,5 @@
fetchThreadMessagesCount,
fetchLatestEditMessageContentByID,
fetchPinnedMessageInfos,
+ fetchRelatedMessages,
};

File Metadata

Mime Type
text/plain
Expires
Mon, Dec 8, 1:34 AM (7 h, 40 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
5846735
Default Alt Text
D7562.1765157668.diff (2 KB)

Event Timeline