module Api
  module V2
    class SccProductsController < ::Api::V2::BaseController
      include Api::Version2
      include Foreman::Controller::AutoCompleteSearch

      resource_description do
        resource_id 'scc_products'
        api_version 'v2'
        api_base_url '/api/v2'
      end

      before_action :find_resource, :only => [:show, :subscribe]

      def metadata_subtotal
        if @scc_products.present?
          @scc_products.count
        else
          super
        end
      end

      api :GET, '/scc_accounts/:scc_account_id/scc_products/', N_('List products for an scc_account')
      param :scc_account_id, :identifier_dottable, :required => true
      param :subscribed_only, :bool, :required => false, :desc => N_('Show subscribed products only')
      param_group :search_and_pagination, ::Api::V2::BaseController

      def index
        scope = resource_scope
        scope = scope.where.not(:product_id => nil) if ::Foreman::Cast.to_bool(params[:subscribed_only])
        scope = scope.where(:organization => params[:organization_id]) if params[:organization_id].present?
        @scc_products = scope.search_for(params[:search], :order => params[:order]).paginate(:page => params[:page])
      end

      api :GET, '/scc_accounts/:scc_account_id/scc_products/:id/', N_('Show an scc_account product')
      param :id, :identifier_dottable, :required => true
      param :scc_account_id, :identifier_dottable, :required => true
      def show; end

      api :PUT, '/scc_accounts/:scc_account_id/scc_products/:id/subscribe/', N_('Subscribe product')
      param :id, :identifier_dottable, :required => true
      param :scc_account_id, :identifier_dottable, :required => true
      def subscribe
        subcribe_task = ForemanTasks.async_task(::Actions::SccManager::SubscribeProduct, @scc_product, {}) if @scc_product
        respond_to do |format|
          if subcribe_task
            format.json { render json: subcribe_task.to_json, status: :ok }
          else
            format.json { render json: 'Failed to subscribe product'.to_json, status: :not_found }
          end
        end
      rescue ::Foreman::Exception => e
        render json: { error: ('Failed to add task to queue: %s' % e).to_s }, status: :unprocessable_entity
      rescue ForemanTasks::Lock::LockConflict => e
        render json: { error: ('Lock on SCC account already taken: %s' % e).to_s }, status: :unprocessable_entity
      end

      private

      def find_resource
        @scc_account = ::SccAccount.find(params[:scc_account_id])
        @scc_product = @scc_account.scc_products.find(params[:id])
      end

      def action_permission
        case params[:action]
        when 'subscribe'
          :subscribe
        else
          super
        end
      end
    end
  end
end