class Puppet::Indirector::Msgpack

# File lib/puppet/indirector/msgpack.rb, line 29
def destroy(request)
  Puppet::FileSystem.unlink(path(request.key))
rescue => detail
  unless detail.is_a? Errno::ENOENT
    raise Puppet::Error, "Could not destroy #{self.name} #{request.key}: #{detail}", detail.backtrace
  end
  1                           # emulate success...
end

# File lib/puppet/indirector/msgpack.rb, line 16
def find(request)
  load_msgpack_from_file(path(request.key), request.key)
end

# File lib/puppet/indirector/msgpack.rb, line 45
def path(name, ext = '.msgpack')
  if name =~ Puppet::Indirector::BadNameRegexp then
    Puppet.crit("directory traversal detected in #{self.class}: #{name.inspect}")
    raise ArgumentError, "invalid key"
  end

  base = Puppet.run_mode.master? ? Puppet[:server_datadir] : Puppet[:client_datadir]
  File.join(base, self.class.indirection_name.to_s, name.to_s + ext)
end

# File lib/puppet/indirector/msgpack.rb, line 20
def save(request)
  filename = path(request.key)
  FileUtils.mkdir_p(File.dirname(filename))

  Puppet::Util.replace_file(filename, 0660) {|f| f.print to_msgpack(request.instance) }
rescue TypeError => detail
  Puppet.log_exception "Could not save #{self.name} #{request.key}: #{detail}"
end

# File lib/puppet/indirector/msgpack.rb, line 38
def search(request)
  Dir.glob(path(request.key)).collect do |file|
    load_msgpack_from_file(file, request.key)
  end
end

# File lib/puppet/indirector/msgpack.rb, line 9
def initialize(*args)
  if ! Puppet.features.msgpack?
    raise "MessagePack terminus not supported without msgpack library"
  end
  super
end