Class: KatelloApi::Base

Inherits:

Object

• Object
• KatelloApi::Base

Defined in:

lib/katello_api/base.rb

Direct Known Subclasses

Resources::About, Resources::ActivationKey, Resources::Architecture, Resources::Changeset, Resources::ChangesetsContent, Resources::ComputeResource, Resources::ConfigTemplate, Resources::ContentUpload, Resources::ContentView, Resources::ContentViewDefinition, Resources::Crl, Resources::CustomInfo, Resources::Distribution, Resources::Distributor, Resources::Domain, Resources::Environment, Resources::Erratum, Resources::Filter, Resources::FilterRule, Resources::GpgKey, Resources::HardwareModel, Resources::Organization, Resources::OrganizationDefaultInfo, Resources::Package, Resources::Permission, Resources::Ping, Resources::Product, Resources::Provider, Resources::PuppetModule, Resources::Repository, Resources::RepositorySet, Resources::Role, Resources::RoleLdapGroup, Resources::SmartProxy, Resources::Statu, Resources::Status, Resources::Subnet, Resources::Subscription, Resources::Sync, Resources::SyncPlan, Resources::System, Resources::SystemErratum, Resources::SystemGroup, Resources::SystemGroupErratum, Resources::SystemGroupPackage, Resources::SystemPackage, Resources::SystemsBulkAction, Resources::Task, Resources::Template, Resources::TemplatesContent, Resources::Uebercert, Resources::User

Constant Summary

API_VERSION =

"2"

Instance Attribute Summary

• #client ⇒ Object readonly

  Returns the value of attribute client.

• #config ⇒ Object readonly

  Returns the value of attribute config.

Class Method Summary

• .doc ⇒ Object
• .method_doc(method) ⇒ Object
• .validation_hash(method) ⇒ Object

Instance Method Summary

• #http_call(http_method, path, params = { }, headers = { }) ⇒ Object
• #initialize(config, options = {}) ⇒ Base constructor

  A new instance of Base.

• #perform_call(method_name, params, headers) ⇒ Object
• #validate_params!(params, rules) ⇒ Object

Constructor Details

#initialize(config, options = {}) ⇒ Base

Returns a new instance of Base.

# File 'lib/katello_api/base.rb', line 31

def initialize(config, options = {})
  headers = { :content_type => 'application/json',
              :accept => "application/json,version=#{API_VERSION}" }

  @client = RestClient::Resource.new(
      "#{config[:base_url]}/katello",
      { :user => config[:username],
        :password => config[:password],
        :oauth => config[:oauth],
        :headers => headers
      }.merge(options))
  @config = config
end

Instance Attribute Details

#client ⇒ Object (readonly)

Returns the value of attribute client.

# File 'lib/katello_api/base.rb', line 29

def client
  @client
end

#config ⇒ Object (readonly)

Returns the value of attribute config.

# File 'lib/katello_api/base.rb', line 29

def config
  @config
end

Class Method Details

.doc ⇒ Object

Raises:

• (NotImplementedError)

# File 'lib/katello_api/base.rb', line 68

def self.doc
  raise NotImplementedError
end

.method_doc(method) ⇒ Object

# File 'lib/katello_api/base.rb', line 76

def self.method_doc(method)
  method_docs[method.to_s]
end

.validation_hash(method) ⇒ Object

# File 'lib/katello_api/base.rb', line 72

def self.validation_hash(method)
  validation_hashes[method.to_s]
end

Instance Method Details

#http_call(http_method, path, params = { }, headers = { }) ⇒ Object

# File 'lib/katello_api/base.rb', line 54

def http_call(http_method, path, params = { }, headers = { })
  headers ||= { }

  args = [http_method]
  if %w[post put].include?(http_method.to_s)
    args << params.to_json
  else
    headers[:params] = params if params
  end

  args << headers if headers
  process_data client[path].send(*args)
end

#perform_call(method_name, params, headers) ⇒ Object

# File 'lib/katello_api/base.rb', line 45

def perform_call(method_name, params, headers)
  method_doc = self.class.method_doc(method_name)
  check_params params, :allowed => method_doc['params'].any?, :method => method_name
  method_apis = method_doc['apis']
  api = find_suitable_api_call(method_apis, params)
  url, params = fill_params_in_url api['api_url'], params
  return http_call(api['http_method'].downcase, url, params, headers)
end

#validate_params!(params, rules) ⇒ Object

Raises:

• (ArgumentError)

# File 'lib/katello_api/base.rb', line 80

def validate_params!(params, rules)
  return unless params.is_a?(Hash)

  invalid_keys = params.keys.map(&:to_s) - (rules.is_a?(Hash) ? rules.keys : rules)
  raise ArgumentError, "Invalid keys: #{invalid_keys.join(", ")}" unless invalid_keys.empty?

  if rules.is_a? Hash
    rules.each do |key, sub_keys|
      validate_params!(params[key], sub_keys) if params[key]
    end
  end
end