Function findThreadsByCursor

apps/web/services/threads/index.ts:311–370

({
  channelIds,
  sentAt,
  sort = 'desc',
  limit = PAGE_SIZE,
  direction,
  anonymizeUsers = false,
  anonymize,
  page,
}: {
  channelIds: string[];
  limit?: number;
  anonymizeUsers?: boolean;
  anonymize: AnonymizeType;
  page?: number;
} & FindThreadsByCursorType)

export default ThreadsServices;

export async function findThreadsByCursor({
  channelIds,
  sentAt,
  sort = 'desc',
  limit = PAGE_SIZE,
  direction,
  anonymizeUsers = false,
  anonymize,
  page,
}: {
  channelIds: string[];
  limit?: number;
  anonymizeUsers?: boolean;
  anonymize: AnonymizeType;
  page?: number;
} & FindThreadsByCursorType): Promise<ThreadsWithMessagesFull[]> {
  if (!channelIds.length) {
    return [];
  }

  const threads = await prisma.threads.findMany({
    take: limit,
    where: {
      ...(!!sentAt &&
        !!direction && { sentAt: { [direction]: BigInt(sentAt) } }),
      ...(!!page && { page }),
      channelId: {
        in: channelIds,
      },
      hidden: false,
      messageCount: {
        gte: 1,
      },
    },
    include: {
      messages: {
        include: {
          author: true,
          mentions: {
            include: {
              users: true,
            },
          },
          reactions: true,
          attachments: true,
        },
        orderBy: { sentAt: 'asc' },
      },
      channel: true,
    },
    ...(!!sort && { orderBy: { sentAt: sort } }),
  });
  return (
    anonymizeUsers
      ? threads.map((thread) =>
          anonymizeMessages(thread, anonymize as AnonymizeType)
        )
      : threads