pulibrary / pdc_describe / 4e4e59fc-9df4-4838-9fd4-6c7ea33cdb7c

class WorkActivityNotification < ApplicationRecord

  belongs_to :work_activity

  belongs_to :user

  after_create do

    if send_message?

      mailer = NotificationMailer.with(user:, work_activity:)

      work = work_activity.work

      delay = wait_time

      from_state = check_from_state(work)

      if work.state == "draft" && from_state == :none # draft event

        new_submission_message = mailer.new_submission_message

        new_submission_message.deliver_later(wait: delay) unless Rails.env.development?

      elsif work.state == "draft" && from_state == :awaiting_approval # revert_to_draft event

        reject_message = mailer.reject_message

        reject_message.deliver_later(wait: delay) unless Rails.env.development?

      elsif work.state == "awaiting_approval" && from_state == :draft # complete_submission

        review_message = mailer.review_message

        review_message.deliver_later(wait: delay) unless Rails.env.development?

      else

        message = mailer.build_message

        message.deliver_later(wait: delay) unless Rails.env.development?

      end

    end

  end

  private

    def wait_time

      work = work_activity.work

      if work.state == "approved"

        90.minutes

      else

        10.seconds

      end

    end

    def check_from_state(work) # check the previous state of the work

      work_states = UserWork.where(work_id: work.id).sort_by(&:created_at).reverse

      if work_states.count > 1

        work_states[1].state.to_sym

      else

        :none

      end

    end

    def direct_message?

      @direct_message ||= work_activity.activity_type == WorkActivity::MESSAGE && work_activity.message.include?("@#{user.uid}")

    end

    def send_message?

      return true if direct_message? # always send a direct message

      return false unless user.email_messages_enabled? # do not send message if all emails are disabled

      work = work_activity.work

      if work.resource.subcommunities.count > 1

        subcommunities_can_send = work.resource.subcommunities.map { |subcommunity| send_message_for_community?(subcommunity) }

        subcommunities_can_send.any?

      else

        send_message_for_community?(work.resource.subcommunities.first)

      end

    end

    def send_message_for_community?(subcommunity)

      group.messages_enabled_for?(user:, subcommunity:)

    end

    def group

      @group ||= work_activity.work.group

    end

end