Function getArchivedThreads

apps/web/services/discord/threads.ts:69–122

({
  channel,
  token,
  onboardingTimestamp,
  logger,
}: {
  channel: channels;
  token: string;
  onboardingTimestamp: Date;
  logger: Logger;
})

}

export async function getArchivedThreads({
  channel,
  token,
  onboardingTimestamp,
  logger,
}: {
  channel: channels;
  token: string;
  onboardingTimestamp: Date;
  logger: Logger;
}) {
  if (!channel.externalChannelId) {
    return;
  }
  logger.log({ getArchivedThreads: 'started' });
  let has_more;
  do {
    const [err, result] = await to(
      DiscordApi.getArchivedPublicThreads({
        externalChannelId: channel.externalChannelId,
        limit: LIMIT,
        before: has_more,
        token,
      })
    );
    if (err) {
      logger.error({ getArchivedThreads: err });
      return;
    }
    const response = result as DiscordArchivedPublicThreads;

    has_more = response.has_more
      ? response.threads[response.threads.length - 1].thread_metadata
          ?.create_timestamp
      : null;

    for (const thread of response.threads) {
      if (
        thread.thread_metadata?.create_timestamp &&
        onboardingTimestamp > new Date(thread.thread_metadata.create_timestamp)
      ) {
        continue;
      }
      await processThread({
        thread,
        onboardingTimestamp,
        channel,
        token,
        logger,
      });
    }
  } while (has_more);
  logger.log({ getArchivedThreads: 'finished' });
}

async function processThread({
  thread,