module Actions
  module Pulp
    module Repository
      class Refresh < Pulp::Abstract
        input_format do
          param :capsule_id
        end

        def plan(repository, input = {})
          update_or_associate_importer(input[:capsule_id], repository)
          update_or_associate_distributors(input[:capsule_id], repository)
        end

        def update_or_associate_importer(capsule_id, repository)
          existing_importers = pulp_extensions(capsule_id).repository.retrieve_with_details(repository.pulp_id)["importers"]
          importer = capsule_id ? repository.generate_importer(true) : repository.generate_importer
          importer_config = capsule_id ? importer.config.merge!(importer_certs(repository)) : importer.config
          found = existing_importers.find { |i| i['importer_type_id'] == importer.id }

          if found
            plan_action(::Actions::Pulp::Repository::UpdateImporter,
                        :repo_id => repository.pulp_id,
                        :id => found['id'],
                        :config => importer_config,
                        :capsule_id => capsule_id
                        )
          else
            plan_action(::Actions::Pulp::Repository::AssociateImporter,
                        :repo_id => repository.pulp_id,
                        :type_id => repository.importers.first['importer_type_id'],
                        :config => importer_config,
                        :capsule_id => input[:capsule_id],
                        :hash => { :importer_id => importer.id }
                        )
          end
        end

        def update_or_associate_distributors(capsule_id, repository)
          concurrence do
            existing_distributors = pulp_extensions(capsule_id).repository.retrieve_with_details(repository.pulp_id)["distributors"]
            repository.generate_distributors.each do |distributor|
              found = existing_distributors.find { |i| i['distributor_type_id'] == distributor.type_id }
              if found
                plan_action(::Actions::Pulp::Repository::RefreshDistributor,
                            :repo_id => repository.pulp_id,
                            :id => found['id'],
                            :config => distributor.config,
                            :capsule_id => capsule_id
                            )
              else
                plan_action(::Actions::Pulp::Repository::AssociateDistributor,
                            :repo_id => repository.pulp_id,
                            :type_id => distributor.type_id,
                            :config => distributor.config,
                            :capsule_id => capsule_id,
                            :hash => { :distributor_id => distributor.id }
                            )
              end
            end
          end
        end

        def importer_certs(repository)
          ueber_cert = ::Cert::Certs.ueber_cert(repository.organization)

          {
            :ssl_ca_cert => ::Cert::Certs.ca_cert,
            :ssl_client_cert => ueber_cert[:cert],
            :ssl_client_key => ueber_cert[:key]
          }
        end
      end
    end
  end
end