require 'active_support/core_ext/hash'

module Runcible
  module Resources
    # @see https://pulp-dev-guide.readthedocs.org/en/latest/rest-api/content/index.html
    class Content < Runcible::Base
      # Generates the API path for Contents
      #
      # @param  [String]  upload_id  the id of the upload_request
      # @return [String]             the content path, may contain the upload_id if passed
      def upload_path(upload_id = nil)
        upload_id.nil? ? 'content/uploads/' : "content/uploads/#{upload_id}/"
      end

      # Creates an Upload Request
      #
      # Request Body Contents: None
      # @return [RestClient::Response] Pulp returns the upload_id which is used for subsequent operations
      def create_upload_request
        call(:post, upload_path)
      end

      # Upload bits
      #
      # @param  [String]  upload_id  the id of the upload_request returned by create_upload_request
      # @param  [Numeric] offset     offset for file assembly
      # @param  [File]    content    content of the file being uploaded to the server
      # @return  [RestClient::Response] none
      def upload_bits(upload_id, offset, content)
        call(:put, upload_path("#{upload_id}/#{offset}/"), :payload => content)
      end

      # Import into a repository
      #
      # @param  [String]  repo_id       identifies the associated repository
      # @param  [String]  unit_type_id  identifies the type of unit the upload represents
      # @param  [String]  upload_id     the id of the upload_request returned by create_upload_request
      # @param  [Object]  unit_key      unique identifier for the new unit; the contents are contingent
      #                                  on the type of unit being uploaded
      # @param  [Hash]    optional      container for all optional parameters
      # @return [RestClient::Response]  none
      def import_into_repo(repo_id, unit_type_id, upload_id, unit_key, optional = {})
        required = required_params(binding.send(:local_variables), binding)
        call(:post, Repository.path("#{repo_id}/actions/import_upload/"),
                                    :payload => { :required => required, :optional => optional })
      end

      # Delete an upload request
      #
      # @param  [String]  upload_id  the id of the upload_request returned by create_upload_request
      # Query Parameters: None
      # @return [RestClient::Response] none
      def delete_upload_request(upload_id)
        call(:delete, upload_path("#{upload_id}/"))
      end

      # List all upload requests
      #
      # Query Parameters: None
      # @return [RestClient::Response]  the list of IDs for all upload requests
      #                                 on the server; empty list if there are none
      def list_all_requests
        call(:get, upload_path)
      end

      # Generates an api path for orphaned content
      #
      # @param  [String]  type_id  the type id of the orphaned content
      # @return [String]  the content path, may contain the type_id if passed
      def orphan_path(type_id = nil)
        path = 'content/orphans/'
        path << "#{type_id}/" if type_id
        path
      end

      # List all orphaned content optionally by type
      #
      # @param type_id  content unit type (rpm, puppet_module, etc.)
      # @return list of orphaned content
      def list_orphans(type_id = nil)
        call(:get, orphan_path(type_id))
      end

      # Delete all orphaned content optionally by type
      #
      # @param type_id  content unit type (rpm, puppet_module, etc.)
      # @return list of orphaned content
      def remove_orphans(type_id = nil)
        call(:delete, orphan_path(type_id))
      end
    end
  end
end