class Cantemo::Portal::Agent::WatchFolderUtility::Foreman
Public Class Methods
initialize_watch_folder(watch_folder_def)
click to toggle source
# File lib/cantemo/portal/agent/watch_folder_utility/foreman.rb, line 10 def self.initialize_watch_folder(watch_folder_def) case (watch_folder_def['handler'] || '').downcase.gsub(/[-_ ]/, '') when 'asperawatch' wf_class = Envoi::Aspera::WatchService::WatchFolder end wf_class.new(watch_folder_def) end
poll_watch_folder(watch_folder, &block)
click to toggle source
# File lib/cantemo/portal/agent/watch_folder_utility/foreman.rb, line 34 def self.poll_watch_folder(watch_folder, &block) watch_folder.poll(&block) end
poll_watch_folders(watch_folders, &block)
click to toggle source
# File lib/cantemo/portal/agent/watch_folder_utility/foreman.rb, line 38 def self.poll_watch_folders(watch_folders, &block) watch_folders.each { |watch_folder| poll_watch_folder(watch_folder, &block) } end
process_watch_folder_def(watch_folder_def)
click to toggle source
# File lib/cantemo/portal/agent/watch_folder_utility/foreman.rb, line 18 def self.process_watch_folder_def(watch_folder_def) initialize_watch_folder(watch_folder_def) end
process_watch_folder_defs(watch_folder_defs)
click to toggle source
# File lib/cantemo/portal/agent/watch_folder_utility/foreman.rb, line 22 def self.process_watch_folder_defs(watch_folder_defs) if watch_folder_defs.is_a?(Array) watch_folder_defs.map { |watch_folder_def| process_watch_folder_def(watch_folder_def) } elsif watch_folder_defs.is_a?(Hash) watch_folder_defs.map do |name, watch_folder_def| watch_folder_def['path'] ||= name; process_watch_folder_def(watch_folder_def) end else raise "Unhandled format: #{watch_folder_defs.class.name}" end end
run_once(watch_folders, &block)
click to toggle source
# File lib/cantemo/portal/agent/watch_folder_utility/foreman.rb, line 42 def self.run_once(watch_folders, &block) poll_watch_folders(watch_folders, &block) end