Function eventNewThread

apps/web/services/events/eventNewThread.ts:31–114

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

};

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

  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: 'newThread', id: messageId }),
        matrixNewThread(event),
      ]
    );
    if (channel?.type === ChannelType.DM) {
      promises.push(
        ChannelsService.unarchiveChannel({ channelId: channel.id })
      );
    }

    const llm = channel?.channelsIntegration.find(
      (ci) => ci.type === channelsIntegrationType.LLM
    );
    if (channel?.accountId && llm?.data) {