Method upsertSlackUser

server/src/db/slack-db.ts:25–62

* Upsert a Slack user from sync

(user: {
    slack_user_id: string;
    slack_email: string | null;
    slack_display_name: string | null;
    slack_real_name: string | null;
    slack_is_bot: boolean;
    slack_is_deleted: boolean;
    slack_tz_offset?: number | null;
  })

   * Upsert a Slack user from sync
   */
  async upsertSlackUser(user: {
    slack_user_id: string;
    slack_email: string | null;
    slack_display_name: string | null;
    slack_real_name: string | null;
    slack_is_bot: boolean;
    slack_is_deleted: boolean;
    slack_tz_offset?: number | null;
  }): Promise<SlackUserMapping> {
    const result = await query<SlackUserMapping>(
      `INSERT INTO slack_user_mappings (
        slack_user_id, slack_email, slack_display_name, slack_real_name,
        slack_is_bot, slack_is_deleted, slack_tz_offset, last_slack_sync_at
      ) VALUES ($1, $2, $3, $4, $5, $6, $7, NOW())
      ON CONFLICT (slack_user_id)
      DO UPDATE SET
        slack_email = EXCLUDED.slack_email,
        slack_display_name = EXCLUDED.slack_display_name,
        slack_real_name = EXCLUDED.slack_real_name,
        slack_is_bot = EXCLUDED.slack_is_bot,
        slack_is_deleted = EXCLUDED.slack_is_deleted,
        slack_tz_offset = EXCLUDED.slack_tz_offset,
        last_slack_sync_at = NOW(),
        updated_at = NOW()
      RETURNING *`,
      [
        user.slack_user_id,
        user.slack_email,
        user.slack_display_name,
        user.slack_real_name,
        user.slack_is_bot,
        user.slack_is_deleted,
        user.slack_tz_offset ?? null,
      ]
    );

    return result.rows[0];
  }

  /**
   * Mark a Slack user as deleted (e.g. when the Slack API returns user_not_found)