module Katello
  class ContentViewDockerFilter < ContentViewFilter
    CONTENT_TYPE = 'docker'.freeze

    has_many :docker_rules, :dependent => :destroy, :foreign_key => :content_view_filter_id,
             :class_name => "Katello::ContentViewDockerFilterRule"
    validates_lengths_from_database

    # Returns a set of Pulp/MongoDB conditions to filter out manifests in the
    # repo repository that match parameters
    #
    # @param repo [Repository] a repository containing manifests to filter
    # @return [Array] an array of hashes with MongoDB conditions
    def generate_clauses(repo)
      manifest_tags = []

      self.docker_rules.each do |rule|
        manifest_tags.concat(query_manifests(repo, rule))
      end

      { "_id" => { "$in" => manifest_tags } } unless manifest_tags.empty?
    end

    def content_unit_pulp_ids(repo)
      manifest_tags = []
      self.docker_rules.each do |rule|
        manifest_tags.concat(query_manifests(repo, rule))
      end

      manifest_tags
    end

    protected

    def fetch_tag_pulp_ids(repo, rule, manifest_klass = DockerManifest)
      query_name = rule.name.tr("*", "%")
      tags_query = ::Katello::DockerTag.where(:id => ::Katello::RepositoryDockerTag.
                                              where(:repository_id => repo.id).select(:docker_tag_id)).
                                        where(:docker_taggable_type => manifest_klass.name).
                                        where("name ilike ?", query_name).
                                        select(:docker_taggable_id)

      query = manifest_klass.in_repositories(repo).where("id in (#{tags_query.to_sql})")
      names = query.all.collect do |manifest|
        manifest.docker_tags.where(:id => ::Katello::RepositoryDockerTag.
                                   where(:repository_id => repo.id).
                                   select(:docker_tag_id)).where("name ilike ?", query_name).
        all.collect do |tag|
          tag.pulp_id
        end
      end
      names.flatten.uniq
    end

    def query_manifests(repo, rule)
      (fetch_tag_pulp_ids(repo, rule, DockerManifest) + fetch_tag_pulp_ids(repo, rule, DockerManifestList)).flatten.uniq
    end
  end
end