Function getActiveThreads

apps/web/services/discord/threads.ts:17–67

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

import ChannelsService from 'services/channels';

export async function getActiveThreads({
  serverId,
  token,
  onboardingTimestamp,
  logger,
}: {
  serverId: string;
  token: string;
  onboardingTimestamp: Date;
  logger: Logger;
}) {
  logger.log({ getActiveThreads: 'started' });

  const [err, response] = await to(
    DiscordApi.getActiveThreads({
      serverId,
      token,
    })
  );
  if (err) {
    logger.error({ getActiveThreads: err });
    return;
  }

  logger.log({ 'threads found': response.threads.length });
  for (const thread of response.threads) {
    if (!thread.parent_id) {
      logger.error({ 'thread without channel': thread });
      continue;
    }
    if (
      thread.thread_metadata?.create_timestamp &&
      onboardingTimestamp > new Date(thread.thread_metadata.create_timestamp)
    ) {
      continue;
    }
    const channel = await ChannelsService.findByExternalId(thread.parent_id);
    if (!channel) {
      logger.error({ 'channel not found on linen db': thread });
      continue;
    }
    await processThread({
      thread,
      onboardingTimestamp,
      channel,
      token,
      logger,
    });
  }
  logger.log({ getActiveThreads: 'finished' });
}

export async function getArchivedThreads({
  channel,