Function createChannels

apps/web/services/slack/sync/syncChannels.ts:7–69

({
  slackTeamId,
  token,
  accountId,
  getSlackChannels,
  joinChannel,
  hideChannels,
  shouldJoinChannel,
  logger,
}: {
  slackTeamId: string;
  token: string;
  accountId: string;
  getSlackChannels: GetSlackChannelsFnType;
  joinChannel: JoinChannelFnType;
  hideChannels: boolean;
  shouldJoinChannel: boolean;
  logger: Logger;
})

import { ChannelType } from '@linen/database';

export async function createChannels({
  slackTeamId,
  token,
  accountId,
  getSlackChannels,
  joinChannel,
  hideChannels,
  shouldJoinChannel,
  logger,
}: {
  slackTeamId: string;
  token: string;
  accountId: string;
  getSlackChannels: GetSlackChannelsFnType;
  joinChannel: JoinChannelFnType;
  hideChannels: boolean;
  shouldJoinChannel: boolean;
  logger: Logger;
}) {
  try {
    const channelsResponse = await getSlackChannels(slackTeamId, token);
    if (!channelsResponse.body?.channels) {
      return [];
    }
    const channels = await Promise.all(
      channelsResponse.body.channels.map((channel) =>
        ChannelsService.findOrCreateChannel({
          externalChannelId: channel.id,
          channelName: channel.name,
          accountId,
          hidden: hideChannels,
          ...(channel.is_private ? { type: ChannelType.PRIVATE } : {}),
        })
      )
    );
    logger.log({ 'Joining channels': 'started' });
    let sleeping = sleep(60 * 1000);
    let counter = 0;
    const filteredChannels = channels.filter(
      (c) => c.externalPageCursor !== 'completed'
    );

    for (let channel of filteredChannels) {
      counter++;
      if (shouldJoinChannel && channel.externalChannelId) {
        await joinChannel(channel.externalChannelId, token);
      }
      // Slack's api can handle bursts
      // so only wait for requests if there are more than 50 messages
      if (counter >= 50) {
        await sleeping;
        counter = 0;
        sleeping = sleep(60 * 1000);
      }
    }
    logger.log({ 'Joining channels': 'finished' });

    return channels;