stephan-nordnes-eriksen/feather_watch

module FeatherWatch::Core
    class LinuxWatcher
        def initialize(directories, callback, verbose= false, silence_exceptions= false)
            puts "Initializing linux watcher" if @verbose

            @verbose = verbose
            @silence_exceptions = silence_exceptions
            
            @notifiers = []
            directories = [directories] if directories.is_a?(String)
            
            setup_notifier(directories, callback, verbose, silence_exceptions)
        end
        
        def start
            puts "Starting linux watcher" if @verbose
            @notifiers.each do |notifier|
                Thread.new do
                    notifier.run
                end
            end
        end

        def stop
            puts "Stopping linux watcher" if @verbose
            @notifiers.each do |notifier|
                notifier.stop
            end
        end

        private

        def setup_notifier(directories, callback, verbose, silence_exceptions)
            directories.each do |dir|
                notifier = INotify::Notifier.new
                @notifiers << notifier
                #Avaliable events: :access, :attrib, :close_write, :close_nowrite, :create, :delete, :delete_self, :ignored, :modify, :move_self, :moved_from, :moved_to, :open
                notifier.watch(dir, :recursive, :create, :attrib, :delete, :close_write, :delete_self, :modify, :move_self, :moved_from, :moved_to) do |event|
                    begin
                        status = nil
                        if    !([:attrib, :close_write, :modify] & event.flags ).empty?
                            status = :modified
                        elsif !([:moved_to]                      & event.flags ).empty?
                            status = :added
                        elsif !([:moved_from]                    & event.flags ).empty?
                            status = :removed
                        elsif !([:create]                        & event.flags ).empty?
                            status = :added
                        elsif !([:delete, :delete_self]          & event.flags ).empty?
                            status = :removed
                        end
                        
                        if status != nil
                            puts "File #{status.to_s}: #{event.absolute_name}"   if @verbose
                            callback.call({status: status, file: event.absolute_name, event: event})
                        else
                            STDERR.puts "Unhandled status flags: #{event.flags} for file #{event.absolute_name}" if @verbose
                        end
                    rescue Exception => e
                        unless @silence_exceptions
                            FeatherWatch::Core::Common.print_error(e)
                        end
                    end
                end
            end
        end
    end
end