ee-threads.ts

  const mailsWithoutReplyId = inboxEmails.filter((email) => {
    return email.replyToMessageId === null;
  });

  const groupedEmails: EmailThread[] = [];

  for (const mailWithoutReplyId of mailsWithoutReplyId) {
    const chain = recursiveExtractReplies([mailWithoutReplyId]);

    const emails = chain
      .sort((a, b) => {
        return a.sentAt.getTime() - b.sentAt.getTime();
      });

      groupedEmails.push({
        emails,
        lead: mailWithoutReplyId.lead,
        emailAccount: mailWithoutReplyId.emailAccount,
        campaign: mailWithoutReplyId.campaign,
      });
  }

  const recursiveExtractReplies = (inboxEmails: InboxEmailWithExtraInfo[]) => {
    const finalArray: InboxEmailWithExtraInfo[] = [...inboxEmails];

    for (const actualEmail of inboxEmails) {
      let replies = inboxEmails.filter(
        (email) => email.replyToMessageId === actualEmail.messageId
      );

      const subReplies = recursiveExtractReplies(replies);

      if (subReplies) {
        finalArray.push(...subReplies);
      }
    }

    return finalArray;
  };