Function fetchMessageNotifyType

lib/push/utils.js:108–168

(
  inputData: FetchMessageNotifyTypeInputData,
)

  +messageData: MessageData,
};
async function fetchMessageNotifyType(
  inputData: FetchMessageNotifyTypeInputData,
): Promise<Map<string, Array<FetchMessageNotifyTypeReturnInstance>>> {
  const {
    newMessageInfos,
    messageDatas,
    threadsToMessageIndices,
    userNotMemberOfSubthreads,
    fetchMessageInfoByID,
    userID,
  } = inputData;

  const promises: Array<Promise<?FetchMessageNotifyTypeReturnInstance>> = [];
  for (const [, messageIndices] of threadsToMessageIndices) {
    promises.push(
      ...messageIndices.map(async messageIndex => {
        const messageInfo = newMessageInfos[messageIndex];
        const { type } = messageInfo;
        const { getMessageNotifyType } = messageSpecs[type];

        let messageNotifyType: MessageNotifyType =
          messageNotifyTypes.SET_UNREAD;
        if (messageInfo.creatorID === userID) {
          // We don't need to notify the message author about their message
          messageNotifyType = messageNotifyTypes.NONE;
        } else if (getMessageNotifyType) {
          messageNotifyType = await getMessageNotifyType(messageInfo, {
            notifTargetUserID: userID,
            userNotMemberOfSubthreads,
            fetchMessageInfoByID,
          });
        }

        const messageData = messageDatas[messageIndex];
        return {
          messageNotifyType,
          messageInfo,
          messageData,
        };
      }),
    );
  }
  const results = await Promise.all(promises);

  const returnMap = new Map<
    string,
    Array<FetchMessageNotifyTypeReturnInstance>,
  >();
  for (const result of results) {
    if (!result) {
      continue;
    }
    let resultsForThread = returnMap.get(result.messageInfo.threadID);
    if (!resultsForThread) {
      resultsForThread = [];
      returnMap.set(result.messageInfo.threadID, resultsForThread);
    }
    resultsForThread.push(result);