Broom

A simple module to help monitor a directory for new files and perform an action on each new file. Broom periodically sweeps a directory, caching each file and its last modification time. After each sweep, Broom iterates through the cache and yields only the files that have a current modification time that matches the cached modification time. In the event of an error, Broom gracefully sweeps the file to a failure dustpan. Else, the file is swept to a success dustpan.

Broom depends on the following directory structure, which can be modified using the 'success_dir' and 'failure_dir' options.

/path/to/directory
/path/to/directory/_success
/path/to/directory/_failure

gem install broom

Broom.sweep('/dropbox') do |path, dirname, basename, extname|
  Resque.enqueue(Job, "#{dirname}/_success/#{basename}")
end

threads = []

threads << Thread.new do
  Broom.sweep('/foo') do |path, dirname, basename, extname|
    # do something
  end
end

threads << Thread.new do
  Broom.sweep('/bar') do |path, dirname, basename, extname|
    # do something
  end
end

threads.each { |x| x.join }