Katello/katello

module Katello
  class Api::V2::RepositoriesBulkActionsController < Api::V2::ApiController
    before_action :find_repositories

    api :PUT, "/repositories/bulk/destroy", N_("Destroy one or more repositories")
    param :ids, Array, :desc => N_("List of repository ids"), :required => true
    def destroy_repositories
      deletion_authorized_repositories = @repositories.deletable
      unpromoted_repos = deletion_authorized_repositories.reject { |repo| repo.promoted? && repo.content_views.generated_for_none.exists? }
      unpromoted_repos_non_last_affected_repo = unpromoted_repos.reject { |repo| repo.filters.any? { |filter| filter.repositories.size == 1 } }
      messages1 = format_bulk_action_messages(
          :success    => "",
          :error      => _("You do not have permissions to delete %s"),
          :models     => @repositories,
          :authorized => deletion_authorized_repositories
      )

      messages2 = format_bulk_action_messages(
          :success    => "",
          :error      => _("Repository %s cannot be deleted since it has already been included in a published Content View. Use repository details page to delete"),
          :models     => deletion_authorized_repositories,
          :authorized => unpromoted_repos
      )

      messages3 = format_bulk_action_messages(
        :success    => "",
        :error      => _("Repository %s cannot be deleted since it is the last affected repository in a filter. Use repository details page to delete."),
        :models     => unpromoted_repos,
        :authorized => unpromoted_repos_non_last_affected_repo
      )

      errors = messages1[:error] + messages2[:error] + messages3[:error]

      task = nil
      if unpromoted_repos_non_last_affected_repo.any?
        task = async_task(::Actions::BulkAction, ::Actions::Katello::Repository::Destroy, unpromoted_repos_non_last_affected_repo)
      else
        status = 400
      end
      respond_for_bulk_async :resource => OpenStruct.new(:task => task, :errors => errors), :status => status
    end

    api :POST, "/repositories/bulk/sync", N_("Synchronize repository")
    param :ids, Array, :desc => N_("List of repository ids"), :required => true
    def sync_repositories
      syncable_repositories = @repositories.syncable.has_url
      if syncable_repositories.empty?
        msg = _("Unable to synchronize any repository. You either do not have the permission to"\
                " synchronize or the selected repositories do not have a feed url.")
        fail HttpErrors::UnprocessableEntity, msg
      else
        task = async_task(::Actions::BulkAction,
                          ::Actions::Katello::Repository::Sync,
                          syncable_repositories)

        respond_for_async :resource => task
      end
    end

    api :POST, "/repositories/bulk/reclaim_space", N_("Reclaim space from On Demand repositories")
    param :ids, Array, :desc => N_("List of repository ids"), :required => true
    def reclaim_space_from_repositories
      if @repositories.empty?
        fail _("No repositories selected.")
      end
      repositories = @repositories.select { |repo| repo.download_policy == ::Katello::RootRepository::DOWNLOAD_ON_DEMAND }
      if repositories.empty?
        fail _("Only On Demand repositories may have space reclaimed.")
      end
      task = async_task(::Actions::BulkAction,
                        ::Actions::Pulp3::Repository::ReclaimSpace,
                        repositories)

      respond_for_async :resource => task
    end

    private

    def find_repositories
      params.require(:ids)
      @repositories = Repository.readable.where(:id => params[:ids])
    end
  end
end