Function getThreads

apps/web/services/ssr/channels.ts:129–182

({
  channelId,
  anonymize,
  anonymizeUsers,
  page,
}: {
  channelId: string;
  anonymize: AnonymizeType;
  anonymizeUsers: boolean;
  page?: string;
})

}

async function getThreads({
  channelId,
  anonymize,
  anonymizeUsers,
  page,
}: {
  channelId: string;
  anonymize: AnonymizeType;
  anonymizeUsers: boolean;
  page?: string;
}) {
  if (!!page) {
    const threads = (
      await findThreadsByCursor({
        channelIds: [channelId],
        page: parsePage(page),
        anonymize,
        anonymizeUsers,
      })
    ).sort(sortBySentAtAsc);

    return {
      nextCursor: {
        next: null,
        prev: null,
      },
      threads,
    };
  }

  const { sort, direction, sentAt } = decodeCursor(undefined);

  const threads = (
    await findThreadsByCursor({
      channelIds: [channelId],
      sentAt,
      sort,
      direction,
      anonymize,
      anonymizeUsers,
    })
  ).sort(sortBySentAtAsc);

  const nextCursor = await buildCursor({
    sort,
    direction,
    sentAt,
    pathCursor: page,
    total: threads.length,
    prevDate: threads[0]?.sentAt,
    nextDate: threads[threads.length - 1]?.sentAt,
  });
  return { nextCursor, threads };
}

function isPageNotValid(page: string, pages: number | null) {
  return !isPageValid(page, pages);