class Listen::Directory

TODO: refactor (turn it into a normal object, cache the stat, etc)

Public Class Methods

_async_changes(snapshot, path, previous, options) click to toggle source
# File lib/listen/directory.rb, line 50
def self._async_changes(snapshot, path, previous, options)
  fail "Not a Pathname: #{path.inspect}" unless path.respond_to?(:children)
  previous.each do |entry, data|
    # TODO: this is a hack with insufficient testing
    type = data.key?(:mtime) ? :file : :dir
    rel_path_s = (path + entry).to_s
    _change(snapshot, type, rel_path_s, options)
  end
end
_change(snapshot, type, path, options) click to toggle source
# File lib/listen/directory.rb, line 60
def self._change(snapshot, type, path, options)
  return snapshot.invalidate(type, path, options) if type == :dir

  # Minor param cleanup for tests
  # TODO: use a dedicated Event class
  opts = options.dup
  opts.delete(:recursive)
  snapshot.invalidate(type, path, opts)
end
detect_type(full_path) click to toggle source
# File lib/listen/directory.rb, line 70
def self.detect_type(full_path)
  # TODO: should probably check record first
  stat = ::File.lstat(full_path.to_s)
  stat.directory? ? :dir : :file
rescue Errno::ENOENT
  # TODO: ok, it should really check the record here
  # report as dir for scanning
  :dir
end
scan(snapshot, rel_path, options) click to toggle source
# File lib/listen/directory.rb, line 6
def self.scan(snapshot, rel_path, options)
  record = snapshot.record
  dir = Pathname.new(record.root)
  previous = record.dir_entries(rel_path)

  record.add_dir(rel_path)

  # TODO: use children(with_directory: false)
  path = dir + rel_path
  current = Set.new(path.children)

  Listen::Logger.debug do
    format('%s: %s(%s): %s -> %s',
           (options[:silence] ? 'Recording' : 'Scanning'),
           rel_path, options.inspect, previous.inspect, current.inspect)
  end

  current.each do |full_path|
    type = detect_type(full_path)
    item_rel_path = full_path.relative_path_from(dir).to_s
    _change(snapshot, type, item_rel_path, options)
  end

  # TODO: this is not tested properly
  previous = previous.reject { |entry, _| current.include? path + entry }

  _async_changes(snapshot, Pathname.new(rel_path), previous, options)

rescue Errno::ENOENT, Errno::EHOSTDOWN
  record.unset_path(rel_path)
  _async_changes(snapshot, Pathname.new(rel_path), previous, options)

rescue Errno::ENOTDIR
  # TODO: path not tested
  record.unset_path(rel_path)
  _async_changes(snapshot, path, previous, options)
  _change(snapshot, :file, rel_path, options)
rescue
  Listen::Logger.warn do
    format('scan DIED: %s:%s', $ERROR_INFO, $ERROR_POSITION * "\n")
  end
  raise
end