discourse/app/models/email_log.rb

# frozen_string_literal: true

class EmailLog < ActiveRecord::Base
  CRITICAL_EMAIL_TYPES ||= Set.new %w{
    account_created
    admin_login
    confirm_new_email
    confirm_old_email
    confirm_old_email_add
    forgot_password
    notify_old_email
    notify_old_email_add
    signup
    signup_after_approval
  }

  belongs_to :user
  belongs_to :post
  belongs_to :smtp_group, class_name: 'Group'

  has_one :topic, through: :post

  validates :email_type, :to_address, presence: true

  scope :bounced, -> { where(bounced: true) }

  scope :addressed_to_user, ->(user) do
    where(<<~SQL, user_id: user.id)
      EXISTS(
        SELECT 1
        FROM user_emails
        WHERE user_emails.user_id = :user_id AND
        email_logs.to_address = user_emails.email
      )
    SQL
  end

  after_create do
    # Update last_emailed_at if the user_id is present and email was sent
    User.where(id: user_id).update_all("last_emailed_at = CURRENT_TIMESTAMP") if user_id.present?
  end

  def self.unique_email_per_post(post, user)
    return yield unless post && user

    DistributedMutex.synchronize("email_log_#{post.id}_#{user.id}") do
      if where(post_id: post.id, user_id: user.id).exists?
        nil
      else
        yield
      end
    end
  end

  def self.reached_max_emails?(user, email_type = nil)
    return false if SiteSetting.max_emails_per_day_per_user == 0 || CRITICAL_EMAIL_TYPES.include?(email_type)

    count = where('created_at > ?', 1.day.ago)
      .where(user_id: user.id)
      .count

    count >= SiteSetting.max_emails_per_day_per_user
  end

  def self.count_per_day(start_date, end_date)
    where("created_at BETWEEN ? AND ?", start_date, end_date)
      .group("DATE(created_at)")
      .order("DATE(created_at)")
      .count
  end

  def self.for(reply_key)
    self.find_by(reply_key: reply_key)
  end

  def self.last_sent_email_address
    self.where(email_type: "signup")
      .order(created_at: :desc)
      .limit(1)
      .pluck(:to_address)
      .first
  end

  def bounce_key
    super&.delete('-')
  end

end

# == Schema Information
#
# Table name: email_logs
#
#  id            :integer          not null, primary key
#  to_address    :string           not null
#  email_type    :string           not null
#  user_id       :integer
#  created_at    :datetime         not null
#  updated_at    :datetime         not null
#  post_id       :integer
#  bounce_key    :uuid
#  bounced       :boolean          default(FALSE), not null
#  message_id    :string
#  smtp_group_id :integer
#
# Indexes
#
#  idx_email_logs_on_smtp_group_id  (smtp_group_id)
#  index_email_logs_on_bounce_key   (bounce_key) UNIQUE WHERE (bounce_key IS NOT NULL)
#  index_email_logs_on_bounced      (bounced)
#  index_email_logs_on_created_at   (created_at)
#  index_email_logs_on_message_id   (message_id)
#  index_email_logs_on_post_id      (post_id)
#  index_email_logs_on_user_id      (user_id)
#