Contents

module Cumuli
  class App
    DEFAULT_WAIT_TIME = 5 #120
    SIGNALS = ['TERM', 'INT', 'HUP']

    attr_accessor :env, :wait_time, :app_dir, :log_dir

    def initialize(options={})
      @env = options[:env]
      @wait_time = options[:wait_time]
      @log_dir = options[:log_dir] || "#{Dir.pwd}/log"
      @app_dir = options[:app_dir] || Dir.pwd
    end

    def start
      return if foreman_process.started?

      Dir.chdir(app_dir) do
        listen_for_signals
        logger.print "Starting ..."
        foreman_process.start
        wait_for_apps if wait?
      end
    end

    def stop
      if foreman_process.started?
        foreman_process.stop
        wait_for_apps('stop') if wait?
        @foreman_process = nil
      end
    end

    def logger
      @logger = StdoutLogger.new
    end

    def foreman_process
      @foreman_process ||= Spawner.new(env, log_dir)
    end

    def apps
      @apps ||= Procs.new(app_dir).apps
    end

    def process_pids
      PS.new.family
    end

    def pid
      foreman_process.group_id
    end

    def wait?
      wait_time && wait_time > 0
    end

    def listen_for_signals
      SIGNALS.each do |signal|
        trap(signal) do
          puts "#{self.class}: trapped signal #{signal} in #{Process.pid} ... stopping"
          stop
        end
      end
    end

    def wait_for_apps(direction = 'start')
      logger.add_space
      apps.each do |app|
        log_and_wait(app, direction)
      end
      logger.add_space
    end

    def log_and_wait(app, direction)
      timeout = wait_time || DEFAULT_WAIT_TIME
      logger.print "#{direction}: waiting for app named '#{app.name}' at #{app.url}"
      app.send("wait_for_#{direction}", timeout)
      logger.print "#{direction}: application '#{app.name}' on #{app.url} complete"
      logger.add_space
    rescue Exception => e
      stop
      raise e
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
cumuli-0.3.4	lib/cumuli/app/app.rb