Function autoLinkUnmappedSlackUsers

server/src/slack/sync.ts:712–786

()

 * Used by both the admin endpoint and the daily background job.
 */
export async function autoLinkUnmappedSlackUsers(): Promise<{
  linked: number;
  chapters_joined: number;
  organizations_assigned: number;
  pending_org_prospects_set: number;
  errors: number;
}> {
  // Ensure all current workspace members have rows before attempting to link.
  // Users who joined before the team_join listener was active have no row otherwise.
  const syncResult = await syncSlackUsers();
  if (syncResult.errors.length > 0) {
    logger.warn({ errors: syncResult.errors }, 'Slack user sync had errors; auto-link results may be incomplete');
  }

  // excludeOptedOut: false — opt-out applies to nudge notifications, not account linking.
  // Linking is a system operation; it doesn't send any messages.
  const unmappedSlack = await slackDb.getUnmappedUsers({
    excludeOptedOut: false,
    excludeRecentlyNudged: false,
  });

  const aaoEmailToUserId = await buildAaoEmailToUserIdMap();
  const mappedWorkosUserIds = await slackDb.getMappedWorkosUserIds();

  // Set pending_organization_id for unmapped Slack users whose email domain matches an org.
  // This is a DB-only operation and is safe regardless of whether Slack is configured.
  // It is idempotent and covers users who joined Slack before the listener was active.
  const backfillResult = await slackDb.backfillPendingOrganizations();

  let linked = 0;
  let chaptersJoined = 0;
  let orgsAssigned = 0;
  let errors = 0;

  for (const slackUser of unmappedSlack) {
    if (!slackUser.slack_email) continue;

    const workosUserId = aaoEmailToUserId.get(slackUser.slack_email.toLowerCase());
    if (!workosUserId || mappedWorkosUserIds.has(workosUserId)) continue;

    try {
      await slackDb.mapUser({
        slack_user_id: slackUser.slack_user_id,
        workos_user_id: workosUserId,
        mapping_source: 'email_auto',
      });
      linked++;
      mappedWorkosUserIds.add(workosUserId);
      // Clear cached admin status so Addie recognizes newly linked admins immediately.
      invalidateAdminStatusCache(slackUser.slack_user_id);

      const chapterResult = await syncUserToChaptersFromSlackChannels(workosUserId, slackUser.slack_user_id);
      chaptersJoined += chapterResult.chapters_joined;

      const orgResult = await checkAndAssignOrganizationByDomain(workosUserId);
      if (orgResult?.assigned) orgsAssigned++;
    } catch (err) {
      logger.error({ err, slackUserId: slackUser.slack_user_id, email: slackUser.slack_email }, 'Failed to auto-link user');