Function addMessage

apps/web/services/slack/webhooks/processMessageEvents.ts:100–216

(
  channel: channels & {
    account: (accounts & { slackAuthorizations: slackAuthorizations[] }) | null;
  },
  event: SlackMessageEvent,
  logger: Logger
)

}

async function addMessage(
  channel: channels & {
    account: (accounts & { slackAuthorizations: slackAuthorizations[] }) | null;
  },
  event: SlackMessageEvent,
  logger: Logger
) {
  const thread_ts = event.thread_ts || event.ts;
  const accessToken = channel.account?.slackAuthorizations[0]?.accessToken!;

  const externalUserId = event.bot_id || event.user;
  if (!externalUserId) {
    return { error: 'missing externalUserId', event };
  }

  const user = await findOrCreateUserFromUserInfo(
    externalUserId,
    channel.accountId!,
    accessToken
  );

  const thread = await findOrCreateThread({
    externalThreadId: thread_ts,
    channelId: channel.id,
    sentAt: parseSlackSentAt(event.ts),
    lastReplyAt: parseSlackSentAt(event.ts),
    slug: slugify(event.text),
  });

  if (!!event.thread_ts) {
    thread.messageCount += 1;
    await updateSlackThread(thread.id, {
      messageCount: thread.messageCount,
    });
  }

  //TODO: create render text object and save that on creation of message
  // This way we don't have to fetch mentions on every message render
  let mentionUserIds = event.text.match(/<@(.*?)>/g) || [];
  let mentionUsersMap = mentionUserIds.map((m) =>
    m.replace('<@', '').replace('>', '')
  );
  const mentionUsers = await Promise.all(
    mentionUsersMap.map((userId) =>
      findOrCreateUserFromUserInfo(userId, channel.accountId!, accessToken)
    )
  );

  const mentionIds = mentionUsers.filter(Boolean).map((x) => x!.id);

  const param: Prisma.messagesUncheckedCreateInput = {
    body: event.text,
    channelId: channel.id,
    sentAt: tsToSentAt(event.ts),
    threadId: thread?.id,
    externalMessageId: event.ts,
    usersId: user?.id,
    messageFormat: MessageFormat.SLACK,