module Katello
  class Api::V2::EnvironmentsController < Api::V2::ApiController
    include Katello::Concerns::FilteredAutoCompleteSearch
    resource_description do
      resource_id 'lifecycle_environments'
      description <<-DESC
        # Description

        An environment is a basic organization structure that groups hosts,
        products, repositories, etc.  Every host belongs to one environment
        and it's isolated inside so that it can see only content that is in its
        environment.

        ## Chains

        Environments are ordered into chains and their content (products,
        repositories, tempaltes, packages) can be moved to an environment only from its
        prior environment. You can have for example chain like:

            Library -> Development -> Testing -> Production

        Each change in an environment is done through a changeset in an action
        called promotion.

        ## Library

        Library is a special environment that has no ascendant: All the content
        starts in this environment. More chains can start from the library environment but
        no further branching of a chain is enabled.
      DESC

      api_version 'v2'
      api_base_url "/katello/api"
    end

    respond_to :json
    before_action :find_organization, :only => [:create, :paths, :auto_complete_search]
    before_action :find_optional_organization, :only => [:index, :show, :update, :destroy]
    before_action :find_prior, :only => [:create]
    before_action :find_authorized_katello_resource, :only => [:show, :update, :destroy, :repositories]
    before_action :find_content_view, :only => [:repositories]
    before_action :find_path, :only => [:create]

    wrap_parameters :include => (KTEnvironment.attribute_names + %w(prior prior_id new_name))

    api :GET, "/environments", N_("List environments in an organization")
    api :GET, "/organizations/:organization_id/environments", N_("List environments in an organization")
    param :organization_id, :number, :desc => N_("organization identifier")
    param :library, [true, false], :desc => N_("set true if you want to see only library environments")
    param :name, String, :desc => N_("filter only environments containing this name")
    param :label, String, :desc => N_("filter only environments containing this label"), :required => false
    param_group :search, Api::V2::ApiController
    add_scoped_search_description_for(KTEnvironment)
    def index
      respond(:collection => scoped_search(index_relation.distinct, :name, :asc, :resource_class => KTEnvironment))
    end

    def index_relation
      query = KTEnvironment.readable
      query = query.where(organization: @organization) if @organization
      query = query.where(:name => params[:name]) if params[:name]
      query = query.where(:label => params[:label]) if params[:label]
      query = query.where(:library => params[:library]) if params[:library]
      query
    end

    api :GET, "/environments/:id", N_("Show an environment")
    api :GET, "/organizations/:organization_id/environments/:environment_id", N_("Show an environment")
    param :id, :number, :desc => N_("ID of the environment"), :required => true
    param :organization_id, :number, :desc => N_("ID of the organization")
    def show
      respond(resource: @environment)
    end

    api :POST, "/environments", N_("Create an environment")
    api :POST, "/organizations/:organization_id/environments", N_("Create an environment in an organization")
    param :organization_id, :number, :desc => N_("name of organization"), :required => true
    param :name, String, :desc => N_("name of the environment"), :required => true
    param :label, String, :desc => N_("label of the environment"), :required => false
    param :description, String, :desc => N_("description of the environment")
    param :registry_name_pattern, String, :desc => N_("pattern for container image names")
    param :registry_unauthenticated_pull, :bool, :desc => N_("allow unauthenticed pull of container images")
    param :prior_id, Integer, :required => true, :desc => <<-DESC
      ID of an environment that is prior to the new environment in the chain. It has to be
      either the ID of Library or the ID of an environment at the end of a chain.
    DESC
    def create
      create_params = environment_params
      create_params[:label] = labelize_params(create_params)
      create_params[:organization] = @organization
      @environment = @prior.insert_successor(create_params, @path)
      respond
    end

    api :PUT, "/environments/:id", N_("Update an environment")
    api :PUT, "/organizations/:organization_id/environments/:id", N_("Update an environment in an organization")
    param :id, :number, :desc => N_("ID of the environment"), :required => true
    param :organization_id, :number, :desc => N_("name of the organization")
    param :new_name, String, :desc => N_("new name to be given to the environment")
    param :description, String, :desc => N_("description of the environment")
    param :registry_name_pattern, String, :desc => N_("pattern for container image names")
    param :registry_unauthenticated_pull, :bool, :desc => N_("allow unauthenticed pull of container images")
    param :async, :bool, desc: N_("Do not wait for the update action to finish. Default: true")
    def update
      async = ::Foreman::Cast.to_bool(params.fetch(:async, true))
      update_params = environment_params
      fail HttpErrors::BadRequest, _("Can't update the '%s' environment") % "Library" if @environment.library? && update_params.empty?
      update_params[:name] = params[:environment][:new_name] if params[:environment][:new_name]
      @environment.update!(update_params)
      if update_params[:registry_name_pattern] || update_params[:registry_unauthenticated_pull]
        task = send(async ? :async_task : :sync_task, ::Actions::Katello::Environment::PublishContainerRepositories, @environment)
      end

      if params.include?(:async) && async && task
        respond_for_async(resource: task)
      else
        respond
      end
    end

    api :DELETE, "/environments/:id", N_("Destroy an environment")
    api :DELETE, "/organizations/:organization_id/environments/:id", N_("Destroy an environment in an organization")
    param :id, :number, :desc => N_("ID of the environment"), :required => true
    param :organization_id, :number, :desc => N_("organization identifier")
    def destroy
      sync_task(::Actions::Katello::Environment::Destroy, @environment)
      respond_for_destroy
    rescue RuntimeError => e
      raise HttpErrors::BadRequest, e.message
    end

    api :GET, "/organizations/:organization_id/environments/paths", N_("List environment paths")
    param :organization_id, :number, :desc => N_("organization identifier")
    param :content_source_id, :number, :desc => N_("Show whether each lifecycle environment is associated with the given Smart Proxy id.")
    param :permission_type, String, :desc => <<-DESC
      The associated permission type. One of (readable | promotable)
      Default: readable
    DESC
    def paths
      env_paths = if params[:permission_type] == "promotable"
                    @organization.promotable_promotion_paths
                  else
                    @organization.readable_promotion_paths
                  end
      if params[:content_source_id]
        @content_source_id = params[:content_source_id].to_i
        @content_source = SmartProxy.authorized(:view_smart_proxies).find(@content_source_id)
      end
      paths = env_paths.inject([]) do |result, path|
        result << { :environments => [@organization.library] + path.select(&:readable?) }
      end
      paths = [{ :environments => [@organization.library] }] if paths.empty?

      collection = {
        :results => paths,
        :total => paths.size,
        :subtotal => paths.size,
      }
      respond_for_index(:collection => collection, :template => :paths)
    end

    def resource_name
      'environment'
    end

    def resource_class
      Katello::KTEnvironment
    end

    protected

    def find_prior
      prior = params[:environment][:prior] || params.require(:environment).require(:prior_id)
      @prior = KTEnvironment.readable.find(prior)
      fail HttpErrors::NotFound, _("Couldn't find prior-environment '%s'") % prior.to_s if @prior.nil?
      @prior
    end

    def find_path
      path = params[:environment][:path_id] || params[:path_id]
      path ? @path = KTEnvironment.readable.find(path).path : @path = nil
    end

    def environment_params
      if @environment&.library?
        attrs = [:registry_name_pattern, :registry_unauthenticated_pull]
      else
        attrs = [:name, :description, :registry_name_pattern, :registry_unauthenticated_pull]
      end
      attrs << :label if params[:action] == "create"
      params.require(:environment).permit(*attrs)
    end

    def find_content_view
      @content_view = ContentView.readable.find_by(:id => params[:content_view_id])
    end
  end
end