Function syncUserToChaptersFromSlackChannels

server/src/slack/sync.ts:351–470

(
  workosUserId: string,
  slackUserId: string
)

 * Checks which channels they're in and adds them to corresponding committees.
 */
export async function syncUserToChaptersFromSlackChannels(
  workosUserId: string,
  slackUserId: string
): Promise<SyncUserChaptersResult> {
  const result: SyncUserChaptersResult = {
    workos_user_id: workosUserId,
    slack_user_id: slackUserId,
    channels_checked: 0,
    chapters_joined: 0,
    chapters_already_member: 0,
    chapters: [],
    errors: [],
  };

  if (!isSlackConfigured()) {
    result.errors.push('Slack is not configured (ADDIE_BOT_TOKEN missing)');
    return result;
  }

  try {
    logger.info(
      { workosUserId, slackUserId },
      'Starting user committee sync from Slack channels'
    );

    // Get all channels the user is a member of
    let userChannelIds: string[];
    try {
      userChannelIds = await getUserChannels(slackUserId);
    } catch (error) {
      const errorMessage = error instanceof Error ? error.message : 'Unknown error';

      // If Slack says the user doesn't exist, mark them deleted so we don't keep trying
      if (errorMessage.includes('user_not_found')) {
        logger.warn({ slackUserId }, 'Slack user no longer exists — marking as deleted');
        await slackDb.markSlackUserDeleted(slackUserId);
        result.errors.push('Slack user no longer exists');
        return result;
      }

      result.errors.push(`Failed to fetch user channels: ${errorMessage}`);
      logger.error({ error, slackUserId }, 'Failed to fetch user channels from Slack');
      return result;
    }
    result.channels_checked = userChannelIds.length;

    if (userChannelIds.length === 0) {
      logger.info({ slackUserId }, 'User is not a member of any channels');
      return result;
    }

    // Get all committees that have Slack channels configured
    const workingGroups = await workingGroupDb.listWorkingGroupsWithSlackChannel();

    // Get user's Slack info for membership record
    const slackMapping = await slackDb.getBySlackUserId(slackUserId);

    // Check each group with a Slack channel