class Chef::ChefFS::FileSystem::ChefServer::RestListEntry

Public Class Methods

new(name, parent, exists = nil) click to toggle source
# File lib/chef/chef_fs/file_system/chef_server/rest_list_entry.rb, line 30
def initialize(name, parent, exists = nil)
  super(name, parent)
  @exists = exists
  @this_object_cache = nil
end

Public Instance Methods

_read_json() click to toggle source
# File lib/chef/chef_fs/file_system/chef_server/rest_list_entry.rb, line 107
def _read_json
  @this_object_cache ? JSON.parse(@this_object_cache) : root.get_json(api_path)
rescue Timeout::Error => e
  raise Chef::ChefFS::FileSystem::OperationFailedError.new(:read, self, e, "Timeout reading: #{e}")
rescue Net::HTTPClientException => e
  if $!.response.code == "404"
    raise Chef::ChefFS::FileSystem::NotFoundError.new(self, e)
  else
    raise Chef::ChefFS::FileSystem::OperationFailedError.new(:read, self, e, "HTTP error reading: #{e}")
  end
end
api_child_name() click to toggle source
# File lib/chef/chef_fs/file_system/chef_server/rest_list_entry.rb, line 40
def api_child_name
  if %w{ .rb .json }.include? File.extname(name)
    File.basename(name, ".*")
  else
    name
  end
end
api_error_text(response) click to toggle source
# File lib/chef/chef_fs/file_system/chef_server/rest_list_entry.rb, line 201
def api_error_text(response)
  Chef::JSONCompat.parse(response.body)["error"].join("\n")
rescue
  response.body
end
api_path() click to toggle source
# File lib/chef/chef_fs/file_system/chef_server/rest_list_entry.rb, line 48
def api_path
  "#{parent.api_path}/#{api_child_name}"
end
chef_object() click to toggle source
# File lib/chef/chef_fs/file_system/chef_server/rest_list_entry.rb, line 119
def chef_object
  # REST will inflate the Chef object using json_class
  data_handler.json_class.from_hash(read)
end
compare_to(other) click to toggle source
# File lib/chef/chef_fs/file_system/chef_server/rest_list_entry.rb, line 132
def compare_to(other)
  # TODO this pair of reads can be parallelized

  # Grab the other value
  begin
    other_value_json = other.read
  rescue Chef::ChefFS::FileSystem::NotFoundError
    return [ nil, nil, :none ]
  end

  # Grab this value
  begin
    value = _read_json
  rescue Chef::ChefFS::FileSystem::NotFoundError
    return [ false, :none, other_value_json ]
  end

  # Minimize (and normalize) both values for easy and beautiful diffs
  value = minimize_value(value)
  value_json = Chef::JSONCompat.to_json_pretty(value)
  begin
    other_value = Chef::JSONCompat.parse(other_value_json)
  rescue Chef::Exceptions::JSON::ParseError => e
    Chef::Log.warn("Parse error reading #{other.path_for_printing} as JSON: #{e}")
    return [ nil, value_json, other_value_json ]
  end
  other_value = minimize_value(other_value)
  other_value_json = Chef::JSONCompat.to_json_pretty(other_value)

  # free up cache - it will be hydrated on next check for exists?
  @this_object_cache = nil

  [ value == other_value, value_json, other_value_json ]
end
data_handler() click to toggle source
# File lib/chef/chef_fs/file_system/chef_server/rest_list_entry.rb, line 36
def data_handler
  parent.data_handler
end
delete(recurse) click to toggle source
# File lib/chef/chef_fs/file_system/chef_server/rest_list_entry.rb, line 88
def delete(recurse)
  # free up cache - it will be hydrated on next check for exists?
  @this_object_cache = nil
  rest.delete(api_path)
rescue Timeout::Error => e
  raise Chef::ChefFS::FileSystem::OperationFailedError.new(:delete, self, e, "Timeout deleting: #{e}")
rescue Net::HTTPClientException => e
  if e.response.code == "404"
    raise Chef::ChefFS::FileSystem::NotFoundError.new(self, e)
  else
    raise Chef::ChefFS::FileSystem::OperationFailedError.new(:delete, self, e, "Timeout deleting: #{e}")
  end
end
display_name() click to toggle source
# File lib/chef/chef_fs/file_system/chef_server/rest_list_entry.rb, line 58
def display_name
  File.basename(display_path)
end
display_path() click to toggle source
# File lib/chef/chef_fs/file_system/chef_server/rest_list_entry.rb, line 52
def display_path
  pth = api_path.start_with?("/") ? api_path : "/#{api_path}"
  File.extname(pth).empty? ? pth + ".json" : pth
end
Also aliased as: path_for_printing
environment() click to toggle source
# File lib/chef/chef_fs/file_system/chef_server/rest_list_entry.rb, line 66
def environment
  parent.environment
end
exists?() click to toggle source
# File lib/chef/chef_fs/file_system/chef_server/rest_list_entry.rb, line 70
def exists?
  if @exists.nil?
    begin
      @this_object_cache = rest.get(api_path)
      @exists = true
    rescue Net::HTTPClientException => e
      if e.response.code == "404"
        @exists = false
      else
        raise
      end
    rescue Chef::ChefFS::FileSystem::NotFoundError
      @exists = false
    end
  end
  @exists
end
minimize_value(value) click to toggle source
# File lib/chef/chef_fs/file_system/chef_server/rest_list_entry.rb, line 124
def minimize_value(value)
  data_handler.minimize(normalize_value(value), self)
end
normalize_value(value) click to toggle source
# File lib/chef/chef_fs/file_system/chef_server/rest_list_entry.rb, line 128
def normalize_value(value)
  data_handler.normalize(value, self)
end
org() click to toggle source
# File lib/chef/chef_fs/file_system/chef_server/rest_list_entry.rb, line 62
def org
  parent.org
end
path_for_printing()
Alias for: display_path
read() click to toggle source
# File lib/chef/chef_fs/file_system/chef_server/rest_list_entry.rb, line 102
def read
  # Minimize the value (get rid of defaults) so the results don't look terrible
  Chef::JSONCompat.to_json_pretty(normalize_value(_read_json))
end
rest() click to toggle source
# File lib/chef/chef_fs/file_system/chef_server/rest_list_entry.rb, line 167
def rest
  parent.rest
end
write(file_contents) click to toggle source
# File lib/chef/chef_fs/file_system/chef_server/rest_list_entry.rb, line 171
def write(file_contents)
  # free up cache - it will be hydrated on next check for exists?
  @this_object_cache = nil

  begin
    object = Chef::JSONCompat.parse(file_contents)
  rescue Chef::Exceptions::JSON::ParseError => e
    raise Chef::ChefFS::FileSystem::OperationFailedError.new(:write, self, e, "Parse error reading JSON: #{e}")
  end

  if data_handler
    object = data_handler.normalize_for_put(object, self)
    data_handler.verify_integrity(object, self) do |error|
      raise Chef::ChefFS::FileSystem::OperationFailedError.new(:write, self, nil, error.to_s)
    end
  end

  begin
    rest.put(api_path, object)
  rescue Timeout::Error => e
    raise Chef::ChefFS::FileSystem::OperationFailedError.new(:write, self, e, "Timeout writing: #{e}")
  rescue Net::HTTPClientException => e
    if e.response.code == "404"
      raise Chef::ChefFS::FileSystem::NotFoundError.new(self, e)
    else
      raise Chef::ChefFS::FileSystem::OperationFailedError.new(:write, self, e, "HTTP error writing: #{e}")
    end
  end
end