# frozen_string_literal: true

module Jobs
  class UnassignNotification < ::Jobs::Base
    def execute(args)
      raise Discourse::InvalidParameters.new(:topic_id) if args[:topic_id].nil?
      raise Discourse::InvalidParameters.new(:assigned_to_id) if args[:assigned_to_id].nil?
      raise Discourse::InvalidParameters.new(:assigned_to_type) if args[:assigned_to_type].nil?

      topic = Topic.find(args[:topic_id])
      assigned_to_users = args[:assigned_to_type] == "User" ? [User.find(args[:assigned_to_id])] : Group.find(args[:assigned_to_id]).users

      assigned_to_users.each do |user|
        Assigner.publish_topic_tracking_state(topic, user.id)

        Notification.where(
          notification_type: Notification.types[:assigned] || Notification.types[:custom],
          user_id: user.id,
          topic_id: topic.id,
        ).where("data like '%discourse_assign.assign_notification%' OR data like '%discourse_assign.assign_group_notification%'").destroy_all
      end
    end
  end
end