Contents

$:.unshift File.expand_path('../../vendor', __FILE__)
require 'rucola/fsevents'

require 'kicker/callback_chain'
require 'kicker/growl'
require 'kicker/options'
require 'kicker/utils'
require 'kicker/validate'

require 'kicker/recipes/could_not_handle_file'
require 'kicker/recipes/execute_cli_command'

class Kicker
  class << self
    attr_accessor :latency
    
    def latency
      @latency ||= 1.5
    end
    
    def paths
      @paths ||= %w{ . }
    end
    
    def run(argv = ARGV)
      load '.kick' if File.exist?('.kick')
      new(parse_options(argv)).start
    end
  end
  
  attr_reader :latency, :paths, :last_event_processed_at
  
  def initialize(options)
    @paths = (options[:paths] ? options[:paths] : Kicker.paths).map { |path| File.expand_path(path) }
    
    @latency       = options[:latency] || self.class.latency
    @use_growl     = options[:growl]
    @growl_command = options[:growl_command]
    
    finished_processing!
  end
  
  def start
    validate_options!
    
    log "Watching for changes on: #{@paths.join(', ')}"
    log ''
    
    run_watch_dog!
    start_growl! if @use_growl
    
    OSX.CFRunLoopRun
  end
  
  private
  
  def run_watch_dog!
    dirs = @paths.map { |path| File.directory?(path) ? path : File.dirname(path) }
    watch_dog = Rucola::FSEvents.start_watching(dirs, :latency => @latency) { |events| process(events) }
    
    trap('INT') do
      log "Cleaning up…"
      watch_dog.stop
      exit
    end
  end
  
  def finished_processing!
    @last_event_processed_at = Time.now
  end
  
  def changed_files(events)
    events.map do |event|
      event.files.select { |file| File.mtime(file) > @last_event_processed_at }
    end.flatten
  end
  
  def process(events)
    unless (files = changed_files(events)).empty?
      full_chain.call(self, files)
      finished_processing!
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
alloy-kicker-1.9.1	lib/kicker.rb
alloy-kicker-1.9.2	lib/kicker.rb
alloy-kicker-1.9.3	lib/kicker.rb