Changeset View
Changeset View
Standalone View
Standalone View
keyserver/src/fetchers/message-fetchers.js
Show First 20 Lines • Show All 683 Lines • ▼ Show 20 Lines | > { | ||||
const result = await fetchMessageRowsByIDs([...requiredIDs]); | const result = await fetchMessageRowsByIDs([...requiredIDs]); | ||||
const messages = await parseMessageSQLResult(result, new Map(), viewer); | const messages = await parseMessageSQLResult(result, new Map(), viewer); | ||||
for (const message of messages) { | for (const message of messages) { | ||||
const { rawMessageInfo } = message; | const { rawMessageInfo } = message; | ||||
if (rawMessageInfo.id) { | if (rawMessageInfo.id) { | ||||
invariant( | invariant( | ||||
rawMessageInfo.type !== messageTypes.SIDEBAR_SOURCE && | rawMessageInfo.type !== messageTypes.SIDEBAR_SOURCE && | ||||
rawMessageInfo.type !== messageTypes.REACTION, | rawMessageInfo.type !== messageTypes.REACTION && | ||||
'SIDEBAR_SOURCE should not point to a SIDEBAR_SOURCE or REACTION', | rawMessageInfo.type !== messageTypes.EDIT_MESSAGE, | ||||
'SIDEBAR_SOURCE should not point to a SIDEBAR_SOURCE, REACTION or EDIT_MESSAGE', | |||||
); | ); | ||||
messagesByID.set(rawMessageInfo.id, rawMessageInfo); | messagesByID.set(rawMessageInfo.id, rawMessageInfo); | ||||
} | } | ||||
} | } | ||||
return messagesByID; | return messagesByID; | ||||
} | } | ||||
async function fetchMessageInfoByID( | async function fetchMessageInfoByID( | ||||
Show All 31 Lines |