Function upsertUser

server/src/routes/workos-webhooks.ts:241–313

* Upsert user to local users table * Called on user.created and user.updated events

(user: UserData)

 * Called on user.created and user.updated events
 */
async function upsertUser(user: UserData): Promise<void> {
  const pool = getPool();

  // Resolve names: prefer WorkOS values, but when WorkOS sends empty names,
  // preserve existing DB values or backfill from Slack mapping
  let firstName = user.first_name;
  let lastName = user.last_name;

  if (!firstName?.trim() || !lastName?.trim()) {
    const existing = await pool.query<{
      first_name: string | null;
      last_name: string | null;
      slack_real_name: string | null;
      slack_display_name: string | null;
    }>(
      `SELECT u.first_name, u.last_name, sm.slack_real_name, sm.slack_display_name
       FROM users u
       LEFT JOIN slack_user_mappings sm ON sm.slack_user_id = u.primary_slack_user_id
       WHERE u.workos_user_id = $1`,
      [user.id]
    );

    if (existing.rows.length > 0) {
      const row = existing.rows[0];

      // Keep existing DB names if WorkOS sends empty
      if (!firstName?.trim()) firstName = row.first_name;
      if (!lastName?.trim()) lastName = row.last_name;

      // Backfill from Slack if still empty
      if (!firstName?.trim() && !lastName?.trim()) {
        const slackName = row.slack_real_name || row.slack_display_name;
        if (slackName) {
          const parts = slackName.trim().split(/\s+/);
          firstName = parts[0];
          lastName = parts.length > 1 ? parts.slice(1).join(' ') : null;
        }
      }
    }
  }

  await pool.query(
    `INSERT INTO users (
      workos_user_id,
      email,
      first_name,
      last_name,
      email_verified,
      workos_created_at,
      workos_updated_at,
      created_at,
      updated_at
    ) VALUES ($1, $2, $3, $4, $5, $6, $7, NOW(), NOW())
    ON CONFLICT (workos_user_id) DO UPDATE SET
      email = EXCLUDED.email,
      first_name = COALESCE(NULLIF(TRIM(EXCLUDED.first_name), ''), users.first_name),
      last_name = COALESCE(NULLIF(TRIM(EXCLUDED.last_name), ''), users.last_name),
      email_verified = EXCLUDED.email_verified,