Function findThreadWithMessages

apps/web/services/threads/index.ts:518–562

({
  incrementId,
  id,
}: {
  incrementId?: number;
  id?: string;
})

};

const findThreadWithMessages = async ({
  incrementId,
  id,
}: {
  incrementId?: number;
  id?: string;
}) => {
  const MESSAGES_ORDER_BY = 'asc';
  return await prisma.threads
    .findUnique({
      where: { incrementId, id },
      include: {
        messages: {
          include: {
            author: true,
            //Don't like how it includes mentions when I just want users
            // waiting on this to flatten it out
            // https://github.com/prisma/prisma/issues/9719
            mentions: {
              include: {
                users: true,
              },
            },
            reactions: true,
            attachments: true,
          },
          orderBy: {
            sentAt: MESSAGES_ORDER_BY,
          },
        },
        channel: {
          include: {
            account: { select: { anonymize: true, anonymizeUsers: true } },
          },
        },
      },
    })
    .then((thread) => {
      const account = thread?.channel.account;
      if (thread && account?.anonymizeUsers) {
        return anonymizeMessages(thread, account.anonymize as AnonymizeType);
      }
      return thread;
    });
};

export const updateSlackThread = async (
  id: string,