class Chef::ChefFS::FileSystem::RestListEntry

Public Class Methods

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

Public Instance Methods

_read_hash() click to toggle source
# File lib/chef/chef_fs/file_system/rest_list_entry.rb, line 86
def _read_hash
  begin
    # Minimize the value (get rid of defaults) so the results don't look terrible
    minimize_value(root.get_json(api_path))
  rescue Timeout::Error => e
    raise Chef::ChefFS::FileSystem::OperationFailedError.new(:read, self, e), "Timeout reading: #{e}"
  rescue Net::HTTPServerException => 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
end
api_child_name() click to toggle source
# File lib/chef/chef_fs/file_system/rest_list_entry.rb, line 38
def api_child_name
  if name.length < 5 || name[-5,5] != ".json"
    raise "Invalid name #{path}: must end in .json"
  end
  name[0,name.length-5]
end
api_path() click to toggle source
# File lib/chef/chef_fs/file_system/rest_list_entry.rb, line 45
def api_path
  "#{parent.api_path}/#{api_child_name}"
end
chef_object() click to toggle source
# File lib/chef/chef_fs/file_system/rest_list_entry.rb, line 101
def chef_object
  # REST will inflate the Chef object using json_class
  data_handler.json_class.json_create(read)
end
compare_to(other) click to toggle source
# File lib/chef/chef_fs/file_system/rest_list_entry.rb, line 110
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_hash
  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 = JSON.parse(other_value_json, :create_additions => false)
  rescue JSON::ParserError => 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)

  [ value == other_value, value_json, other_value_json ]
end
data_handler() click to toggle source
# File lib/chef/chef_fs/file_system/rest_list_entry.rb, line 34
def data_handler
  parent.data_handler
end
delete(recurse) click to toggle source
# File lib/chef/chef_fs/file_system/rest_list_entry.rb, line 68
def delete(recurse)
  begin
    rest.delete(api_path)
  rescue Timeout::Error => e
    raise Chef::ChefFS::FileSystem::OperationFailedError.new(:delete, self, e), "Timeout deleting: #{e}"
  rescue Net::HTTPServerException => 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
end
environment() click to toggle source
# File lib/chef/chef_fs/file_system/rest_list_entry.rb, line 53
def environment
  parent.environment
end
exists?() click to toggle source
# File lib/chef/chef_fs/file_system/rest_list_entry.rb, line 57
def exists?
  if @exists.nil?
    begin
      @exists = parent.children.any? { |child| child.name == name }
    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/rest_list_entry.rb, line 106
def minimize_value(value)
  data_handler.minimize(data_handler.normalize(value, self), self)
end
org() click to toggle source
# File lib/chef/chef_fs/file_system/rest_list_entry.rb, line 49
def org
  parent.org
end
read() click to toggle source
# File lib/chef/chef_fs/file_system/rest_list_entry.rb, line 82
def read
  Chef::JSONCompat.to_json_pretty(_read_hash)
end
rest() click to toggle source
# File lib/chef/chef_fs/file_system/rest_list_entry.rb, line 142
def rest
  parent.rest
end
write(file_contents) click to toggle source
# File lib/chef/chef_fs/file_system/rest_list_entry.rb, line 146
def write(file_contents)
  begin
    object = JSON.parse(file_contents, :create_additions => false)
  rescue JSON::ParserError => 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), "#{error}"
    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::HTTPServerException => 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