Function eventNewMessage

apps/web/services/events/eventNewMessage.ts:31–103

({
  channelId,
  messageId,
  threadId,
  imitationId,
  mentions = [],
  mentionNodes = [],
  communityId,
  message,
  userId,
  isLinenMessage,
}: NewMessageEvent)

};

export async function eventNewMessage({
  channelId,
  messageId,
  threadId,
  imitationId,
  mentions = [],
  mentionNodes = [],
  communityId,
  message,
  userId,
  isLinenMessage,
}: NewMessageEvent) {
  const event = {
    channelId,
    messageId,
    threadId,
    imitationId,
    isThread: false,
    isReply: true,
    message,
  };

  const channel = await ChannelsService.getChannelAndMembersWithAuth(channelId);

  const promises: Promise<any>[] = [
    eventNewMentions({
      mentions,
      mentionNodes,
      channelId,
      threadId,
      authorId: userId,
    }),
    ...resolvePush({ channel, userId, event, communityId }),
  ];

  if (isLinenMessage) {
    promises.push(
      ...[
        createNotificationJob(messageId, {
          ...event,
          communityId,
          mentions,
          mentionNodes,
        }),
        createTwoWaySyncJob({ ...event, event: 'newMessage', id: messageId }),
        matrixNewMessage(event),
        ThreadsServices.updateMetrics({ messageId, threadId }),
        UserThreadStatusService.markAsUnread(threadId, userId),
        UserThreadStatusService.markAsUnmutedForMentionedUsers(
          threadId,
          mentions.map((mention) => mention.usersId)
        ),
      ]
    );
    if (channel?.type === ChannelType.DM) {
      promises.push(
        ChannelsService.unarchiveChannel({ channelId: channel.id })
      );