Function tryAutoMapByEmail

server/src/slack/events.ts:249–334

* Try to auto-map a Slack user to a web user by email * Maps them if the email matches and neither account is already mapped

(slackUserId: string, email: string)

 * Maps them if the email matches and neither account is already mapped
 */
async function tryAutoMapByEmail(slackUserId: string, email: string): Promise<void> {
  try {
    const pool = getPool();

    // Look up the web user by email
    const result = await pool.query<{ workos_user_id: string }>(
      `SELECT workos_user_id FROM organization_memberships WHERE LOWER(email) = LOWER($1) LIMIT 1`,
      [email]
    );

    if (result.rows.length === 0) {
      logger.debug({ email }, 'No web account found for Slack user email');
      return;
    }

    const workosUserId = result.rows[0].workos_user_id;

    // Check if this WorkOS user is already mapped to a different Slack user
    const existingWorkosMapping = await slackDb.getByWorkosUserId(workosUserId);
    if (existingWorkosMapping) {
      logger.debug(
        { email, workosUserId, existingSlackUserId: existingWorkosMapping.slack_user_id },
        'Web user already mapped to different Slack account'
      );
      return;
    }

    // Check if this Slack user is already mapped (race condition guard)
    const existingSlackMapping = await slackDb.getBySlackUserId(slackUserId);
    if (existingSlackMapping?.workos_user_id) {
      logger.debug(
        { slackUserId, existingWorkosUserId: existingSlackMapping.workos_user_id },
        'Slack user already mapped to a web account'
      );
      return;
    }

    // Map the user
    await slackDb.mapUser({
      slack_user_id: slackUserId,
      workos_user_id: workosUserId,
      mapping_source: 'email_auto',
    });

    logger.info({ slackUserId, workosUserId, email }, 'Auto-mapped Slack user to web account by email');

    // Apply any pending marketing opt-in preference captured via Slack DM
    // Only apply if the user hasn't already made an explicit choice on the web
    if (existingSlackMapping?.pending_marketing_opt_in != null) {
      try {
        const { EmailPreferencesDatabase } = await import('../db/email-preferences-db.js');
        const emailPrefsDb = new EmailPreferencesDatabase();
        const wasSet = await emailPrefsDb.setMarketingOptInIfNotSet({
          workos_user_id: workosUserId,
          email,
          optIn: existingSlackMapping.pending_marketing_opt_in,
        });
        // Clear the pending flag now that it's been processed