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 @@ -21,6 +21,8 @@ messageTruncationStatus, type FetchMessageInfosResult, defaultMaxMessageAge, + type FetchPinnedMessagesRequest, + type FetchPinnedMessagesResult, } from 'lib/types/message-types.js'; import { threadPermissions } from 'lib/types/thread-types.js'; import { ServerError } from 'lib/utils/errors.js'; @@ -659,6 +661,53 @@ return result; } +async function fetchPinnedMessageInfos( + viewer: Viewer, + request: FetchPinnedMessagesRequest, +): Promise { + // The only message types that can be pinned are 0, 14, and 15 + // (text, images, and multimedia), so we don't need to worry about + // an admin pinning a message about creating a secret subchannel. This is + // why we don't check subthread permissions (as opposed to other queries). + const messageRowsQuery = 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, + NULL AS subthread_permissions, u.id AS uploadID, + u.type AS uploadType, u.secret AS uploadSecret, u.extra AS uploadExtra + FROM messages m + LEFT JOIN uploads u ON u.container = m.id + LEFT JOIN memberships mm ON mm.thread = m.thread AND mm.user = ${viewer.id} + WHERE m.thread = ${request.threadID} + AND m.pinned = 1 + AND JSON_EXTRACT(mm.permissions, ${visibleExtractString}) IS TRUE + ORDER BY m.pin_time DESC + `; + const [messageRows] = await dbQuery(messageRowsQuery); + if (messageRows.length === 0) { + return { pinnedMessages: [] }; + } + const derivedMessages = await fetchDerivedMessages(messageRows, viewer); + + const parsedPinnedMessages = await parseMessageSQLResult( + messageRows, + derivedMessages, + viewer, + ); + + const pinnedRawMessageInfos = parsedPinnedMessages.map( + message => message.rawMessageInfo, + ); + + const shimmedPinnedRawMessageInfos = shimUnsupportedRawMessageInfos( + pinnedRawMessageInfos, + viewer.platformDetails, + ); + + return { + pinnedMessages: shimmedPinnedRawMessageInfos, + }; +} + async function fetchDerivedMessages( rows: $ReadOnlyArray, viewer?: Viewer, @@ -729,4 +778,5 @@ fetchMessageInfoForEntryAction, fetchMessageInfoByID, fetchThreadMessagesCount, + fetchPinnedMessageInfos, }; diff --git a/lib/types/message-types.js b/lib/types/message-types.js --- a/lib/types/message-types.js +++ b/lib/types/message-types.js @@ -573,3 +573,11 @@ export type MessageStorePrunePayload = { +threadIDs: $ReadOnlyArray, }; + +export type FetchPinnedMessagesRequest = { + +threadID: string, +}; + +export type FetchPinnedMessagesResult = { + +pinnedMessages: $ReadOnlyArray, +};